# File lib/thinking_sphinx/connection.rb, line 18 def self.connection_class raise "Sphinx's MySQL protocol does not work with JDBC." if RUBY_PLATFORM == 'java' return ThinkingSphinx::Connection::JRuby if RUBY_PLATFORM == 'java' ThinkingSphinx::Connection::MRI end
# File lib/thinking_sphinx/connection.rb, line 2 def self.new configuration = ThinkingSphinx::Configuration.instance # If you use localhost, MySQL insists on a socket connection, but Sphinx # requires a TCP connection. Using 127.0.0.1 fixes that. address = configuration.searchd.address || '127.0.0.1' address = '127.0.0.1' if address == 'localhost' options = { :host => address, :port => configuration.searchd.mysql41, :reconnect => true }.merge(configuration.settings['connection_options'] || {}) connection_class.new address, options[:port], options end
# File lib/thinking_sphinx/connection.rb, line 25 def self.pool @pool ||= Innertube::Pool.new( Proc.new { ThinkingSphinx::Connection.new }, Proc.new { |connection| connection.close } ) end
# File lib/thinking_sphinx/connection.rb, line 32 def self.take retries = 0 original = nil begin pool.take do |connection| begin yield connection rescue ThinkingSphinx::QueryExecutionError, Mysql2::Error => error original = ThinkingSphinx::SphinxError.new_from_mysql error raise original if original.is_a?(ThinkingSphinx::QueryError) raise Innertube::Pool::BadResource end end rescue Innertube::Pool::BadResource retries += 1 raise original unless retries < 3 ActiveSupport::Notifications.instrument( "message.thinking_sphinx", :message => "Retrying query \"#{original.statement}\" after error: #{original.message}" ) retry end end