Sha256: 17da2e09b64452fc725f08bf15286aa062318f43a8a6b13b52b45a45345997a6
Contents?: true
Size: 1.34 KB
Versions: 17
Compression:
Stored size: 1.34 KB
Contents
# frozen_string_literal: true
class ThinkingSphinx::Connection::JRuby < ThinkingSphinx::Connection::Client
attr_reader :address, :options
def initialize(options)
options.delete :socket
super
@address = "jdbc:mysql://#{@options[:host]}:#{@options[:port]}/?allowMultiQueries=true"
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
17 entries across 17 versions & 1 rubygems