使用存储的过程在SQL表中插入R数据帧

Question

我在R中有一个数据帧，其中包含10行和7列。有一个存储过程在后台进行少量逻辑检查，然后将数据插入表“ commodity_price”。

library(RMySQL)
#Connection Settings
mydb = dbConnect(MySQL(),
                 user='uid',
                 password='pwd',
                 dbname='database_name',
                 host='localhost')

#Listing the tables
dbListTables(mydb)

f= data.frame(
    location= rep('Bhubaneshwar', 4),
    sourceid= c(8,8,9,2),
    product= c("Ingot", "Ingot", "Sow Ingot", "Alloy Ingot"),
    Specification = c('ie10','ic20','se07','se08'),
Price=c(14668,14200,14280,20980),
currency=rep('INR',4),
uom=rep('INR/MT',4)
)

For multiple rows insert, there's a pre-created stored proc 'PROC_COMMODITY_PRICE_INSERT', which I need to call.


for (i in 1:nrow(f))
{
  dbGetQuery(mydb,"CALL PROC_COMMODITY_PRICE_INSERT(
     paste(f$location[i],',',
f$sourceid[i],',',f$product[i],',',f$Specification[i],',',
f$Price[i],',',f$currency[i],',', f$uom[i],',',@xyz,')',sep='')
  );")
}

我反复出错。

Error in .local(conn, statement, ...) : 
  could not run statement: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '[i],',',
f$sourceid[i],',',f$product[i],',',f$Specification' at line 2

我尝试使用RODBC，但根本没有连接。如何通过调用存储的proc将R数据框中的数据插入“ commodity_price”表中？预先感谢！

Answer 1

这可能是由于您使用了'，这可能有效：

for (i in 1:nrow(f))
{
  dbGetQuery(mydb,paste("CALL PROC_COMMODITY_PRICE_INSERT(",f$location[i],',',
f$sourceid[i],',',f$product[i],',',f$Specification[i],',',
f$Price[i],',',f$currency[i],',', f$uom[i],',',"@xyz",sep='',");"))
}

或单线：

dbGetQuery(mydb,paste0("CALL PROC_COMMODITY_PRICE_INSERT('",apply(f, 1, paste0, collapse = "', '"),"');"))

Answer 2

尝试for循环：

for (i in 1:nrow(f))
{
  dbGetQuery(mydb,paste("CALL PROC_COMMODITY_PRICE_INSERT(","'",f$location[i],"'",',',"'",
f$sourceid[i],"'",',',"'",f$product[i],"'",',',"'",f$Specification[i],"'",',',"'",
f$Price[i],"'",',',"'",f$currency[i],"'",',',"'",f$uom[i],"'",',','@xyz',sep='',");"))
}