Module: Postjob::Migrations

Extended by:
Migrations
Included in:
Migrations
Defined in:
lib/postjob/migrations.rb

Constant Summary collapse

SQL = 
::Simple::SQL
SCHEMA_NAME = 
::Postjob::Queue::SCHEMA_NAME
CHANNEL = 
::Postjob::Queue::Notifications::CHANNEL
CLIENT_VERSION = 
"ruby/#{::Postjob::VERSION}"
DEFAULT_QUEUE = 
::Postjob::DEFAULT_QUEUE

Instance Method Summary collapse

Instance Method Details

#migrate! ⇒ Object 



24
25
26
27
28
29
30
 
# File 'lib/postjob/migrations.rb', line 24

def migrate!
  SQL.exec "CREATE SCHEMA IF NOT EXISTS #{SCHEMA_NAME}"

  Dir.glob(__FILE__.gsub(/\.rb$/, "/**/*.{sql,rb}")).sort.each do |file|
    run_migration file
  end
end

#unmigrate! ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/postjob/migrations.rb', line 17

def unmigrate!
  ::Postjob::Host.clear_storage

  SQL.exec "SET client_min_messages TO WARNING"
  SQL.exec "DROP SCHEMA IF EXISTS #{SCHEMA_NAME} CASCADE"
end