module ThinkingSphinx::Connection

Public Class Methods

connection_class() click to toggle source
# 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
new() click to toggle source
# 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
pool() click to toggle source
# 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
take() { |connection| ... } click to toggle source
# 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