相关疑难解决方法(0)

我有一个Rails 4应用程序,我与它一起使用sidekiq来运行异步作业.我通常在我的Rails应用程序之外运行的一个作业是一大堆复杂的SQL查询,它们无法真正由ActiveRecord建模.这组SQL查询与我的Rails应用程序的连接是,它应该在我的一个控制器操作被调用时执行.

理想情况下,我会从控制器中的Rails应用程序中为Sidekiq排队,继续运行查询.现在它们存储在一个外部文件中,我不完全确定Rails运行所述SQL的最佳方法是什么.

任何解决方案都很受欢

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

有没有人遇到过这个？或者对另一种方法的任何建议？