RMySql 做并行失败

Question

我正在使用

RMySQL

的并行查询。是否可以共享工人之间的连接？

library(foreach)
library(doParallel)
library(RMySQL)

con <- dbConnect(MySQL(),
                 user = 'user',
                 password = 'password',
                 host = 'someip',
                 dbname = 'test01')  

numCores <- detectCores()
registerDoParallel(numCores)

foreach (i=1:3,.packages='RMySQL') %dopar% {
  dbGetQuery(con,paste0("INSERT INTO t VALUES ('Some Text')"))
}

dbDisconnect(con)

我收到这个错误：

Error in { : task 1 failed - "Corrupt MySQL handle"

Answer 1

是否可以共享工人之间的连接？

不，连接维护查询进度及其结果的状态。需要每个工作人员单独连接。