Contents

require 'pathname'

Sequel.extension :migration

module Praxis::Mapper
  module Support
    class SchemaLoader

      attr_reader :options, :schema_root

      def initialize(schema_root='.', **options)
        @schema_root = Pathname.new(schema_root)
        @options = options
        @connection_manager = ConnectionManager.new
        @repositories = Set.new

        @migrations = Hash.new

        @connection_manager.repositories.each do |repository_name, config|

          next unless config[:query] == Praxis::Mapper::Query::Sql

          migration_path = @schema_root + repository_name.to_s

          migration_path.children.each do |file|
            table = file.basename.to_s[0..-4]

            before = Sequel::Migration.descendants.clone
            require file.expand_path if file.exist?

            after = Sequel::Migration.descendants

            migration = (after - before).first

            @migrations[repository_name] ||= Array.new
            @migrations[repository_name] << [table, migration]
          end

        end
      end


      def load!
        @migrations.each do |repository_name, migrations|
          connection = @connection_manager.checkout(repository_name)

          migrations.each do |(table, migration)|
            migration.apply(connection, :up)
          end
        end
   
      end

    end
  end
end

Version data entries

14 entries across 14 versions & 1 rubygems

Version	Path
praxis-mapper-4.5	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.4.1	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.4	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.3	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.2	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.1.2	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.1.1	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.1	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-4.0	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-3.4.0	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-3.3	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-3.2	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-3.1.2	lib/praxis-mapper/support/schema_loader.rb
praxis-mapper-3.1.1	lib/praxis-mapper/support/schema_loader.rb