mysql – “foreach”循环：使用R中的所有核心(特别是如果我们在foreach循环中发送sql查询)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了mysql – “foreach”循环：使用R中的所有核心(特别是如果我们在foreach循环中发送sql查询)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1229字，纯文字阅读大概需要2分钟。
内容图文
我打算用“foreach”来uitlize我的CPU中的所有核心.我需要在循环中发送一个sql查询.该脚本在正常的’for’循环中工作正常,但是当我将其更改为’foreach’时它会出现以下错误.
错误是：
select: Interrupted system call
select: Interrupted system call
select: Interrupted system call
Error in { : task 1 failed - "expired MySQLConnection"
我使用的代码是：
library(foreach)
library(doMC)
library(RMySQL)
library(multicore)
registerDoMC(cores=6)
m <- dbDriver("MySQL", max.con = 100)
con <- dbConnect(m, user="*****", password = "******", host ="**.**.***",dbname="dbname")
list<-dbListTables(con)
foreach(i = 1:(length(list))%dopar%{
query<-paste("SELECT * FROM ",list[i]," WHERE `CLOSE` BETWEEN 1 AND 100",sep="")
t<-dbGetQuery(con,query)
}
虽然’foreach’在我的系统中正常工作用于所有其他目的,但它仅在sql查询的情况下给出错误.有没有办法在’foreach’循环中发送sql查询？
解决方法:
我的建议如下：
将数据库查询移到循环外部,并锁定访问权限,这样就不会进行并行数据库查询.我认为这也会加快速度,因为你不会有并行磁盘访问,同时仍然可以进行并行处理.
含义(伪代码)
db =连接数据库
threadlock = lock();
parfor {
threadlock.lock
result = db query(在此处提取所有数据,因为在加载时无法处理而不保持数据库锁定)
thread.unlock
处理结果数据(现在只是数据,而不是sql对象).
}
内容总结
以上是互联网集市为您收集整理的mysql – “foreach”循环：使用R中的所有核心(特别是如果我们在foreach循环中发送sql查询)全部内容，希望文章能够帮你解决mysql – “foreach”循环：使用R中的所有核心(特别是如果我们在foreach循环中发送sql查询)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。