Sha256: fc775fa012c7140e25fae508e38578b80f48a0ced0ff7d7556c02aa793aab79b
Contents?: true
Size: 1.49 KB
Versions: 22
Compression:
Stored size: 1.49 KB
Contents
Sequel.require 'adapters/shared/mysql'
module Sequel
module DataObjects
# Database and Dataset instance methods for MySQL specific
# support via DataObjects.
module MySQL
# Database instance methods for MySQL databases accessed via DataObjects.
module DatabaseMethods
include Sequel::MySQL::DatabaseMethods
# Return instance of Sequel::DataObjects::MySQL::Dataset with the given opts.
def dataset(opts=nil)
Sequel::DataObjects::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 DataObjects does no parsing on the
# given connection string by default.
def database_name
(m = /\/(.*)/.match(URI.parse(uri).path)) && m[1]
end
def schema_column_type(db_type)
db_type == 'tinyint(1)' ? :boolean : super
end
end
# Dataset class for MySQL datasets accessed via DataObjects.
class Dataset < DataObjects::Dataset
include Sequel::MySQL::DatasetMethods
# Use execute_insert to execute the replace_sql.
def replace(*args)
execute_insert(replace_sql(*args))
end
private
# do_mysql sets NO_BACKSLASH_ESCAPES, so use standard SQL string escaping
def literal_string(s)
"'#{s.gsub("'", "''")}'"
end
end
end
end
end
Version data entries
22 entries across 22 versions & 2 rubygems