class RtSphinx::Query

Public Class Methods

new() click to toggle source
# File lib/rt_sphinx/query.rb, line 6
def initialize
  @connection = RtSphinx::Connection.instance
end

Public Instance Methods

insert(*values) click to toggle source
# File lib/rt_sphinx/query.rb, line 15
def insert(*values)
  item_id = rand(10_000)*rand(9_888)
  values_str = values.map{|v| "'#{v}'"}.join(', ')
  insert_sql = "INSERT INTO rt_logs (id, timestamp, message, logjson) VALUES (#{item_id}, #{values_str})"
  @connection.execute_sql(insert_sql, 'insert')
end
select(clause) click to toggle source
# File lib/rt_sphinx/query.rb, line 10
def select(clause)
  select_sql = "SELECT * FROM rt_logs WHERE #{clause}"
  @connection.execute_sql(select_sql, 'select')
end