/usr/lib/ruby/vendor_ruby/sequel/adapters/ado.rb is in ruby-sequel 4.15.0-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 | require 'win32ole'
module Sequel
# The ADO adapter provides connectivity to ADO databases in Windows.
module ADO
class Database < Sequel::Database
DISCONNECT_ERROR_RE = /Communication link failure/
set_adapter_scheme :ado
# In addition to the usual database options,
# the following options have an effect:
#
# :command_timeout :: Sets the time in seconds to wait while attempting
# to execute a command before cancelling the attempt and generating
# an error. Specifically, it sets the ADO CommandTimeout property.
# If this property is not set, the default of 30 seconds is used.
# :driver :: The driver to use in the ADO connection string. If not provided, a default
# of "SQL Server" is used.
# :conn_string :: The full ADO connection string. If this is provided,
# the usual options are ignored.
# :provider :: Sets the Provider of this ADO connection (for example, "SQLOLEDB").
# If you don't specify a provider, the default one used by WIN32OLE
# has major problems, such as creating a new native database connection
# for every query, which breaks things such as temporary tables.
#
# Pay special attention to the :provider option, as without specifying a provider,
# many things will be broken. The SQLNCLI10 provider appears to work well if you
# are connecting to Microsoft SQL Server, but it is not the default as that would
# break backwards compatability.
def connect(server)
opts = server_opts(server)
s = opts[:conn_string] || "driver=#{opts[:driver]};server=#{opts[:host]};database=#{opts[:database]}#{";uid=#{opts[:user]};pwd=#{opts[:password]}" if opts[:user]}"
handle = WIN32OLE.new('ADODB.Connection')
handle.CommandTimeout = opts[:command_timeout] if opts[:command_timeout]
handle.Provider = opts[:provider] if opts[:provider]
handle.Open(s)
handle
end
def disconnect_connection(conn)
conn.Close
rescue WIN32OLERuntimeError
nil
end
# Just execute so it doesn't attempt to return the number of rows modified.
def execute_ddl(sql, opts=OPTS)
execute(sql, opts)
end
# Just execute so it doesn't attempt to return the number of rows modified.
def execute_insert(sql, opts=OPTS)
execute(sql, opts)
end
# Use pass by reference in WIN32OLE to get the number of affected rows,
# unless is a provider is in use (since some providers don't seem to
# return the number of affected rows, but the default provider appears
# to).
def execute_dui(sql, opts=OPTS)
return super if opts[:provider]
synchronize(opts[:server]) do |conn|
begin
log_yield(sql){conn.Execute(sql, 1)}
WIN32OLE::ARGV[1]
rescue ::WIN32OLERuntimeError => e
raise_error(e)
end
end
end
def execute(sql, opts=OPTS)
synchronize(opts[:server]) do |conn|
begin
r = log_yield(sql){conn.Execute(sql)}
yield(r) if block_given?
rescue ::WIN32OLERuntimeError => e
raise_error(e)
end
end
nil
end
private
def adapter_initialize
case @opts[:conn_string]
when /Microsoft\.(Jet|ACE)\.OLEDB/io
Sequel.require 'adapters/ado/access'
extend Sequel::ADO::Access::DatabaseMethods
self.dataset_class = ADO::Access::Dataset
else
@opts[:driver] ||= 'SQL Server'
case @opts[:driver]
when 'SQL Server'
Sequel.require 'adapters/ado/mssql'
extend Sequel::ADO::MSSQL::DatabaseMethods
self.dataset_class = ADO::MSSQL::Dataset
set_mssql_unicode_strings
end
end
super
end
# The ADO adapter's default provider doesn't support transactions, since it
# creates a new native connection for each query. So Sequel only attempts
# to use transactions if an explicit :provider is given.
def begin_transaction(conn, opts=OPTS)
super if @opts[:provider]
end
def commit_transaction(conn, opts=OPTS)
super if @opts[:provider]
end
def database_error_classes
[::WIN32OLERuntimeError]
end
def disconnect_error?(e, opts)
super || (e.is_a?(::WIN32OLERuntimeError) && e.message =~ DISCONNECT_ERROR_RE)
end
def rollback_transaction(conn, opts=OPTS)
super if @opts[:provider]
end
end
class Dataset < Sequel::Dataset
Database::DatasetClass = self
def fetch_rows(sql)
execute(sql) do |s|
columns = cols = s.Fields.extend(Enumerable).map{|column| output_identifier(column.Name)}
@columns = columns
s.getRows.transpose.each do |r|
row = {}
cols.each{|c| row[c] = r.shift}
yield row
end unless s.eof
end
end
# ADO returns nil for all for delete and update statements.
def provides_accurate_rows_matched?
false
end
end
end
end
|