Sha256: c1579bc87c4116e645b596c7265732059f062a6c715fc7ab784fb4b39a924da1
Contents?: true
Size: 1.38 KB
Versions: 15
Compression:
Stored size: 1.38 KB
Contents
class Baza::Table
include Comparable
include Baza::DatabaseModelFunctionality
attr_reader :db
def to_s
"#<#{self.class.name} name=\"#{name}\">"
end
def inspect
to_s
end
def rows(*args)
ArrayEnumerator.new do |yielder|
db.select(name, *args) do |data|
yielder << Baza::Row.new(
db: db,
table: name,
data: data
)
end
end
end
def row(id)
row = rows({id: id}, limit: 1).first
raise Baza::Errors::RowNotFound unless row
row
end
def to_param
name
end
def insert(data, args = {})
@db.insert(name, data, args)
end
def upsert_duplicate_key(data, terms = {}, args = {})
@db.upsert_duplicate_key(name, data, terms, args)
end
def rows_count
sql = "SELECT COUNT(*) AS count FROM #{@db.sep_table}#{@db.escape_table(name)}#{@db.sep_table}"
@db.query(sql).fetch.fetch(:count).to_i
end
def truncate
@db.query("TRUNCATE #{@db.sep_table}#{@db.escape_table(name)}#{@db.sep_table}")
self
end
def <=>(other)
return false unless other.is_a?(Baza::Table)
return false unless other.db.opts.fetch(:db) == db.opts.fetch(:db)
other.name <=> name
end
def create_columns(col_arr)
col_arr.each do |col_data|
sql = "ALTER TABLE #{db.sep_col}#{name}#{db.sep_col} ADD COLUMN #{@db.columns.data_sql(col_data)};"
@db.query(sql)
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems