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