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 collapse
- DISCONNECT_ERROR_RE =
/terminating connection due to administrator command/
- DatasetClass =
self
Constants inherited from Sequel::Database
Sequel::Database::ADAPTERS, Sequel::Database::AUTOINCREMENT, Sequel::Database::COLUMN_DEFINITION_ORDER, Sequel::Database::COLUMN_SCHEMA_DATETIME_TYPES, Sequel::Database::COLUMN_SCHEMA_STRING_TYPES, Sequel::Database::COMBINABLE_ALTER_TABLE_OPS, Sequel::Database::COMMA_SEPARATOR, Sequel::Database::CURRENT_TIMESTAMP_RE, Sequel::Database::DEFAULT_JOIN_TABLE_COLUMN_OPTIONS, Sequel::Database::DEFAULT_STRING_COLUMN_SIZE, Sequel::Database::EXTENSIONS, Sequel::Database::NOT_NULL, Sequel::Database::NULL, Sequel::Database::PRIMARY_KEY, 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
#cache_schema, #dataset_class, #default_schema, #default_string_column_size, #log_warn_duration, #loggers, #opts, #pool, #prepared_statements, #sql_log_level, #timezone, #transaction_isolation_level
Instance Method Summary collapse
-
#connect(server) ⇒ Object
Setup a DataObjects::Connection to the database.
- #disconnect_connection(conn) ⇒ Object
-
#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, #after_commit, #after_rollback, #alter_table, #alter_table_generator, #call, #cast_type_literal, connect, #create_join_table, #create_or_replace_view, #create_table, #create_table!, #create_table?, #create_table_generator, #create_view, #database_type, #dataset, #disconnect, #drop_column, #drop_index, #drop_join_table, #drop_table, #drop_table?, #drop_view, #dump_foreign_key_migration, #dump_indexes_migration, #dump_schema_cache, #dump_schema_cache?, #dump_schema_migration, #dump_table_schema, #each_server, #execute_ddl, #extend_datasets, #extension, #fetch, #foreign_key_list, #from, #from_application_timestamp, #get, #global_index_namespace?, #identifier_input_method, identifier_input_method, identifier_input_method=, #identifier_input_method=, #identifier_output_method, identifier_output_method, #identifier_output_method=, identifier_output_method=, #in_transaction?, #indexes, #inspect, #literal, #load_schema_cache, #load_schema_cache?, #log_exception, #log_info, #log_yield, #logger=, #prepared_statement, #query, quote_identifiers=, #quote_identifiers=, #quote_identifiers?, register_extension, #remove_servers, #rename_column, #rename_table, #run, #schema, #select, #serial_primary_key_options, #servers, #set_column_default, #set_column_type, #set_prepared_statement, single_threaded=, #single_threaded?, #supports_create_table_if_not_exists?, #supports_deferrable_constraints?, #supports_deferrable_foreign_key_constraints?, #supports_drop_table_if_exists?, #supports_prepared_transactions?, #supports_savepoints?, #supports_savepoints_in_prepared_transactions?, #supports_transaction_isolation_levels?, #supports_transactional_ddl?, #synchronize, #table_exists?, #tables, #test_connection, #to_application_timestamp, #transaction, #typecast_value, #url, #valid_connection?, #views
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.
51 52 53 54 55 56 57 |
# File 'lib/sequel/adapters/do.rb', line 51 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.
60 61 62 |
# File 'lib/sequel/adapters/do.rb', line 60 def connect(server) setup_connection(::DataObjects::Connection.new(uri(server_opts(server)))) end |
#disconnect_connection(conn) ⇒ Object
64 65 66 |
# File 'lib/sequel/adapters/do.rb', line 64 def disconnect_connection(conn) conn.dispose 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.
73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 |
# File 'lib/sequel/adapters/do.rb', line 73 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.
97 98 99 |
# File 'lib/sequel/adapters/do.rb', line 97 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.
103 104 105 |
# File 'lib/sequel/adapters/do.rb', line 103 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:.
109 110 111 |
# File 'lib/sequel/adapters/do.rb', line 109 def subadapter uri.split(":").first end |
#uri(opts = {}) ⇒ Object
Return the DataObjects URI for the Sequel URI, removing the do: prefix.
115 116 117 118 |
# File 'lib/sequel/adapters/do.rb', line 115 def uri(opts={}) opts = @opts.merge(opts) (opts[:uri] || opts[:url]).sub(/\Ado:/, '') end |