only create table if it doesn't exist

n0nag0n · Jan 18, 2021 · 5e75da0 · 5e75da0
1 parent e56284c
commit 5e75da0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/Job_Queue.php b/src/Job_Queue.php
@@ -486,7 +486,7 @@ protected function checkAndIfNecessaryCreateJobQueueTable(): void {
 			if(!$has_table) {
 				if($this->isMysqlQueueType()) {
 					$field_type = $this->options['mysql']['use_compression'] ? 'longblob' : 'longtext';
-					$this->connection->exec("CREATE TABLE {$table_name} (
+					$this->connection->exec("CREATE TABLE IF NOT EXISTS {$table_name} (
 						`id` int(11) NOT NULL AUTO_INCREMENT,
 						`pipeline` varchar(500) NOT NULL,
 						`payload` {$field_type} NOT NULL,
@@ -503,7 +503,7 @@ protected function checkAndIfNecessaryCreateJobQueueTable(): void {
 						KEY `pipeline_send_dt_is_buried_is_reserved` (`pipeline`(75), `send_dt`, `is_buried`, `is_reserved`)
 					);");
 				} else {
-					$this->connection->exec("CREATE TABLE {$table_name} (
+					$this->connection->exec("CREATE TABLE IF NOT EXISTS {$table_name} (
 						'id' INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
 						'pipeline' TEXT NOT NULL,
 						'payload' TEXT NOT NULL,