7

我正在尝试将 R data.frame 写入 Netezza 表。它有大约 55K 行，我设置了 4GB 作为 Java 的内存限制（选项（java.parameters =“-Xmx4096m”））

询问：

insert into MY_TABLE_NAME select * from external 'csv_file_containing_data_frame.csv' using (delim ',' remotesource 'jdbc');

当我从 DbVisualizer 之类的工具运行它时，上面的 SQL 行没有任何问题，但是当我尝试从 RStudio 运行它时出现以下错误。

代码：

driver <- JDBC(driverClass="org.netezza.Driver", classPath = "drivers//nzjdbc.jar", "'")

connWrite <- dbConnect(driver, "jdbc:netezza://DB_SERVER:1234//DB_NAME", username, password)

str_insert_query <- paste(
    "insert into MY_TABLE select * from external '", OutputFile , "' using (delim ',' remotesource 'jdbc');", sep = ""

dbSendQuery(connWrite, str_insert_query[1])

dbDisconnect(connWrite)

错误信息：

Error in .verify.JDBC.result(r, "Unable to retrieve JDBC result set for ",  : 
  Unable to retrieve JDBC result set for insert into MY_TABLE select * from external 'C:/.../csv_file_containing_data_frame.csv' using (delim ',' remotesource 'jdbc'); (netezza.bad.query.result)
  • dbWriteTable 可以工作，但速度太慢以至于无法使用。
  • 试图将 dbSendQuery() 的结果分配给一个变量，但它不起作用。

任何帮助将不胜感激。谢谢！

4

1 回答 1

6

需要使用dbSendUpdate。

dbSendUpdate(connWrite, str_insert_query[1])
于 2017-03-13T17:11:43.520 回答