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