我试图将R data.frame写入Netezza表。它有大约5.5万行,并且我将4GB设置为Java的内存限制(选项(java.parameters =“ -Xmx4096m”))
查询:
insert into MY_TABLE_NAME select * from external 'csv_file_containing_data_frame.csv' using (delim ',' remotesource 'jdbc');
Run Code Online (Sandbox Code Playgroud)
当我从诸如DbVisualizer之类的工具运行SQL时,上面的SQL 可以正常工作,但是当我尝试从RStudio运行它时出现以下错误。
R代码:
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)
Run Code Online (Sandbox Code Playgroud)
错误信息:
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)
Run Code Online (Sandbox Code Playgroud)
任何帮助将不胜感激。谢谢!
需要使用dbSendUpdate。
dbSendUpdate(connWrite, str_insert_query[1])
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
7125 次 |
| 最近记录: |