Class: Sequel::IBMDB::Connection

Classes and Modules

Attributes

prepared_statements [R] 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

new(connection_param)

Create the underlying IBM_DB connection.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 41
41:       def initialize(connection_param)
42:         @conn = if connection_param.class == String
43:           IBM_DB.connect(connection_param, '', '')
44:         else  # connect using catalog 
45:           IBM_DB.connect(*connection_param)
46:         end
47: 
48:         self.autocommit = true
49:         @prepared_statements = {}
50:       end

Public Instance methods

autocommit()

Check whether the connection is in autocommit state or not.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 53
53:       def autocommit
54:         IBM_DB.autocommit(@conn) == 1
55:       end

autocommit=(value)

Turn autocommit on or off for the connection.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 58
58:       def autocommit=(value)
59:         IBM_DB.autocommit(@conn, value ? IBM_DB::SQL_AUTOCOMMIT_ON : IBM_DB::SQL_AUTOCOMMIT_OFF)
60:       end

close()

Close the connection, disconnecting from DB2.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 63
63:       def close
64:         IBM_DB.close(@conn)
65:       end

commit()

Commit the currently outstanding transaction on this connection.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 68
68:       def commit
69:         IBM_DB.commit(@conn)
70:       end

error_msg()

Return the related error message for the connection.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 73
73:       def error_msg
74:         IBM_DB.getErrormsg(@conn, IBM_DB::DB_CONN)
75:       end

error_sqlstate()

Return the related error message for the connection.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 78
78:       def error_sqlstate
79:         IBM_DB.getErrorstate(@conn, IBM_DB::DB_CONN)
80:       end

execute(sql)

Execute the given SQL on the database, and return a Statement instance holding the results.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 84
84:       def execute(sql)
85:         stmt = IBM_DB.exec(@conn, sql)
86:         raise Error.new(error_msg, error_sqlstate) unless stmt
87:         Statement.new(stmt)
88:       end

execute_prepared(ps_name, *values)

Execute the related prepared statement on the database with the given arguments.

[Source]

    # File lib/sequel/adapters/ibmdb.rb, line 92
92:       def execute_prepared(ps_name, *values)
93:         stmt = @prepared_statements[ps_name].last
94:         res = stmt.execute(*values)
95:         unless res
96:           raise Error.new("Error executing statement #{ps_name}: #{error_msg}", error_sqlstate)
97:         end
98:         stmt
99:       end

prepare(sql, ps_name)

Prepare a statement with the given sql on the database, and cache the prepared statement value by name.

[Source]

     # File lib/sequel/adapters/ibmdb.rb, line 103
103:       def prepare(sql, ps_name)
104:         if stmt = IBM_DB.prepare(@conn, sql)
105:           ps_name = ps_name.to_sym
106:           stmt = Statement.new(stmt)
107:           @prepared_statements[ps_name] = [sql, stmt]
108:         else
109:           err = error_msg
110:           err = "Error preparing #{ps_name} with SQL: #{sql}" if error_msg.nil? || error_msg.empty?
111:           raise Error.new(err, error_sqlstate)
112:         end
113:       end

rollback()

Rollback the currently outstanding transaction on this connection.

[Source]

     # File lib/sequel/adapters/ibmdb.rb, line 116
116:       def rollback
117:         IBM_DB.rollback(@conn)
118:       end

Methods

Classes and Modules

Attributes

Public Class methods

Public Instance methods