Module: MultiTenant::MigrationExtensions

Defined in:
lib/activerecord-multi-tenant/migrations.rb

Instance Method Summary collapse

Instance Method Details

#create_distributed_table(table_name, partition_key) ⇒ Object 



3
4
5
 
# File 'lib/activerecord-multi-tenant/migrations.rb', line 3

def create_distributed_table(table_name, partition_key)
  execute "SELECT create_distributed_table($$#{table_name}$$, $$#{partition_key}$$)"
end

#enable_extension_on_all_nodes(extension) ⇒ Object 



12
13
14
 
# File 'lib/activerecord-multi-tenant/migrations.rb', line 12

def enable_extension_on_all_nodes(extension)
  execute_on_all_nodes "CREATE EXTENSION IF NOT EXISTS \"#{extension}\""
end

#execute_on_all_nodes(sql) ⇒ Object 



7
8
9
10
 
# File 'lib/activerecord-multi-tenant/migrations.rb', line 7

def execute_on_all_nodes(sql)
  execute sql
  execute "SELECT citus_run_on_all_workers($$#{sql}$$)"
end