Ruby mysql2 несколько операторов в одном запросе

Question

У меня проблема, когда я обновляю миллионы строк в моей базе данных, поэтому вместо того, чтобы обновлять каждую из них отдельно, я хочу объединить группы из 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) 

С кем это может быть передние? Или какие-либо рекомендации по другому подходу?

Answer 1

Короткий ответ к этой проблеме, когда MULTI_STATEMENTS включена MySQL ожидает обрабатывать результат Ваш запрос.

Быстрое исправление сделать что-то похожее на это после каждого набора нескольких операторов обновления

while db_write.next_result 
    db_write.store_result rescue '' 
    end 

Answer 2

Почему вы не только ::

Нет необходимости запускать его несколько раз ....

UPDATE pew SET x = 10 WHERE x IS NULL 

Answer 3

Как я понимаю, это результат 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