We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 13fe2c2 commit ce17f2bCopy full SHA for ce17f2b
lib/queue_classic/setup.rb
@@ -3,16 +3,16 @@ module Setup
3
Root = File.expand_path("../..", File.dirname(__FILE__))
4
SqlFunctions = File.join(Root, "/sql/ddl.sql")
5
CreateTable = File.join(Root, "/sql/create_table.sql")
6
+ DropSqlFunctions = File.join(QC::Root, "/sql/drop_ddl.sql")
7
8
def self.create
- Conn.transaction do
9
- Conn.execute(File.read(CreateTable))
10
- Conn.execute(File.read(SqlFunctions))
11
- end
+ Conn.execute(File.read(CreateTable))
+ Conn.execute(File.read(SqlFunctions))
12
end
13
14
def self.drop
15
Conn.execute("DROP TABLE IF EXISTS queue_classic_jobs CASCADE")
+ Conn.execute(File.read(DropSqlFunctions))
16
17
18
0 commit comments