5

我有一个问题，我正在更新我的数据库中的数百万行，所以我不想单独更新每一行，而是想将约 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)

有没有人遇到过这个？或者对另一种方法有什么建议？

4

4 回答 4

7

对这个问题的简短回答是启用 MULTI_STATEMENTS 时，mysql 期望您处理查询结果。

快速解决方法是在每组多个更新语句之后执行类似的操作

  while db_write.next_result
    db_write.store_result rescue ''
  end
于 2012-06-28T14:26:40.677 回答
1

你为什么不只是::

无需多次运行它......

UPDATE pew SET x = 10 WHERE x IS NULL
于 2012-06-26T09:23:18.540 回答
1

据我了解，这是 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
于 2014-12-16T06:49:49.633 回答
1

在下一条 SQL 语句之前编写以下命令。

ActiveRecord::Base.connection.raw_connection.abandon_results!

它将启用新的 SQL 命令执行。

于 2018-07-06T13:03:08.993 回答