Module: MultiTenant::MigrationExtensions
- Defined in:
- lib/activerecord-multi-tenant/migrations.rb
Instance Method Summary collapse
- #citus_version ⇒ Object
- #create_distributed_table(table_name, partition_key) ⇒ Object
- #enable_extension_on_all_nodes(extension) ⇒ Object
- #execute_on_all_nodes(sql) ⇒ Object
Instance Method Details
#citus_version ⇒ Object
25 26 27 |
# File 'lib/activerecord-multi-tenant/migrations.rb', line 25 def citus_version execute("SELECT extversion FROM pg_extension WHERE extname = 'citus'").getvalue(0,0).try(:split, '-').try(:first) end |
#create_distributed_table(table_name, partition_key) ⇒ Object
3 4 5 6 |
# File 'lib/activerecord-multi-tenant/migrations.rb', line 3 def create_distributed_table(table_name, partition_key) return unless citus_version.present? execute "SELECT create_distributed_table($$#{table_name}$$, $$#{partition_key}$$)" end |
#enable_extension_on_all_nodes(extension) ⇒ Object
21 22 23 |
# File 'lib/activerecord-multi-tenant/migrations.rb', line 21 def enable_extension_on_all_nodes(extension) execute_on_all_nodes "CREATE EXTENSION IF NOT EXISTS \"#{extension}\"" end |
#execute_on_all_nodes(sql) ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 19 |
# File 'lib/activerecord-multi-tenant/migrations.rb', line 8 def execute_on_all_nodes(sql) execute sql case citus_version when '6.0' execute "SELECT citus_run_on_all_workers($$#{sql}$$)" # initial citus_tools.sql with different names when nil # Do nothing, this is regular Postgres else # 6.1 and newer execute "SELECT run_command_on_workers($$#{sql}$$)" end end |