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")
- UpgradeTo_3_1_0 =
File.join(Root, "/sql/update_to_3_1_0.sql")
- DowngradeFrom_3_1_0 =
File.join(Root, "/sql/downgrade_from_3_1_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
- .downgrade_from_3_1_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
- .update_to_3_1_0(c = QC::default_conn_adapter.connection) ⇒ Object
Class Method Details
.create(c = QC::default_conn_adapter.connection) ⇒ Object
12 13 14 15 16 17 |
# File 'lib/queue_classic/setup.rb', line 12 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
41 42 43 44 |
# File 'lib/queue_classic/setup.rb', line 41 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 |
.downgrade_from_3_1_0(c = QC::default_conn_adapter.connection) ⇒ Object
53 54 55 56 |
# File 'lib/queue_classic/setup.rb', line 53 def self.downgrade_from_3_1_0(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(DowngradeFrom_3_1_0)) end |
.drop(c = QC::default_conn_adapter.connection) ⇒ Object
19 20 21 22 23 24 |
# File 'lib/queue_classic/setup.rb', line 19 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
26 27 28 29 30 31 32 |
# File 'lib/queue_classic/setup.rb', line 26 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(UpgradeTo_3_1_0)) conn.execute(File.read(DropSqlFunctions)) conn.execute(File.read(SqlFunctions)) end |
.update_to_3_0_0(c = QC::default_conn_adapter.connection) ⇒ Object
34 35 36 37 38 39 |
# File 'lib/queue_classic/setup.rb', line 34 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 |
.update_to_3_1_0(c = QC::default_conn_adapter.connection) ⇒ Object
46 47 48 49 50 51 |
# File 'lib/queue_classic/setup.rb', line 46 def self.update_to_3_1_0(c = QC::default_conn_adapter.connection) conn = QC::ConnAdapter.new(c) conn.execute(File.read(UpgradeTo_3_1_0)) conn.execute(File.read(DropSqlFunctions)) conn.execute(File.read(SqlFunctions)) end |