Class: Sequel::IBMDB::Database

Inherits:
Database show all
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::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 collapse

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

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_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, #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, #tables, #test_connection, #to_application_timestamp, #transaction, #typecast_value, #uri, #url, #views

Methods included from Metaprogramming

#meta_def

Constructor Details

#initialize(opts = {}) ⇒ Database

Returns a new instance of Database.



168
169
170
171
172
 
# File 'lib/sequel/adapters/ibmdb.rb', line 168

def initialize(opts={})
  super
  @conversion_procs = DB2_TYPES.dup
  @conversion_procs[:timestamp] = method(:to_application_timestamp)
end

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) ⇒ 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)
  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
250
251
252
253
254
 
# File 'lib/sequel/adapters/ibmdb.rb', line 228

def execute_prepared_statement(ps_name, opts)
  args = opts[:arguments]
  ps = prepared_statement(ps_name)
  sql = ps.prepared_sql
  synchronize(opts[:server]) do |conn|
    unless conn.prepared_statements.fetch(ps_name, []).first == sql
      log_yield("PREPARE #{ps_name}: #{sql}"){conn.prepare(sql, ps_name)}
    end
    args = args.map{|v| v.nil? ? nil : prepared_statement_arg(v)}
    log_sql = "EXECUTE #{ps_name}"
    if ps.log_sql
      log_sql << " ("
      log_sql << sql
      log_sql << ")"
    end
    stmt = log_yield(log_sql, args){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



257
258
259
260
261
262
263
 
# File 'lib/sequel/adapters/ibmdb.rb', line 257

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.

Returns:

  • (Boolean) 


268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
 
# File 'lib/sequel/adapters/ibmdb.rb', line 268

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