use collection factory, can extract db name from dsn

php-quartz · Apr 3, 2018 · 07efdc2 · 07efdc2
1 parent 10ca7ae
commit 07efdc2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/Scheduler/Store/YadmStoreResource.php b/Scheduler/Store/YadmStoreResource.php
@@ -1,6 +1,7 @@
 <?php
 namespace Quartz\Scheduler\Store;
 
+use Makasim\Yadm\CollectionFactory;
 use Makasim\Yadm\Hydrator;
 use Makasim\Yadm\PessimisticLock;
 use Makasim\Yadm\Storage;
@@ -89,7 +90,9 @@ public function getClient()
      */
     public function getCollection($name)
     {
-        return $this->getClient()->selectCollection($this->options['dbName'], $name);
+        $factory = new CollectionFactory($this->getClient(), $this->options['uri']);
+
+        return $factory->create($name, $this->options['dbName']);
     }
 
     /**

diff --git a/composer.json b/composer.json
@@ -8,7 +8,7 @@
     "require": {
         "php": ">=5.6",
         "ramsey/uuid": "^2|^3.5",
-        "makasim/yadm": "^0.3",
+        "makasim/yadm": "^0.3.12",
         "g4/cron": "^0.1",
         "symfony/event-dispatcher": "^3.4|^4"
     },