Class: Sequel::DataObjects::Database
- Inherits:
-
Sequel::Database
- Object
- Sequel::Database
- Sequel::DataObjects::Database
- 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::MSSQL_DEFAULT_RE, 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_ISOLATION_LEVELS, Sequel::Database::TRANSACTION_ROLLBACK, Sequel::Database::UNDERSCORE, Sequel::Database::UNIQUE, Sequel::Database::UNSIGNED
Instance Attribute Summary
Attributes inherited from Sequel::Database
#default_schema, #log_warn_duration, #loggers, #opts, #pool, #prepared_statements, #sql_log_level, #transaction_isolation_level
Instance Method Summary collapse
-
#connect(server) ⇒ Object
Setup a DataObjects::Connection to the database.
-
#dataset(opts = nil) ⇒ Object
Return a Sequel::DataObjects::Dataset object for this database.
-
#execute(sql, opts = {}) ⇒ Object
Execute the given SQL.
-
#execute_dui(sql, opts = {}) ⇒ Object
Execute the SQL on the this database, returning the number of affected rows.
-
#execute_insert(sql, opts = {}) ⇒ Object
Execute the SQL on this database, returning the primary key of the table being inserted to.
-
#initialize(opts) ⇒ Database
constructor
Call the DATABASE_SETUP proc directly after initialization, so the object always uses sub adapter specific code.
-
#subadapter ⇒ Object
Return the subadapter type for this database, i.e.
-
#uri(opts = {}) ⇒ Object
Return the DataObjects URI for the Sequel URI, removing the do: prefix.
Methods inherited from Sequel::Database
#<<, #[], adapter_class, adapter_scheme, #adapter_scheme, #add_column, #add_index, #add_servers, #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, #each_server, #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=, #indexes, #inspect, #literal, #log_info, #log_yield, #logger=, #query, #quote_identifiers=, quote_identifiers=, #quote_identifiers?, #remove_servers, #rename_column, #rename_table, #run, #schema, #select, #serial_primary_key_options, #servers, #set_column_default, #set_column_type, single_threaded=, #single_threaded?, #supports_prepared_transactions?, #supports_savepoints?, #supports_transaction_isolation_levels?, #synchronize, #table_exists?, #tables, #test_connection, #transaction, #typecast_value, #url
Methods included from Metaprogramming
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.
45 46 47 48 49 50 51 |
# File 'lib/sequel/adapters/do.rb', line 45 def initialize(opts) super raise(Error, "No connection string specified") unless uri if prok = DATABASE_SETUP[subadapter.to_sym] prok.call(self) end end |
Instance Method Details
#connect(server) ⇒ Object
Setup a DataObjects::Connection to the database.
54 55 56 |
# File 'lib/sequel/adapters/do.rb', line 54 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.
59 60 61 |
# File 'lib/sequel/adapters/do.rb', line 59 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.
68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 |
# File 'lib/sequel/adapters/do.rb', line 68 def execute(sql, opts={}) synchronize(opts[:server]) do |conn| begin command = conn.create_command(sql) res = log_yield(sql){block_given? ? command.execute_reader : command.execute_non_query} rescue ::DataObjects::Error => e raise_error(e) 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.
92 93 94 |
# File 'lib/sequel/adapters/do.rb', line 92 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.
98 99 100 |
# File 'lib/sequel/adapters/do.rb', line 98 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:.
104 105 106 |
# File 'lib/sequel/adapters/do.rb', line 104 def subadapter uri.split(":").first end |
#uri(opts = {}) ⇒ Object
Return the DataObjects URI for the Sequel URI, removing the do: prefix.
110 111 112 113 |
# File 'lib/sequel/adapters/do.rb', line 110 def uri(opts={}) opts = @opts.merge(opts) (opts[:uri] || opts[:url]).sub(/\Ado:/, '') end |