Sha256: 8d46c9799b6bd90b777555c27a1501e278bd2806e9cbf78affc24edda3728e32
Contents?: true
Size: 1.65 KB
Versions: 8
Compression:
Stored size: 1.65 KB
Contents
Sequel.require 'adapters/shared/mysql'
module Sequel
module JDBC
# Database and Dataset instance methods for MySQL specific
# support via JDBC.
module MySQL
# Database instance methods for MySQL databases accessed via JDBC.
module DatabaseMethods
include Sequel::MySQL::DatabaseMethods
# Return instance of Sequel::JDBC::MySQL::Dataset with the given opts.
def dataset(opts=nil)
Sequel::JDBC::MySQL::Dataset.new(self, opts)
end
private
# The database name for the given database. Need to parse it out
# of the connection string, since the JDBC does no parsing on the
# given connection string by default.
def database_name
u = URI.parse(uri.sub(/\Ajdbc:/, ''))
(m = /\/(.*)/.match(u.path)) && m[1]
end
# Get the last inserted id using LAST_INSERT_ID().
def last_insert_id(conn, opts={})
stmt = conn.createStatement
begin
rs = stmt.executeQuery('SELECT LAST_INSERT_ID()')
rs.next
rs.getInt(1)
ensure
stmt.close
end
end
end
# Dataset class for MySQL datasets accessed via JDBC.
class Dataset < JDBC::Dataset
include Sequel::MySQL::DatasetMethods
# Use execute_insert to execute the insert_sql.
def insert(*values)
execute_insert(insert_sql(*values))
end
# Use execute_insert to execute the replace_sql.
def replace(*args)
execute_insert(replace_sql(*args))
end
end
end
end
end
Version data entries
8 entries across 8 versions & 2 rubygems