class Sequel::Amalgalite::Database

Database class for SQLite databases used with Sequel and the amalgalite driver.

Constants

DatasetClass

Public Instance Methods

connect(server) click to toggle source

Connect to the database. Since SQLite is a file based database, the only options available are :database (to specify the database name), and :timeout, to specify how long to wait for the database to be available if it is locked, given in milliseconds (default is 5000).

# File lib/sequel/adapters/amalgalite.rb, line 76
def connect(server)
  opts = server_opts(server)
  opts[:database] = ':memory:' if blank_object?(opts[:database])
  db = ::Amalgalite::Database.new(opts[:database])
  db.busy_handler(::Amalgalite::BusyTimeout.new(opts.fetch(:timeout, 5000)/50, 50))
  db.type_map = SequelTypeMap.new(self)
  connection_pragmas.each{|s| log_yield(s){db.execute_batch(s)}}
  db
end
database_type() click to toggle source

Amalgalite is just the SQLite database without a separate SQLite installation.

# File lib/sequel/adapters/amalgalite.rb, line 87
def database_type
  :sqlite
end
execute(sql, opts=OPTS) { |stmt = log_yield(sql){prepare}| ... } click to toggle source

Run the given SQL with the given arguments and yield each row.

# File lib/sequel/adapters/amalgalite.rb, line 108
def execute(sql, opts=OPTS)
  _execute(sql, opts) do |conn|
    begin
      yield(stmt = log_yield(sql){conn.prepare(sql)})
    ensure
      stmt.close if stmt
    end
  end
end
execute_ddl(sql, opts=OPTS) click to toggle source

Run the given SQL with the given arguments. Returns nil.

# File lib/sequel/adapters/amalgalite.rb, line 92
def execute_ddl(sql, opts=OPTS)
  _execute(sql, opts){|conn| log_yield(sql){conn.execute_batch(sql)}}
  nil
end
execute_dui(sql, opts=OPTS) click to toggle source

Run the given SQL with the given arguments and return the number of changed rows.

# File lib/sequel/adapters/amalgalite.rb, line 98
def execute_dui(sql, opts=OPTS)
  _execute(sql, opts){|conn| log_yield(sql){conn.execute_batch(sql)}; conn.row_changes}
end
execute_insert(sql, opts=OPTS) click to toggle source

Run the given SQL with the given arguments and return the last inserted row id.

# File lib/sequel/adapters/amalgalite.rb, line 103
def execute_insert(sql, opts=OPTS)
  _execute(sql, opts){|conn| log_yield(sql){conn.execute_batch(sql)}; conn.last_insert_rowid}
end
single_value(sql, opts=OPTS) click to toggle source

Run the given SQL with the given arguments and return the first value of the first row.

# File lib/sequel/adapters/amalgalite.rb, line 119
def single_value(sql, opts=OPTS)
  _execute(sql, opts){|conn| log_yield(sql){conn.first_value_from(sql)}}
end

Private Instance Methods

_execute(sql, opts) { |conn| ... } click to toggle source

Yield an available connection. Rescue any Amalgalite::Errors and turn them into DatabaseErrors.

# File lib/sequel/adapters/amalgalite.rb, line 127
def _execute(sql, opts)
  begin
    synchronize(opts[:server]){|conn| yield conn}
  rescue ::Amalgalite::Error, ::Amalgalite::SQLite3::Error => e
    raise_error(e)
  end
end
connection_pool_default_options() click to toggle source

The Amagalite adapter does not need the pool to convert exceptions. Also, force the max connections to 1 if a memory database is being used, as otherwise each connection gets a separate database.

# File lib/sequel/adapters/amalgalite.rb, line 138
def connection_pool_default_options
  o = super.dup
  # Default to only a single connection if a memory database is used,
  # because otherwise each connection will get a separate database
  o[:max_connections] = 1 if @opts[:database] == ':memory:' || blank_object?(@opts[:database])
  o
end
database_error_classes() click to toggle source

Both main error classes that Amalgalite raises

# File lib/sequel/adapters/amalgalite.rb, line 147
def database_error_classes
  [::Amalgalite::Error, ::Amalgalite::SQLite3::Error]
end