将 SQL table 读入 SparklyR

Question

如何使用 SparklyR 将 SQL table 连接到 R？ cheatsheet表示可以使用DBI::dbWriteTable，但没有提到DBI::dbReadTable。假设我的 table 在这里：

driver = "SQL Server Native Client 11.0"
server = "corsql10.corwin.local"
database = "Project_DB"
table = "Participants"

有示例代码的回复优先。谢谢！！

Answer 1

丹,

您可以尝试这样的操作：

install.packages('devtools')
devtools::install_github('imanuelcostigan/RSQLServer')
require(RSQLServer)
require(dplyr)

src <- RSQLServer::src_sqlserver("corsql10.corwin.local", database = "Project_DB")
data <- tbl(src, "Participants")

DBI::dbWriteTable(sc, "spark_Participants", data)

首先，定义来自SQL服务器的数据源。其次，将其写入 Spark。 tbl 应该创建对 SQL 服务器 table 的引用而不将其加载到内存中。看起来 RSQLServer 包没有得到很好的维护，CRAN 将其删除，因为作者没有修复它的错误......所以你将不得不解决它。这是一个很好的资源：Accessing MSSQL Server with R

将 SQL table 读入 SparklyR

Read SQL table into SparklyR

sql

sql-server

r

sparklyr