Module: Sequel::Pervasive::DatabaseMethods
- Defined in:
- lib/sequel/pervasive_adapter.rb
Instance Method Summary collapse
-
#database_type ⇒ Object
Pervasive SQL Server uses the :psql type.
- #dataset(opts = nil) ⇒ Object
-
#execute(sql, opts = {}) ⇒ Object
overriding execute to be able to thow a DatabaseDisconnectError when the ODBC::Error is code 08S01.
-
#select_fields(table, *fields) ⇒ Object
def connect(server) conn = super(server) conn.autocommit = false if RAILS_ENV == ‘test’ conn end.
Instance Method Details
#database_type ⇒ Object
Pervasive SQL Server uses the :psql type.
5 6 7 |
# File 'lib/sequel/pervasive_adapter.rb', line 5 def database_type :psql end |
#dataset(opts = nil) ⇒ Object
9 10 11 12 13 |
# File 'lib/sequel/pervasive_adapter.rb', line 9 def dataset(opts = nil) ds = super ds.extend(DatasetMethods) ds end |
#execute(sql, opts = {}) ⇒ Object
overriding execute to be able to thow a DatabaseDisconnectError when the ODBC::Error is code 08S01.
26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/sequel/pervasive_adapter.rb', line 26 def execute(sql, opts={}) log_info(sql) synchronize(opts[:server]) do |conn| begin r = conn.run(sql) yield(r) if block_given? rescue Sequel::DatabaseConnectionError => se raise Sequel.convert_exception_class(se, Sequel::DatabaseDisconnectError) rescue Sequel::DatabaseError => se se = Sequel.convert_exception_class(se, Sequel::DatabaseDisconnectError) if se..match(/08S01/) raise_error(se) rescue ::ODBC::Error => e e = Sequel.convert_exception_class(e, Sequel::DatabaseDisconnectError) if e..match(/08S01/) raise_error(e) ensure r.drop if r end nil end end |
#select_fields(table, *fields) ⇒ Object
def connect(server)
conn = super(server)
conn.autocommit = false if RAILS_ENV == 'test'
conn
end
21 22 23 |
# File 'lib/sequel/pervasive_adapter.rb', line 21 def select_fields(table, *fields) dataset.select_fields(table, *fields) end |