Sha256: a38f8e0f73cb9ab4325a2be2e9f6c90662ea69cc4f62bb649d8753064575fd77
Contents?: true
Size: 1.5 KB
Versions: 11
Compression:
Stored size: 1.5 KB
Contents
module RailsDb
module Adapters
class BaseAdapter
extend ::RailsDb::Connection
MULTI_STATEMENT_HELP_TEXT = "EXPERIMENTAL: You can import only file with SQL statements separated by ';'. Each new statement must start from new line."
def self.execute(sql)
t0 = Time.now
connection.execute(sql)
Time.now - t0
end
def self.exec_query(sql)
t0 = Time.now
results = connection.exec_query(sql)
execution_time = Time.now - t0
[results, execution_time]
end
def self.select(sql)
BaseAdapter.exec_query(sql)
end
def self.explain(sql)
BaseAdapter.exec_query(sql)
end
def self.adapter_name
'base'
end
def self.mime
'text/x-sql'
end
def self.truncate(table_name)
execute("TRUNCATE TABLE #{table_name};")
end
def self.delete(table_name, pk_name, pk_id)
execute("DELETE FROM #{table_name} WHERE #{pk_name} = #{pk_id};")
end
def self.count(table_name)
select("SELECT COUNT(*) FROM #{table_name}")[0].rows.flatten.last.to_i
end
def self.primary_key(table_name)
connection.primary_key(table_name)
end
def self.indexes(table_name)
connection.indexes(table_name)
end
private
def self.multiple_execute(sql, divider = ";\n")
sql.split(divider).each do |statement|
connection.execute(statement)
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems