class Sequel::SchemaSharding::DatabaseManager::SchemaIterator

Public Instance Methods

iterate_on(table_name) { |connection, schema_name, table_name| ... } click to toggle source
# File lib/sequel/schema-sharding/database_manager/schema_iterator.rb, line 2
def iterate_on(table_name, &block)
  config.logical_shard_configs(table_name).each_pair do |shard_number, physical_shard|
    schema_name = connection_manager.schema_for(table_name, shard_number)
    connection = connection_manager.master(physical_shard)

    yield connection, schema_name, table_name
  end
end

Private Instance Methods

config() click to toggle source
# File lib/sequel/schema-sharding/database_manager/schema_iterator.rb, line 13
def config
  Sequel::SchemaSharding.config
end
connection_manager() click to toggle source
# File lib/sequel/schema-sharding/database_manager/schema_iterator.rb, line 17
def connection_manager
  Sequel::SchemaSharding.connection_manager
end