Module: QC::Setup
- Defined in:
- lib/queue_classic/setup.rb
Constant Summary collapse
- Root =
File.("../..", File.dirname(__FILE__))
- SqlFunctions =
File.join(Root, "/sql/ddl.sql")
- CreateTable =
File.join(Root, "/sql/create_table.sql")
- DropSqlFunctions =
File.join(Root, "/sql/drop_ddl.sql")
- UpgradeTo_3_0_0 =
File.join(Root, "/sql/update_to_3_0_0.sql")
- DowngradeFrom_3_0_0 =
File.join(Root, "/sql/downgrade_from_3_0_0.sql")
Class Method Summary collapse
- .create(c = QC::default_conn_adapter.connection) ⇒ Object
- .downgrade_from_3_0_0(c = QC::default_conn_adapter.connection) ⇒ Object
- .drop(c = QC::default_conn_adapter.connection) ⇒ Object
- .update(c = QC::default_conn_adapter.connection) ⇒ Object
- .update_to_3_0_0(c = QC::default_conn_adapter.connection) ⇒ Object
Class Method Details
.create(c = QC::default_conn_adapter.connection) ⇒ Object
10 11 12 13 14 15 |
# File 'lib/queue_classic/setup.rb', line 10 def self.create(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(CreateTable)) conn.execute(File.read(SqlFunctions)) conn.disconnect if c.nil? #Don't close a conn we didn't create. end |
.downgrade_from_3_0_0(c = QC::default_conn_adapter.connection) ⇒ Object
38 39 40 41 |
# File 'lib/queue_classic/setup.rb', line 38 def self.downgrade_from_3_0_0(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(DowngradeFrom_3_0_0)) end |
.drop(c = QC::default_conn_adapter.connection) ⇒ Object
17 18 19 20 21 22 |
# File 'lib/queue_classic/setup.rb', line 17 def self.drop(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute("DROP TABLE IF EXISTS queue_classic_jobs CASCADE") conn.execute(File.read(DropSqlFunctions)) conn.disconnect if c.nil? #Don't close a conn we didn't create. end |
.update(c = QC::default_conn_adapter.connection) ⇒ Object
24 25 26 27 28 29 |
# File 'lib/queue_classic/setup.rb', line 24 def self.update(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(UpgradeTo_3_0_0)) conn.execute(File.read(DropSqlFunctions)) conn.execute(File.read(SqlFunctions)) end |
.update_to_3_0_0(c = QC::default_conn_adapter.connection) ⇒ Object
31 32 33 34 35 36 |
# File 'lib/queue_classic/setup.rb', line 31 def self.update_to_3_0_0(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(UpgradeTo_3_0_0)) conn.execute(File.read(DropSqlFunctions)) conn.execute(File.read(SqlFunctions)) end |