Sha256: 807703f66f1f83d0b64452d523bcd972e3ab6aa6e90fb6fb2f2fad561344771d

Contents?: true

Size: 1.3 KB

Versions: 8

Compression:

Stored size: 1.3 KB

Contents

Sequel.require 'adapters/shared/mysql'

module Sequel
  module Swift
    # Database and Dataset instance methods for MySQL specific
    # support via Swift.
    module MySQL
      # Database instance methods for MySQL databases accessed via Swift.
      module DatabaseMethods
        include Sequel::MySQL::DatabaseMethods
        
        # Return instance of Sequel::Swift::MySQL::Dataset with the given opts.
        def dataset(opts=nil)
          Sequel::Swift::MySQL::Dataset.new(self, opts)
        end
        
        private
        
        # The database name for the given database.
        def database_name
          opts[:database]
        end

        # Consider tinyint(1) columns as boolean.
        def schema_column_type(db_type)
          db_type == 'tinyint(1)' ? :boolean : super
        end
      end
      
      # Dataset class for MySQL datasets accessed via Swift.
      class Dataset < Swift::Dataset
        include Sequel::MySQL::DatasetMethods
        
        # Use execute_insert to execute the replace_sql.
        def replace(*args)
          execute_insert(replace_sql(*args))
        end
        
        private
        
        # Use Swift's escape method for quoting.
        def literal_string(s)
          db.synchronize{|c| "'#{c.escape(s)}'"}
        end
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version Path
sequel-3.23.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.22.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.21.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.20.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.19.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.18.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.17.0 lib/sequel/adapters/swift/mysql.rb
sequel-3.16.0 lib/sequel/adapters/swift/mysql.rb