如何解决“Mysql2::Error：此连接仍在等待结果” mysql2 和 activerecord 错误

Question

与 此内容不重复具有相同标题的问题

我正在将 activerecord 与 mysql2 一起使用，并且我正在设计一次处理对同一 activerecord 模型/类的 10 个查询。 请注意，我使用严格的 activerecord，而不是直接使用 mysql 查询。

我在 Sinatra 中获取调用，然后使用 activerecord 从数据库获取数据。

我不希望调用被阻塞，因此我使用 mysql2 并且我不想想要使用em同步。

但现在我在后续的同时调用中收到以下消息“Mysql2::Error: This connection is still waiting for a result, after you get the result:”。

我没有与 pool=10

我的类

  class User < ActiveRecord::Base 

和要调用的代码 建立连接 user.find(:all, :conditions => ["id=?", userid])

mysql2 文档说“要使用 ActiveRecord 驱动程序（带或不带 Rails），您需要做的就是安装这个 gem并将您的database.yml中的适配器设置为“mysql2”，这很简单，对吗？:)”

这正是我从mysql迁移到mysql2时所做的。

为什么我会收到此错误。

Answer 1

这是一个完整的工作示例：

require 'rubygems'
gem 'activerecord', '~> 3.1.0'
gem 'sinatra',      '~> 1.3.1'
gem 'mysql2',       '~> 0.3.11'

require 'active_record'
require 'sinatra/base'
require 'mysql2'

# thin use the eventmachine thread pool
# you should have at least one connection per thread
# or you can expect errors
EM::threadpool_size = 10

# connect to the database
ActiveRecord::Base.establish_connection(
    :adapter => "mysql2",
    :database => "test",
    :username => "root",
    :encoding => 'utf8',
    # number of connections openened to the database
    :pool => 10
  )

class App < Sinatra::Base  
  get '/db' do
    ActiveRecord::Base.connection.execute("SELECT SLEEP(1)")
  end
end

run App

要运行它，请将文件保存为“config.ru”并在线程模式下以瘦方式运行它：

thin start -e production --threaded

您可以使用 ab 检查一切是否正常工作，我使用了一个名为 siege 的工具：

siege -c 10 -r 1 http://localhost:3000/db

Answer 2

您应该使用 ConnectionPool...不知何故，您有 2 个连接处于竞争状态。

我不使用 Sinatra，我使用 Rails，但我遇到了同样的问题并这样解决：

#  class ActiveRecord::Base
#   mattr_accessor :shared_connection
#   @@shared_connection = nil
# 
#   def self.connection
#     @@shared_connection || retrieve_connection
#   end
# end
# 
# ActiveRecord::Base.shared_connection = ActiveRecord::Base.connection

class ActiveRecord::Base
  mattr_accessor :shared_connection
  @@shared_connection = nil

  def self.connection
    @@shared_connection || ConnectionPool::Wrapper.new(:size => 1) { retrieve_connection }
  end
end

ActiveRecord::Base.shared_connection = ActiveRecord::Base.connection

Answer 3

您必须使用连接池。 mysql2 允许查询是异步的，但您仍然只能通过一个连接一次向 MySQL 发送一个查询。如果您通过一个连接发送多个查询，您将收到等待结果消息。

使用连接池应该没问题。