class Sequel::IBMDB::Connection
Wraps an underlying connection to DB2 using IBM_DB.
Attributes
A hash with prepared statement name symbol keys, where each value is a two element array with an sql string and cached Statement value.
Public Class Methods
Create the underlying IBM_DB connection.
# File lib/sequel/adapters/ibmdb.rb, line 48 def initialize(connection_param) @conn = if connection_param.class == String IBM_DB.connect(connection_param, '', '') else # connect using catalog IBM_DB.connect(*connection_param) end self.autocommit = true @prepared_statements = {} end
Public Instance Methods
Check whether the connection is in autocommit state or not.
# File lib/sequel/adapters/ibmdb.rb, line 60 def autocommit IBM_DB.autocommit(@conn) == 1 end
Turn autocommit on or off for the connection.
# File lib/sequel/adapters/ibmdb.rb, line 65 def autocommit=(value) IBM_DB.autocommit(@conn, value ? IBM_DB::SQL_AUTOCOMMIT_ON : IBM_DB::SQL_AUTOCOMMIT_OFF) end
Close the connection, disconnecting from DB2.
# File lib/sequel/adapters/ibmdb.rb, line 70 def close IBM_DB.close(@conn) end
Commit the currently outstanding transaction on this connection.
# File lib/sequel/adapters/ibmdb.rb, line 75 def commit IBM_DB.commit(@conn) end
Return the related error message for the connection.
# File lib/sequel/adapters/ibmdb.rb, line 80 def error_msg IBM_DB.getErrormsg(@conn, IBM_DB::DB_CONN) end
Return the related error message for the connection.
# File lib/sequel/adapters/ibmdb.rb, line 85 def error_sqlstate IBM_DB.getErrorstate(@conn, IBM_DB::DB_CONN) end
Execute the related prepared statement on the database with the given arguments.
# File lib/sequel/adapters/ibmdb.rb, line 99 def execute_prepared(ps_name, *values) stmt = @prepared_statements[ps_name].last res = stmt.execute(*values) unless res raise Error.new("Error executing statement #{ps_name}: #{error_msg}", error_sqlstate) end stmt end
Prepare a statement with the given sql
on the database, and
cache the prepared statement value by name.
# File lib/sequel/adapters/ibmdb.rb, line 110 def prepare(sql, ps_name) if stmt = IBM_DB.prepare(@conn, sql) ps_name = ps_name.to_sym stmt = Statement.new(stmt) @prepared_statements[ps_name] = [sql, stmt] else err = error_msg err = "Error preparing #{ps_name} with SQL: #{sql}" if error_msg.nil? || error_msg.empty? raise Error.new(err, error_sqlstate) end end
Rollback the currently outstanding transaction on this connection.
# File lib/sequel/adapters/ibmdb.rb, line 123 def rollback IBM_DB.rollback(@conn) end