Updated connectors for phpcake 3 and yii2.

Author: EgorLazarovich

codebase/db_phpcake.php

@@ -12,16 +12,21 @@
 if you plan to use it for Oracle - use Oracle connection type instead
 **/
 class PHPCakeDBDataWrapper extends ArrayDBDataWrapper {
-	public function select($sql) {
-    if(is_array($this->connection))	//result of findAll
-        $query = $this->connection;
-    else
-        $query = $this->connection->find("all");
-    $temp = array();
-    foreach($query as $row)
-        $temp[] = $row->toArray();
-    return new ArrayQueryWrapper($temp);
-}
+
+    public function select($source) {
+        $sourceData = $source->get_source();
+        if(is_array($sourceData))	//result of find
+            $query = $sourceData;
+        else
+            $query = $sourceData->find("all");
+
+        $temp = array();
+        foreach($query as $row)
+            $temp[] = $row->toArray();
+
+        return new ArrayQueryWrapper($temp);
+    }
+
     protected function getErrorMessage() {
         $errors = $this->connection->invalidFields();
         $text = array();
@@ -30,40 +35,49 @@ protected function getErrorMessage() {
         }
         return implode("\n", $text);
     }
+
     public function insert($data, $source) {
-        $table = TableRegistry::get($source->get_source());
-        $obj = $table->newEntity();
+        $sourceData = $source->get_source();
+        $obj = $sourceData->newEntity();
         $obj = $this->fillModel($obj, $data);
-        $savedResult = $this->connection->save($obj);
+        $savedResult = $source->get_source()->save($obj);
         $data->success($savedResult->get($this->config->id["db_name"]));
     }
+
     public function delete($data, $source) {
-        $table = TableRegistry::get($source->get_source());
-        $obj = $table->get($data->get_id());
-        $this->connection->delete($obj);
+        $sourceData = $source->get_source();
+        $obj = $sourceData->get($data->get_id());
+        $source->get_source()->delete($obj);
     }
+
     public function update($data, $source) {
-        $table = TableRegistry::get($source->get_source());
-        $obj = $table->get($data->get_id());
+        $sourceData = $source->get_source();
+        $obj = $sourceData->get($data->get_id());
         $obj = $this->fillModel($obj, $data);
-        $table->save($obj);
+        $sourceData->save($obj);
     }
+
     private function fillModel($obj, $data) {
         //Map data to model object.
         for($i = 0; $i < count($this->config->text); $i++) {
             $step=$this->config->text[$i];
             $obj->set($step["name"], $data->get_value($step["name"]));
         }
+
         if($relation = $this->config->relation_id["db_name"])
             $obj->set($relation, $data->get_value($relation));
+
         return $obj;
     }
+
     public function escape($str){
         throw new Exception("Not implemented");
     }
+
     public function query($str){
         throw new Exception("Not implemented");
     }
+
     public function get_new_id(){
         throw new Exception("Not implemented");
     }

codebase/db_phplaravel.php

@@ -7,33 +7,38 @@
 require_once("db_common.php");
 
 class PHPYiiDBDataWrapper extends ArrayDBDataWrapper {
-    
-    public function select($sql) {
-        if(is_array($this->connection))	//result of findAll
-            $res = $this->connection;
+
+    public function select($source) {
+        $sourceData = $source->get_source();
+        if(is_array($sourceData))	//result of find
+            $res = $sourceData;
         else
-            $res = $this->connection->find()->all();
+            $res = $sourceData->find()->all();
+
         $temp = array();
         if(sizeof($res)) {
             foreach($res as $obj)
                 $temp[] = $obj->getAttributes();
         }
         return new ArrayQueryWrapper($temp);
     }
+
     protected function getErrorMessage() {
         $errors = $this->connection->getErrors();
         $text = array();
         foreach($errors as $key => $value)
             $text[] = $key." - ".$value[0];
+
         return implode("\n", $text);
     }
     public function insert($data, $source) {
-        $name = get_class($this->connection);
+        $name = get_class($source->get_source());
         $obj = new $name();
         $this->fill_model_and_save($obj, $data);
     }
+
     public function delete($data, $source) {
-        $obj = $this->connection->findOne($data->get_id());
+        $obj = $source->get_source()->findOne($data->get_id());
         if($obj->delete()) {
             $data->success();
             $data->set_new_id($obj->getPrimaryKey());
@@ -43,18 +48,22 @@ public function delete($data, $source) {
             $data->invalid();
         }
     }
+
     public function update($data, $source) {
-        $obj = $this->connection->findOne($data->get_id());
+        $obj = $source->get_source()->findOne($data->get_id());
         $this->fill_model_and_save($obj, $data);
     }
+
     protected function fill_model_and_save($obj, $data) {
         //Map data to model object.
         for($i=0; $i < sizeof($this->config->text); $i++) {
             $step=$this->config->text[$i];
             $obj->setAttribute($step["name"], $data->get_value($step["name"]));
         }
+
         if($relation = $this->config->relation_id["db_name"])
             $obj->setAttribute($relation, $data->get_value($relation));
+
         //Save model.
         if($obj->save()) {
             $data->success();
@@ -65,18 +74,23 @@ protected function fill_model_and_save($obj, $data) {
             $data->invalid();
         }
     }
+
     protected function errors_to_string($errors) {
         $text = array();
         foreach($errors as $value)
             $text[] = implode("\n", $value);
+
         return implode("\n",$text);
     }
+
     public function escape($str) {
         throw new Exception("Not implemented");
     }
+
     public function query($str) {
         throw new Exception("Not implemented");
     }
+
     public function get_new_id() {
         throw new Exception("Not implemented");
     }