Module: Sequel::ActiveRecordConnection::Jdbc

Defined in:
lib/sequel/extensions/activerecord_connection/jdbc.rb

Instance Method Summary collapse

Instance Method Details

#execute(sql, opts = OPTS) ⇒ Object



15
16
17
18
19
20
21
# File 'lib/sequel/extensions/activerecord_connection/jdbc.rb', line 15

def execute(sql, opts=OPTS)
  activerecord_connection.send(:log, sql) do
    super
  end
rescue ActiveRecord::StatementInvalid => exception
  raise_error(exception.cause, classes: database_error_classes)
end

#execute_dui(sql, opts = OPTS) ⇒ Object



23
24
25
26
27
28
29
# File 'lib/sequel/extensions/activerecord_connection/jdbc.rb', line 23

def execute_dui(sql, opts=OPTS)
  activerecord_connection.send(:log, sql) do
    super
  end
rescue ActiveRecord::StatementInvalid => exception
  raise_error(exception.cause, classes: database_error_classes)
end

#statement(conn) ⇒ Object



4
5
6
7
8
9
10
11
12
13
# File 'lib/sequel/extensions/activerecord_connection/jdbc.rb', line 4

def statement(conn)
  stmt = activerecord_raw_connection.connection.createStatement
  yield stmt
rescue ActiveRecord::StatementInvalid => exception
  raise_error(exception.cause, classes: database_error_classes)
rescue *database_error_classes => e
  raise_error(e, classes: database_error_classes)
ensure
  stmt.close if stmt
end