Fix deletion sql error

cdujeu · cdujeu · commit b56a0e275db9 · 2016-10-04T16:00:00.000+02:00
diff --git a/core/src/plugins/mq.sql/SqlMessageExchanger.php b/core/src/plugins/mq.sql/SqlMessageExchanger.php
@@ -138,14 +138,14 @@ public function __destruct()
                     $args = array_merge($args, $insertValues);
                     call_user_func_array(array("dibi", "query"), $args);
                 }catch(\DibiException $dE){
-                    $this->logError(__CLASS__, $dE->getMessage());
+                    $this->logError(__CLASS__, $dE->getMessage().". SQL query was: ".$dE->getMessage());
                 }
             }
             if(count($deletes)){
                 try{
-                    dibi::query('DELETE FROM [ajxp_mq_queues] WHERE [channel_name] IN %s', $deletes);
+                    dibi::query('DELETE FROM [ajxp_mq_queues] WHERE [channel_name] IN (%s)', $deletes);
                 }catch(\DibiException $dE){
-                    $this->logError(__CLASS__, $dE->getMessage());
+                    $this->logError(__CLASS__, $dE->getMessage().". SQL query was: ".$dE->getMessage());
                 }
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -138,14 +138,14 @@ public function __destruct()`
`138`	`138`	`$args = array_merge($args, $insertValues);`
`139`	`139`	`call_user_func_array(array("dibi", "query"), $args);`
`140`	`140`	`}catch(\DibiException $dE){`
`141`		`- $this->logError(__CLASS__, $dE->getMessage());`
	`141`	`+ $this->logError(__CLASS__, $dE->getMessage().". SQL query was: ".$dE->getMessage());`
`142`	`142`	`}`
`143`	`143`	`}`
`144`	`144`	`if(count($deletes)){`
`145`	`145`	`try{`
`146`		`- dibi::query('DELETE FROM [ajxp_mq_queues] WHERE [channel_name] IN %s', $deletes);`
	`146`	`+ dibi::query('DELETE FROM [ajxp_mq_queues] WHERE [channel_name] IN (%s)', $deletes);`
`147`	`147`	`}catch(\DibiException $dE){`
`148`		`- $this->logError(__CLASS__, $dE->getMessage());`
	`148`	`+ $this->logError(__CLASS__, $dE->getMessage().". SQL query was: ".$dE->getMessage());`
`149`	`149`	`}`
`150`	`150`	`}`
`151`	`151`	`}`