Class: Sequel::ADO::Database
- Defined in:
- lib/sequel/adapters/ado.rb
Constant Summary collapse
- DISCONNECT_ERROR_RE =
/Communication link failure/
- DatasetClass =
self
Constants inherited from Database
Database::ADAPTERS, Database::AUTOINCREMENT, Database::COLUMN_DEFINITION_ORDER, Database::COMMA_SEPARATOR, Database::DEFAULT_JOIN_TABLE_COLUMN_OPTIONS, Database::MSSQL_DEFAULT_RE, Database::MYSQL_TIMESTAMP_RE, Database::NOT_NULL, Database::NULL, Database::POSTGRES_DEFAULT_RE, Database::PRIMARY_KEY, Database::SQL_BEGIN, Database::SQL_COMMIT, Database::SQL_RELEASE_SAVEPOINT, Database::SQL_ROLLBACK, Database::SQL_ROLLBACK_TO_SAVEPOINT, Database::SQL_SAVEPOINT, Database::STRING_DEFAULT_RE, Database::TEMPORARY, Database::TRANSACTION_BEGIN, Database::TRANSACTION_COMMIT, Database::TRANSACTION_ISOLATION_LEVELS, Database::TRANSACTION_ROLLBACK, Database::UNDERSCORE, Database::UNIQUE, Database::UNSIGNED
Instance Attribute Summary
Attributes inherited from Database
#cache_schema, #dataset_class, #default_schema, #log_warn_duration, #loggers, #opts, #pool, #prepared_statements, #sql_log_level, #timezone, #transaction_isolation_level
Instance Method Summary collapse
-
#connect(server) ⇒ Object
In addition to the usual database options, the following options have an effect:.
- #execute(sql, opts = {}) ⇒ Object (also: #do)
-
#initialize(opts) ⇒ Database
constructor
A new instance of Database.
Methods inherited from Database
#<<, #[], adapter_class, adapter_scheme, #adapter_scheme, #add_column, #add_index, #add_servers, #after_commit, #after_rollback, #alter_table, #call, #cast_type_literal, connect, #create_join_table, #create_or_replace_view, #create_table, #create_table!, #create_table?, #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, #execute_dui, #execute_insert, #extend_datasets, #fetch, #foreign_key_list, #from, #from_application_timestamp, #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=, #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?, #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_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, #uri, #url, #views
Methods included from Metaprogramming
Constructor Details
#initialize(opts) ⇒ Database
Returns a new instance of Database.
11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 |
# File 'lib/sequel/adapters/ado.rb', line 11 def initialize(opts) super case @opts[:conn_string] when /Microsoft\.(Jet|ACE)\.OLEDB/io Sequel.ts_require 'adapters/shared/access' extend Sequel::Access::DatabaseMethods extend_datasets(Sequel::Access::DatasetMethods) else @opts[:driver] ||= 'SQL Server' case @opts[:driver] when 'SQL Server' Sequel.ts_require 'adapters/ado/mssql' extend Sequel::ADO::MSSQL::DatabaseMethods @dataset_class = ADO::MSSQL::Dataset set_mssql_unicode_strings end end end |
Instance Method Details
#connect(server) ⇒ Object
In addition to the usual database options, the following options have an effect:
- :command_timeout
-
Sets the time in seconds to wait while attempting to execute a command before cancelling the attempt and generating an error. Specifically, it sets the ADO CommandTimeout property. If this property is not set, the default of 30 seconds is used.
- :driver
-
The driver to use in the ADO connection string. If not provided, a default of “SQL Server” is used.
- :conn_string
-
The full ADO connection string. If this is provided, the usual options are ignored.
- :provider
-
Sets the Provider of this ADO connection (for example, “SQLOLEDB”). If you don’t specify a provider, the default one used by WIN32OLE has major problems, such as creating a new native database connection for every query, which breaks things such as temporary tables.
Pay special attention to the :provider option, as without specifying a provider, many things will be broken. The SQLNCLI10 provider appears to work well if you are connecting to Microsoft SQL Server, but it is not the default as that would break backwards compatability.
50 51 52 53 54 55 56 57 58 |
# File 'lib/sequel/adapters/ado.rb', line 50 def connect(server) opts = server_opts(server) s = opts[:conn_string] || "driver=#{opts[:driver]};server=#{opts[:host]};database=#{opts[:database]}#{";uid=#{opts[:user]};pwd=#{opts[:password]}" if opts[:user]}" handle = WIN32OLE.new('ADODB.Connection') handle.CommandTimeout = opts[:command_timeout] if opts[:command_timeout] handle.Provider = opts[:provider] if opts[:provider] handle.Open(s) handle end |
#execute(sql, opts = {}) ⇒ Object Also known as: do
60 61 62 63 64 65 66 67 68 69 70 |
# File 'lib/sequel/adapters/ado.rb', line 60 def execute(sql, opts={}) synchronize(opts[:server]) do |conn| begin r = log_yield(sql){conn.Execute(sql)} yield(r) if block_given? rescue ::WIN32OLERuntimeError => e raise_error(e) end end nil end |