Class: Sequel::IBMDB::Connection

Inherits:
Object
  • Object
show all
Defined in:
lib/sequel/adapters/ibmdb.rb

Overview

Wraps an underlying connection to DB2 using IBM_DB.

Defined Under Namespace

Classes: Error

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(connection_param) ⇒ Connection

Create the underlying IBM_DB connection.



48
49
50
51
52
53
54
55
56
57
 
# 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

Instance Attribute Details

#prepared_statements ⇒ Object

A hash with prepared statement name symbol keys, where each value is a two element array with an sql string and cached Statement value.



35
36
37
 
# File 'lib/sequel/adapters/ibmdb.rb', line 35

def prepared_statements
  @prepared_statements
end

Instance Method Details

#autocommit ⇒ Object

Check whether the connection is in autocommit state or not.



60
61
62
 
# File 'lib/sequel/adapters/ibmdb.rb', line 60

def autocommit
  IBM_DB.autocommit(@conn) == 1
end

#autocommit=(value) ⇒ Object

Turn autocommit on or off for the connection.



65
66
67
 
# 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 ⇒ Object

Close the connection, disconnecting from DB2.



70
71
72
 
# File 'lib/sequel/adapters/ibmdb.rb', line 70

def close
  IBM_DB.close(@conn)
end

#commit ⇒ Object

Commit the currently outstanding transaction on this connection.



75
76
77
 
# File 'lib/sequel/adapters/ibmdb.rb', line 75

def commit
  IBM_DB.commit(@conn)
end

#error_msg ⇒ Object

Return the related error message for the connection.



80
81
82
 
# File 'lib/sequel/adapters/ibmdb.rb', line 80

def error_msg
  IBM_DB.getErrormsg(@conn, IBM_DB::DB_CONN)
end

#error_sqlstate ⇒ Object

Return the related error message for the connection.



85
86
87
 
# File 'lib/sequel/adapters/ibmdb.rb', line 85

def error_sqlstate
  IBM_DB.getErrorstate(@conn, IBM_DB::DB_CONN)
end

#execute(sql) ⇒ Object

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

Raises:



91
92
93
94
95
 
# File 'lib/sequel/adapters/ibmdb.rb', line 91

def execute(sql)
  stmt = IBM_DB.exec(@conn, sql)
  raise Error.new(error_msg, error_sqlstate) unless stmt
  Statement.new(stmt)
end

#execute_prepared(ps_name, *values) ⇒ Object

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



99
100
101
102
103
104
105
106
 
# 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(sql, ps_name) ⇒ Object

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



110
111
112
113
114
115
116
117
118
119
120
 
# 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 ⇒ Object

Rollback the currently outstanding transaction on this connection.



123
124
125
 
# File 'lib/sequel/adapters/ibmdb.rb', line 123

def rollback
  IBM_DB.rollback(@conn)
end