Contents

class ThinkingSphinx::Connection::JRuby < ThinkingSphinx::Connection::Client
  attr_reader :address, :options

  def initialize(options)
    @address = "jdbc:mysql://#{options[:host]}:#{options[:port]}/?allowMultiQueries=true"
    @options = options
  end

  def base_error
    Java::JavaSql::SQLException
  end

  private

  def client
    @client ||= Java::ComMysqlJdbc::Driver.new.connect address, properties
  rescue base_error => error
    raise ThinkingSphinx::SphinxError.new_from_mysql error
  end

  def properties
    object = Java::JavaUtil::Properties.new
    object.setProperty "user", options[:username]     if options[:username]
    object.setProperty "password", options[:password] if options[:password]
    object
  end

  def results_for(statements)
    statement = client.createStatement
    statement.execute statements

    results   = [set_to_array(statement.getResultSet)]
    results  << set_to_array(statement.getResultSet) while statement.getMoreResults
    results.compact
  end

  def set_to_array(set)
    return nil if set.nil?

    meta = set.getMetaData
    rows = []

    while set.next
      rows << (1..meta.getColumnCount).inject({}) do |row, index|
        name      = meta.getColumnName index
        row[name] = set.getObject(index)
        row
      end
    end

    rows
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
thinking-sphinx-3.4.2	lib/thinking_sphinx/connection/jruby.rb
thinking-sphinx-3.4.1	lib/thinking_sphinx/connection/jruby.rb
thinking-sphinx-3.4.0	lib/thinking_sphinx/connection/jruby.rb