社区所有版块导航
Python
python开源   Django   Python   DjangoApp   pycharm  
DATA
docker   Elasticsearch  
aigc
aigc   chatgpt  
WEB开发
linux   MongoDB   Redis   DATABASE   NGINX   其他Web框架   web工具   zookeeper   tornado   NoSql   Bootstrap   js   peewee   Git   bottle   IE   MQ   Jquery  
机器学习
机器学习算法  
Python88.com
反馈   公告   社区推广  
产品
短视频  
印度
印度  
Py学习  »  DATABASE

从r插入mysql

Mislav • 5 年前 • 1302 次点击  

我正在使用dbi包向mysql插入数据。代码如下:

ch <- DBI::dbConnect(MySQL())
dbSendQuery(ch, 'set character set "utf8"')
dbSendQuery(ch, 'SET NAMES utf8')
for (i in 1:nrow(test)) {
  query <- paste0("INSERT INTO trade_data VALUES('0', '", test[i, 1], "', '",
                  test[i, 2], "', ", test[i, 3], "')")
  dbSendQuery(ch, query)
}

问题出现在3td列中,该列是数字,但是 NA 价值观。当循环到达具有 值返回错误:

.local(conn,statement,…)中出错:无法运行语句: “字段列表”中的未知列“na”

我试着把na改成nan,“null”,还有其他一些类型,但是没用。如果我把na改为0,它就会工作。

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/41015
 
1302 次点击  
文章 [ 3 ]  |  最新文章 5 年前
Mislav
Reply   •   1 楼
Mislav    6 年前

我说得对。我不得不将“”改为“null”,将na改为null,然后在insert中使用ifelse语句。这样地:

ch <- DBI::dbConnect(MySQL())
dbSendQuery(ch, 'set character set "utf8"')
dbSendQuery(ch, 'SET NAMES utf8')
test[test == ""] <- "NULL"
test[is.na(test)] <- "NULL"
for (i in 1:nrow(test)) {
  query <- paste0("INSERT INTO trade_data VALUES('0', '", test[i, 1], "', ",
                  ifelse(test[i, 2] == "NULL", test[i, 2], paste0("'", test[i, 2], "'")), ", ", 
                  ifelse(test[i, 3] == "NULL", test[i, 3], paste0("'", test[i, 3], "'")), ", ",
                  # test[i, 3],", ", 
                  test[i, 4], ", ",
                  test[i, 5], ", ",
                  test[i, 6], ", ", test[i, 7] , ", ",
                  test[i, 8], ", ", test[i, 9] , ", ",
                  test[i, 10], ", ", test[i, 11] , ", '",
                  test[i, 12], "')")
  dbSendQuery(ch, query)
}
DBI::dbDisconnect(ch)
Robele Baker
Reply   •   2 楼
Robele Baker    6 年前

如果您愿意将na改为0,那么最好的选择是执行以下操作。

test[is.na(test)] <- 0

这将替换data.frame中的所有NAS test 0。您也可以这样做,如果您愿意的话,也可以改为字符串“null”。

test[is.na(test)] <- 'NULL'

如果只希望替换列,可以执行以下操作:

test$col3[is.na(test$col3)] <- 0

Parfait
Reply   •   3 楼
Parfait    6 年前

考虑为运行sql的任何应用程序层(如r)设置参数化的编程行业标准。使用这种方法,您可以避免任何字符串插值或混乱的引号附件的需要。r的dbi标准有几种方法,其中之一是 sqlInterpolate :

# PREPARED STATEMENT (NO DATA) QMARKS REQUIRED BUT NAMES CAN CHANGE
sql <- "INSERT INTO trade_data (Col1, Col2, Col3, col4) 
        VALUES (?param1, ?param2, ?param3, ?param4)"

ch <- DBI::dbConnect(MySQL())
dbSendQuery(ch, 'set character set "utf8"')
dbSendQuery(ch, 'SET NAMES utf8')

for (i in 1:nrow(test)) {
  # BIND PARAMS
  query <- sqlInterpolate(conn, sql, param1 = "0", param2 = test[i, 1], 
                          param3 = test[i, 2], param4 = test[i, 3])
  # EXECUTE QUERY
  dbSendQuery(ch, query)
}