Ruby mysql2在单个查询中有多个语句
我有一个问题，我正在更新我的数据库中的数百万行，所以我不想单独更新每一行，而是希望将〜1000个语句组合并到一个查询中。
我已经启用了MULTI_STATEMENTS
client = Mysql2::Client.new(:host => 'localhost', :database => 'mehdb', :username => "root", :password => "", :flags => Mysql2::Client::MULTI_STATEMENTS) 这是我正在运行的代码的示例
sql = "SELECT id, x FROM pew WHERE x IS NULL LIMIT 1000" results = db_read.query(sql) while results.count > 0 updates = '' results.each do |r| updates += "UPDATE pew SET x = 10 WHERE id = #{r['id']};" end db_write.query(updates) unless updates.empty? results = db_read.query(sql) end
这项工作在第一次运行期间没问题，但是当它触发第二组更新时，我收到此错误消息
`query': Commands out of sync; you can't run this command now (Mysql2::Error)
有没有人遇到过这个？ 或者对另一种方法的任何建议？
这个问题的简短回答是当启用MULTI_STATEMENTS时，mysql希望你处理查询的结果。
快速解决方法是在每组多个更新语句之后执行与此类似的操作
while db_write.next_result db_write.store_result rescue '' end
为什么不公正::
无需多次运行….
UPDATE pew SET x = 10 WHERE x IS NULL
据我了解，这是一个结果Mysql内部保护 – 您正在查询数据库，并流式传输结果，如果在此期间您还将更新结果，您不能保证任何级别的一致性。
如果您知道可以安全地在流程中进行更改，则可以通过简单地创建第二个连接来解决这个问题：
reading_client = Mysql2::Client.new(:host => 'localhost', :database => 'mehdb', :username => "root", :password => "", :flags => Mysql2::Client::MULTI_STATEMENTS) updating_client = Mysql2::Client.new(:host => 'localhost', :database => 'mehdb', :username => "root", :password => "", :flags => Mysql2::Client::MULTI_STATEMENTS) sql = "SELECT id, x FROM pew WHERE x IS NULL LIMIT 1000" results = reading_client.query(sql) while results.count > 0 updates = '' results.each do |r| updates += "UPDATE pew SET x = 10 WHERE id = #{r['id']};" end updating_client.query(updates) unless updates.empty? results = reading_client.query(sql) end
在下一个SQL语句之前编写以下命令。
ActiveRecord::Base.connection.raw_connection.abandon_results!
它将启用新的SQL命令执行。