Re-use existing PDO object

josegonzalez · Dec 12, 2012 · 6b32579 · 6b32579
1 parent c3a9692
commit 6b32579
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 42 deletions.
diff --git a/Console/Command/Task/CakeDjjobTask.php b/Console/Command/Task/CakeDjjobTask.php
@@ -44,16 +44,7 @@ function configure($config) {
 		$connection = ConnectionManager::getDataSource($this->settings['connection']);
 
 		if ($this->settings['type'] == 'mysql') {
-			DJJob::configure(
-				implode(';', array(
-					"{$this->settings['type']}:host={$connection->config['host']}",
-					"dbname={$connection->config['database']}",
-					"port={$connection->config['port']}",
-				)), array(
-					'mysql_user' => $connection->config['login'],
-					'mysql_pass' => $connection->config['password']
-				)
-			);
+			DJJob::setConnection($connection->getConnection());
 		} else {
 			DJJob::configure(
 				implode(';', array(
@@ -142,4 +133,4 @@ function bulkEnqueue($jobs, $queue = "default", $run_at = null) {
 	function status($queue = "default") {
 		return DJJob::status($queue);
 	}
-}
+}
diff --git a/Console/Command/WorkerShell.php b/Console/Command/WorkerShell.php
@@ -50,16 +50,7 @@ public function startup() {
 		$connection = ConnectionManager::getDataSource($this->params['connection']);
 
 		if ($this->params['type'] == 'mysql') {
-			DJJob::configure(
-				implode(';', array(
-					"{$this->params['type']}:host={$connection->config['host']}",
-					"dbname={$connection->config['database']}",
-					"port={$connection->config['port']}",
-				)), array(
-					'mysql_user' => $connection->config['login'],
-					'mysql_pass' => $connection->config['password']
-				)
-			);
+			DJJob::setConnection($connection->getConnection());
 		} else {
 			DJJob::configure(
 				implode(';', array(
@@ -146,4 +137,4 @@ public function getOptionParser() {
 		));
 	}
 
-}
+}
diff --git a/Controller/Component/CakeDjjobComponent.php b/Controller/Component/CakeDjjobComponent.php
@@ -44,16 +44,7 @@ public function initialize(Controller $controller) {
 		$connection = ConnectionManager::getDataSource($this->settings['connection']);
 
 		if ($this->settings['type'] == 'mysql') {
-			DJJob::configure(
-				implode(';', array(
-					"{$this->settings['type']}:host={$connection->config['host']}",
-					"dbname={$connection->config['database']}",
-					"port={$connection->config['port']}",
-				)), array(
-					'mysql_user' => $connection->config['login'],
-					'mysql_pass' => $connection->config['password']
-				)
-			);
+			DJJob::setConnection($connection->getConnection());
 		} else {
 			DJJob::configure(
 				implode(';', array(

diff --git a/Model/Behavior/CakeDjjobBehavior.php b/Model/Behavior/CakeDjjobBehavior.php
@@ -43,16 +43,7 @@ public function setup(Model $model, $config = array()) {
 		$connection = ConnectionManager::getDataSource($this->settings['connection']);
 
 		if ($this->settings['type'] == 'mysql') {
-			DJJob::configure(
-				implode(';', array(
-					"{$this->settings['type']}:host={$connection->config['host']}",
-					"dbname={$connection->config['database']}",
-					"port={$connection->config['port']}",
-				)), array(
-					'mysql_user' => $connection->config['login'],
-					'mysql_pass' => $connection->config['password']
-				)
-			);
+			DJJob::setConnection($connection->getConnection());
 		} else {
 			DJJob::configure(
 				implode(';', array(