0

我们的财务团队正在使用闪亮的应用程序每月将 csv 文件上传到 postegreSQL。有时，他们需要修改数据然后再次上传。

让我们举一些例子让问题更容易理解：

# Retrieve data from PostgreSQL
>monthly_expense <- dbGetQuery(con, "SELECT * from expense_table2")
>monthly_expense
>month   type  USD
 201605    A   200
 201605    B   300
 201606    A   105
 201606    B   200

 # Produce new 201606 data
 >month<-c("201606", "201606")
 >type<-c("A", "B")
 >USD<-c(150, 250)
 >new_data<-data.frame(month, type, USD )
 >new_data
    month    type USD
 1  201606    A   150
 2  201606    B   250

那么如何用新的数据替换 201606 数据呢？我认为应修改以下命令，以指定应覆盖 2016 年的数据：

 dbWriteTable(con, "expense_table2", value = new_data, append=T, overwrite = TRUE)
4

1 回答 1

1

考虑使用更新查询dbSendQuery：

sqlstrings <- paste0("UPDATE expense_table2 SET USD = ", newdata$USD , " 
                      WHERE month='", newdata$month, "' AND type='", newdata$type, "';")

queryruns <- lapply(sqlstrings, function(x) dbSendQuery(con, x))

或者，更新现有数据框，然后使用以下命令覆盖 Postgres 的 db 表dbWriteTable：

index <- match(monthly_expense$month, new_data2$month)
monthly_expense[index, 2:3] <- new_data2[2:3]

dbWriteTable(con, "expense_table2", value = monthly_expense, append=T, overwrite = TRUE)

更重要rbind的是，未更新的行到 newdata 并将其推送到数据库：

newdata <- rbind(monthly_expense[!(monthly_expense$month %in% newdata$month),],
                 newdata)

dbWriteTable(con, "expense_table2", value = new_data, append=T, overwrite = TRUE)
于 2016-07-21T04:21:34.940 回答