r - 使用 r 编写和更新 DB2 表

Question

我不知道如何在 R 中更新现有的 DB2 数据库或更新其中的单个值。

除了非常笼统的信息外，我在网上找不到太多关于这个主题的信息，但没有具体的例子。

        library(RJDBC)

        teachersalaries=data.frame(name=c("bob"), earnings=c(100))




        dbSendUpdate(conn, "UPDATE test1 salary",teachersalaries[1,2])

---

和

       teachersalaries=data.frame(name=c("bob",'sally'), earnings=c(100,200))




        dbSendUpdate(conn, "INSERT INTO test1 salary", teachersalaries[which(teachersalaries$earnings>200,] )

Answer 1

您是否尝试过像使用其他语言一样传递常规 SQL 语句？

dbSendUpdate(conn, "UPDATE test1 set salary=? where id=?", teachersalary, teacherid)

或者

dbSendUpdate(conn,"INSERT INTO test1 VALUES (?,?)",teacherid,teachersalary)

基本上，您使用参数标记（那些问号）指定常规 SQL DML 语句，并提供值列表作为逗号分隔的参数。

Answer 2

为了同时更新多行，我构建了以下函数。

我已经用多达 10,000 行的批次对其进行了测试，并且效果很好。

# Libraries
library(RJDBC)
library(dplyr)    

# Function upload data into database
db_write_table <- function(conn,table,df){
  # Format data to write
  batch <- apply(df,1,FUN = function(x) paste0("'",trimws(x),"'", collapse = ",")) %>%
  paste0("(",.,")",collapse = ",\n")

  #Build query
  query <- paste("INSERT INTO", table ,"VALUES", batch)

  # Send update
  dbSendUpdate(conn, query)
}

# Push data
db_write_table(conn,"schema.mytable",mydataframe) 

感谢其他作者。

Answer 3

试试这个，它对我很有效。

dbSendUpdate(conn,"INSERT INTO test1 VALUES (?,?)",teacherid,teachersalary)

您只需要以与任何编程语言相同的方式传递一个常规 SQL 片段。试试看。