Class: Sequel::IBMDB::Database
- Includes:
- DB2::DatabaseMethods
- Defined in:
- lib/sequel/adapters/ibmdb.rb
Constant Summary collapse
- DatasetClass =
self
Constants included from DB2::DatabaseMethods
DB2::DatabaseMethods::AUTOINCREMENT, DB2::DatabaseMethods::NOT_NULL, DB2::DatabaseMethods::NULL
Constants inherited from Database
Database::ADAPTERS, Database::AUTOINCREMENT, Database::CASCADE, Database::COLUMN_DEFINITION_ORDER, Database::COMMA_SEPARATOR, Database::MSSQL_DEFAULT_RE, Database::MYSQL_TIMESTAMP_RE, Database::NOT_NULL, Database::NO_ACTION, Database::NULL, Database::POSTGRES_DEFAULT_RE, Database::PRIMARY_KEY, Database::RESTRICT, Database::SET_DEFAULT, Database::SET_NULL, 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 collapse
-
#conversion_procs ⇒ Object
readonly
Hash of connection procs for converting.
Attributes inherited from Database
#dataset_class, #default_schema, #log_warn_duration, #loggers, #opts, #pool, #prepared_statements, #sql_log_level, #timezone, #transaction_isolation_level
Instance Method Summary collapse
-
#alter_table(name, generator = nil, &block) ⇒ Object
REORG the related table whenever it is altered.
-
#connect(server) ⇒ Object
Create a new connection object for the given server.
-
#execute(sql, opts = {}, &block) ⇒ Object
Execute the given SQL on the database.
-
#execute_insert(sql, opts = {}) ⇒ Object
Execute the given SQL on the database, returning the last inserted identity value.
-
#execute_prepared_statement(ps_name, opts) ⇒ Object
Execute a prepared statement named by name on the database.
-
#initialize(opts = {}) ⇒ Database
constructor
A new instance of Database.
-
#schema_column_type(db_type) ⇒ Object
Convert smallint type to boolean if convert_smallint_to_bool is true.
-
#table_exists?(name) ⇒ Boolean
On DB2, a table might need to be REORGed if you are testing existence of it.
Methods included from DB2::DatabaseMethods
#database_type, #db2_version, #indexes, #schema_parse_table, #tables, #views
Methods inherited from Database
#<<, #[], adapter_class, adapter_scheme, #adapter_scheme, #add_column, #add_index, #add_servers, #after_commit, #after_rollback, #call, #cast_type_literal, connect, #create_or_replace_view, #create_table, #create_table!, #create_table?, #create_view, #database_type, #dataset, #disconnect, #drop_column, #drop_index, #drop_table, #drop_view, #dump_indexes_migration, #dump_schema_migration, #dump_table_schema, #each_server, #execute_ddl, #execute_dui, #extend_datasets, #fetch, #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, #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_create_table_if_not_exists?, #supports_prepared_transactions?, #supports_savepoints?, #supports_transaction_isolation_levels?, #synchronize, #tables, #test_connection, #to_application_timestamp, #transaction, #typecast_value, #uri, #url, #views
Methods included from Metaprogramming
Constructor Details
Instance Attribute Details
#conversion_procs ⇒ Object (readonly)
Hash of connection procs for converting
166 167 168 |
# File 'lib/sequel/adapters/ibmdb.rb', line 166 def conversion_procs @conversion_procs end |
Instance Method Details
#alter_table(name, generator = nil, &block) ⇒ Object
REORG the related table whenever it is altered. This is not always required, but it is necessary for compatibilty with other Sequel code in many cases.
177 178 179 180 181 |
# File 'lib/sequel/adapters/ibmdb.rb', line 177 def alter_table(name, generator=nil, &block) res = super reorg(name) res end |
#connect(server) ⇒ Object
Create a new connection object for the given server.
184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 |
# File 'lib/sequel/adapters/ibmdb.rb', line 184 def connect(server) opts = server_opts(server) # use uncataloged connection so that host and port can be supported connection_string = ( \ 'Driver={IBM DB2 ODBC DRIVER};' \ "Database=#{opts[:database]};" \ "Hostname=#{opts[:host]};" \ "Port=#{opts[:port] || 50000};" \ 'Protocol=TCPIP;' \ "Uid=#{opts[:user]};" \ "Pwd=#{opts[:password]};" \ ) Connection.new(connection_string) end |
#execute(sql, opts = {}, &block) ⇒ Object
Execute the given SQL on the database.
202 203 204 205 206 207 208 209 210 |
# File 'lib/sequel/adapters/ibmdb.rb', line 202 def execute(sql, opts={}, &block) if sql.is_a?(Symbol) execute_prepared_statement(sql, opts, &block) else synchronize(opts[:server]){|c| _execute(c, sql, opts, &block)} end rescue Connection::Error => e raise_error(e) end |
#execute_insert(sql, opts = {}) ⇒ Object
Execute the given SQL on the database, returning the last inserted identity value.
214 215 216 217 218 219 220 221 222 223 224 225 |
# File 'lib/sequel/adapters/ibmdb.rb', line 214 def execute_insert(sql, opts={}) synchronize(opts[:server]) do |c| if sql.is_a?(Symbol) execute_prepared_statement(sql, opts) else _execute(c, sql, opts) end _execute(c, "SELECT IDENTITY_VAL_LOCAL() FROM SYSIBM.SYSDUMMY1", opts){|stmt| i = stmt.fetch_array.first.to_i; stmt.free; i} end rescue Connection::Error => e raise_error(e) end |
#execute_prepared_statement(ps_name, opts) ⇒ Object
Execute a prepared statement named by name on the database.
228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 |
# File 'lib/sequel/adapters/ibmdb.rb', line 228 def execute_prepared_statement(ps_name, opts) args = opts[:arguments] ps = prepared_statements[ps_name] sql = ps.prepared_sql synchronize(opts[:server]) do |conn| unless conn.prepared_statements.fetch(ps_name, []).first == sql log_yield("Preparing #{ps_name}: #{sql}"){conn.prepare(sql, ps_name)} end args = args.map{|v| v.nil? ? nil : prepared_statement_arg(v)} stmt = log_yield("Executing #{ps_name}: #{args.inspect}"){conn.execute_prepared(ps_name, *args)} if block_given? begin yield(stmt) ensure stmt.free end else stmt.affected end end end |
#schema_column_type(db_type) ⇒ Object
Convert smallint type to boolean if convert_smallint_to_bool is true
252 253 254 255 256 257 258 |
# File 'lib/sequel/adapters/ibmdb.rb', line 252 def schema_column_type(db_type) if Sequel::IBMDB.convert_smallint_to_bool && db_type =~ /smallint/i :boolean else super end end |
#table_exists?(name) ⇒ Boolean
On DB2, a table might need to be REORGed if you are testing existence of it. This REORGs automatically if the database raises a specific error that indicates it should be REORGed.
263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 |
# File 'lib/sequel/adapters/ibmdb.rb', line 263 def table_exists?(name) v ||= false # only retry once sch, table_name = schema_and_table(name) name = SQL::QualifiedIdentifier.new(sch, table_name) if sch from(name).first true rescue DatabaseError => e if e.to_s =~ /Operation not allowed for reason code "7" on table/ && v == false # table probably needs reorg reorg(name) v = true retry end false end |