Contents

require 'pathname'

require 'rom/types'
require 'rom/initializer'

module ROM
  module SQL
    module Migration
      # @api private
      class Migrator
        extend Initializer

        DEFAULT_PATH = 'db/migrate'.freeze
        VERSION_FORMAT = '%Y%m%d%H%M%S'.freeze

        param :connection

        option :path, type: ROM::Types.Definition(Pathname), default: -> { DEFAULT_PATH }

        # @api private
        def run(options = {})
          Sequel::Migrator.run(connection, path.to_s, options)
        end

        # @api private
        def pending?
          !Sequel::Migrator.is_current?(connection, path.to_s)
        end

        # @api private
        def migration(&block)
          Sequel.migration(&block)
        end

        # @api private
        def create_file(name, version = generate_version)
          filename = "#{version}_#{name}.rb"
          dirname = Pathname(path)
          fullpath = dirname.join(filename)

          FileUtils.mkdir_p(dirname)
          File.write(fullpath, migration_file_content)

          fullpath
        end

        # @api private
        def generate_version
          Time.now.utc.strftime(VERSION_FORMAT)
        end

        # @api private
        def migration_file_content
          File.read(Pathname(__FILE__).dirname.join('template.rb').realpath)
        end
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
rom-sql-1.3.5	lib/rom/sql/migration/migrator.rb
rom-sql-1.3.4	lib/rom/sql/migration/migrator.rb
rom-sql-1.3.3	lib/rom/sql/migration/migrator.rb
rom-sql-1.3.2	lib/rom/sql/migration/migrator.rb
rom-sql-1.3.1	lib/rom/sql/migration/migrator.rb
rom-sql-1.3.0	lib/rom/sql/migration/migrator.rb
rom-sql-1.2.2	lib/rom/sql/migration/migrator.rb