Sha256: e5a39ed5b385ed18f69e5efa5b26637780f85c8c5b430101c27637fc00e02d92

Contents?: true

Size: 1.82 KB

Versions: 19

Compression:

Stored size: 1.82 KB

Contents

Sequel.require 'adapters/shared/mssql'

module Sequel
  module ODBC
    Sequel.synchronize do
      DATABASE_SETUP[:mssql] = proc do |db|
        db.extend Sequel::ODBC::MSSQL::DatabaseMethods
        db.dataset_class = Sequel::ODBC::MSSQL::Dataset
        db.send(:set_mssql_unicode_strings)
      end
    end

    # Database and Dataset instance methods for MSSQL specific
    # support via ODBC.
    module MSSQL
      module DatabaseMethods
        extend Sequel::Database::ResetIdentifierMangling
        include Sequel::MSSQL::DatabaseMethods
        LAST_INSERT_ID_SQL='SELECT SCOPE_IDENTITY()'.freeze
        
        # Return the last inserted identity value.
        def execute_insert(sql, opts=OPTS)
          synchronize(opts[:server]) do |conn|
            begin
              log_yield(sql){conn.do(sql)}
              begin
                s = log_yield(LAST_INSERT_ID_SQL){conn.run(LAST_INSERT_ID_SQL)}
                if (rows = s.fetch_all) and (row = rows.first) and (v = row.first)
                  Integer(v)
                end
              ensure
                s.drop if s
              end
            rescue ::ODBC::Error => e
              raise_error(e)
            end
          end
        end
      end
      class Dataset < ODBC::Dataset
        include Sequel::MSSQL::DatasetMethods

        # Use ODBC format, not Microsoft format, as the ODBC layer does
        # some translation.  MSSQL version is over-ridden to allow 3 millisecond decimal places        
        TIMESTAMP_FORMAT="{ts '%Y-%m-%d %H:%M:%S%N'}".freeze

        private

        def default_timestamp_format
          TIMESTAMP_FORMAT
        end

        # Use ODBC format, not Microsoft format, as the ODBC layer does
        # some translation.
        def literal_date(v)
          v.strftime(ODBC_DATE_FORMAT)
        end
      end
    end
  end
end

Version data entries

19 entries across 19 versions & 2 rubygems

Version Path
sequel-4.30.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.29.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.28.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.27.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.26.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.25.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.24.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.23.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.22.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.21.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.20.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.19.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.18.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.17.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.16.0 lib/sequel/adapters/odbc/mssql.rb
asana2flowdock-1.0.0 vendor/bundle/ruby/1.9.1/gems/sequel-4.15.0/lib/sequel/adapters/odbc/mssql.rb
sequel-4.15.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.14.0 lib/sequel/adapters/odbc/mssql.rb
sequel-4.13.0 lib/sequel/adapters/odbc/mssql.rb