Class: Sequel::DataObjects::Database

Inherits:
Sequel::Database show all
Defined in:
lib/sequel/adapters/do.rb

Overview

DataObjects uses it’s own internal connection pooling in addition to the pooling that Sequel uses. You should make sure that you don’t set the connection pool size to more than 8 for a Sequel::DataObjects::Database object, or hack DataObjects (or Extlib) to use a pool size at least as large as the pool size being used by Sequel.

Constant Summary

Constants inherited from Sequel::Database

Sequel::Database::ADAPTERS, Sequel::Database::AUTOINCREMENT, Sequel::Database::CASCADE, Sequel::Database::COMMA_SEPARATOR, Sequel::Database::MYSQL_TIMESTAMP_RE, Sequel::Database::NOT_NULL, Sequel::Database::NO_ACTION, Sequel::Database::NULL, Sequel::Database::POSTGRES_DEFAULT_RE, Sequel::Database::PRIMARY_KEY, Sequel::Database::RESTRICT, Sequel::Database::SET_DEFAULT, Sequel::Database::SET_NULL, Sequel::Database::SQL_BEGIN, Sequel::Database::SQL_COMMIT, Sequel::Database::SQL_RELEASE_SAVEPOINT, Sequel::Database::SQL_ROLLBACK, Sequel::Database::SQL_ROLLBACK_TO_SAVEPOINT, Sequel::Database::SQL_SAVEPOINT, Sequel::Database::STRING_DEFAULT_RE, Sequel::Database::TEMPORARY, Sequel::Database::TRANSACTION_BEGIN, Sequel::Database::TRANSACTION_COMMIT, Sequel::Database::TRANSACTION_ROLLBACK, Sequel::Database::UNDERSCORE, Sequel::Database::UNIQUE, Sequel::Database::UNSIGNED

Instance Attribute Summary collapse

Attributes inherited from Sequel::Database

#default_schema, #loggers, #opts, #pool, #prepared_statements

Instance Method Summary collapse

Methods inherited from Sequel::Database

#<<, #[], adapter_class, adapter_scheme, #add_column, #add_index, #alter_table, #call, #cast_type_literal, connect, #create_or_replace_view, #create_table, #create_table!, #create_table?, #create_view, #database_type, #disconnect, #drop_column, #drop_index, #drop_table, #drop_view, #dump_indexes_migration, #dump_schema_migration, #dump_table_schema, #execute_ddl, #fetch, #from, #get, #identifier_input_method, identifier_input_method, #identifier_input_method=, identifier_input_method=, #identifier_output_method, identifier_output_method, #identifier_output_method=, identifier_output_method=, #inspect, #literal, #log_info, #logger=, #query, #quote_identifiers=, quote_identifiers=, #quote_identifiers?, #rename_column, #rename_table, #schema, #select, #serial_primary_key_options, #set_column_default, #set_column_type, single_threaded=, #single_threaded?, #supports_savepoints?, #synchronize, #table_exists?, #test_connection, #transaction, #typecast_value, #url

Methods included from Metaprogramming

#meta_def

Constructor Details

#initialize(opts) ⇒ Database

Call the DATABASE_SETUP proc directly after initialization, so the object always uses sub adapter specific code. Also, raise an error immediately if the connection doesn’t have a uri, since DataObjects requires one.

Raises:



53
54
55
56
57
58
59
60
61
 
# File 'lib/sequel/adapters/do.rb', line 53

def initialize(opts)
  @opts = opts
  @converted_exceptions = []
  raise(Error, "No connection string specified") unless uri
  if prok = DATABASE_SETUP[subadapter.to_sym]
    prok.call(self)
  end
  super(opts)
end

Instance Attribute Details

#converted_exceptions ⇒ Object

Convert the given exceptions to Sequel:Errors, necessary because DO raises errors specific to database types in certain cases.



47
48
49
 
# File 'lib/sequel/adapters/do.rb', line 47

def converted_exceptions
  @converted_exceptions
end

Instance Method Details

#connect(server) ⇒ Object

Setup a DataObjects::Connection to the database.



64
65
66
 
# File 'lib/sequel/adapters/do.rb', line 64

def connect(server)
  setup_connection(::DataObjects::Connection.new(uri(server_opts(server))))
end

#dataset(opts = nil) ⇒ Object

Return a Sequel::DataObjects::Dataset object for this database.



69
70
71
 
# File 'lib/sequel/adapters/do.rb', line 69

def dataset(opts = nil)
  DataObjects::Dataset.new(self, opts)
end

#execute(sql, opts = {}) ⇒ Object

Execute the given SQL. If a block is given, the DataObjects::Reader created is yielded to it. A block should not be provided unless a a SELECT statement is being used (or something else that returns rows). Otherwise, the return value is the insert id if opts is :insert, or the number of affected rows, otherwise.



78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
 
# File 'lib/sequel/adapters/do.rb', line 78

def execute(sql, opts={})
  log_info(sql)
  synchronize(opts[:server]) do |conn|
    begin
      command = conn.create_command(sql)
      res = block_given? ? command.execute_reader : command.execute_non_query
    rescue Exception => e
      raise_error(e, :classes=>@converted_exceptions)
    end
    if block_given?
      begin
        yield(res)
      ensure
       res.close if res
      end
    elsif opts[:type] == :insert
      res.insert_id
    else
      res.affected_rows
    end
  end
end

#execute_dui(sql, opts = {}) ⇒ Object

Execute the SQL on the this database, returning the number of affected rows.



103
104
105
 
# File 'lib/sequel/adapters/do.rb', line 103

def execute_dui(sql, opts={})
  execute(sql, opts)
end

#execute_insert(sql, opts = {}) ⇒ Object

Execute the SQL on this database, returning the primary key of the table being inserted to.



109
110
111
 
# File 'lib/sequel/adapters/do.rb', line 109

def execute_insert(sql, opts={})
  execute(sql, opts.merge(:type=>:insert))
end

#subadapter ⇒ Object

Return the subadapter type for this database, i.e. sqlite3 for do:sqlite3::memory:.



115
116
117
 
# File 'lib/sequel/adapters/do.rb', line 115

def subadapter
  uri.split(":").first
end

#uri(opts = {}) ⇒ Object

Return the DataObjects URI for the Sequel URI, removing the do: prefix.



121
122
123
124
 
# File 'lib/sequel/adapters/do.rb', line 121

def uri(opts={})
  opts = @opts.merge(opts)
  (opts[:uri] || opts[:url]).sub(/\Ado:/, '')
end