LEVENSHTEIN

.gitignore

@@ -0,0 +1 @@
+/vendor

README.RU.md

@@ -57,7 +57,7 @@ use explosivebit\arangodb\Query;
 $query = new Query;
 // compose the query
 $query->select(['name', 'status'])
-    ->from('customer')
+    ->collection('customer')
     ->limit(10);
 // execute the query
 $rows = $query->all();
@@ -103,7 +103,7 @@ use yii\data\ActiveDataProvider;
 use explosivebit\arangodb\Query;
 
 $query = new Query;
-$query->from('customer')->where(['status' => 2]);
+$query->collection('customer')->where(['status' => 2]);
 $provider = new ActiveDataProvider([
     'query' => $query,
     'pagination' => [

README.md

@@ -62,7 +62,7 @@ use explosivebit\arangodb\Query;
 $query = new Query;
 // compose the query
 $query->select(['name', 'status'])
-    ->from('customer')
+    ->collection('customer')
     ->limit(10);
 // execute the query
 $rows = $query->all();
@@ -108,7 +108,7 @@ use yii\data\ActiveDataProvider;
 use explosivebit\arangodb\Query;
 
 $query = new Query;
-$query->from('customer')->where(['status' => 2]);
+$query->collection('customer')->where(['status' => 2]);
 $provider = new ActiveDataProvider([
     'query' => $query,
     'pagination' => [

composer.json

@@ -1,9 +1,13 @@
 {
     "name": "mirzaev/yii2-arangodb",
-    "description": "Yii2 ArangoDB",
-    "type": "library",
+    "description": "Library for connecting ArangoDB-PHP to Yii2",
+    "keywords": [
+        "Yii2",
+        "ArangoDB"
+    ],
+    "type": "yii2-extension",
     "license": "AGPL-3.0-or-later",
-    "homepage": "https://git.hood.su/mirzaev/yii2-arangodb",
+    "homepage": "https://git.hood.su/mirzaev/yii2/arangodb",
     "authors": [
         {
             "name": "Arsen Mirzaev Tatyano-Muradovich",
@@ -12,25 +16,30 @@
             "role": "Developer"
         },
         {
-            "homepage": "https://github.com/explosivebit/yii2-arangodb",
-            "role": "Old fork (abandoned)"
+            "name": "Ilya Rumyantsev",
+            "email": "explosivebit@gmail.com"
         },
         {
-            "homepage": "https://github.com/DevGroup-ru/yii2-arangodb",
-            "role": "Original repository (abandoned)"
+            "name": "Alvian Burhanuddin",
+            "email": "alvianthelfarqy@gmail.com"
         }
     ],
     "require": {
-        "php": "^8.0.0"
+        "php": "^8.0.0",
+        "yiisoft/yii2": "2.*",
+        "triagens/arangodb": "~3.2"
+    },
+    "require-dev": {
+        "yiisoft/yii2-debug": "*"
     },
     "autoload": {
         "psr-4": {
-            "mirzaev\\yii2\\arangodb\\": "mirzaev/yii2-arangodb"
+            "mirzaev\\yii2\\arangodb\\": "mirzaev/yii2/arangodb"
         }
     },
     "autoload-dev": {
         "psr-4": {
-            "mirzaev\\yii2\\arangodb\\tests\\": "mirzaev/yii2-arangodb/tests"
+            "mirzaev\\yii2\\arangodb\\tests\\": "mirzaev/yii2/arangodb/tests"
         }
     }
 }

mirzaev/yii2-arangodb/.gitignore

@@ -1,3 +0,0 @@
-composer.phar
-composer.lock
-vendor

mirzaev/yii2-arangodb/composer.json

@@ -1,30 +0,0 @@
-{
-    "name": "elfarqy/yii2-arangodb",
-    "description": "Yii2 arangodb components",
-    "type": "yii2-extension",
-    "keywords": ["yii2","arangodb"],
-    "license": "GPL-3.0+",
-    "authors": [
-        {
-            "name": "Ilya Rumyantsev",
-            "email": "explosivebit@gmail.com"
-        },
-	{
-            "name": "Alvian Burhanuddin",
-            "email": "alvianthelfarqy@gmail.com"
-        }
-    ],
-    "minimum-stability": "dev",
-    "require": {
-        "yiisoft/yii2": "*",
-        "triagens/arangodb": "~3.2"
-    },
-    "require-dev": {
-        "yiisoft/yii2-debug": "*"
-    },
-    "autoload": {
-        "psr-4": {
-            "explosivebit\\arangodb\\": ""
-        }
-    }
-}

mirzaev/yii2-arangodb/views/migration.php

@@ -1,22 +0,0 @@
-<?php
-/**
- * This view is used by console/controllers/MigrateController.php
- * The following variables are available in this view:
- */
-
-/* @var $className string the new migration class name */
-echo "<?php\n";
-?>
-
-class <?= $className ?> extends \explosivebit\arangodb\Migration
-{
-    public function up()
-    {
-		$this->createCollection('<?= $className ?>',[]);
-    }
-
-    public function down()
-    {
-        $this->dropCollection('<?= $className ?>');
-    }
-}

mirzaev/yii2/arangodb/ActiveQuery.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 use Yii;
 use yii\db\ActiveQueryInterface;
@@ -20,7 +20,7 @@ class ActiveQuery extends Query implements ActiveQueryInterface
         parent::__construct($config);
     }
 
-    protected function buildQuery($query = null, $params = [])
+    protected function genQuery($query = null, array $params = [])
     {
         if ($this->primaryModel !== null) {
             // lazy loading
@@ -46,7 +46,7 @@ class ActiveQuery extends Query implements ActiveQueryInterface
             }
         }
 
-        return parent::buildQuery($query, $params);
+        return parent::genQuery($query, $params);
     }
 
     private function createModels($rows)
@@ -103,17 +103,21 @@ class ActiveQuery extends Query implements ActiveQueryInterface
     public function all($db = null)
     {
         $statement = $this->createCommand($db);
+
         $token = $this->getRawAql($statement);
-        Yii::info($token, 'explosivebit\arangodb\Query::query');
+
+        Yii::info($token, 'mirzaev\yii2\arangodb\Query::query');
+
         try {
-            Yii::beginProfile($token, 'explosivebit\arangodb\Query::query');
+            Yii::beginProfile($token, 'mirzaev\yii2\arangodb\Query::query');
             $cursor = $statement->execute();
             $rows = $cursor->getAll();
-            Yii::endProfile($token, 'explosivebit\arangodb\Query::query');
+            Yii::endProfile($token, 'mirzaev\yii2\arangodb\Query::query');
         } catch (\Exception $ex) {
-            Yii::endProfile($token, 'explosivebit\arangodb\Query::query');
+            Yii::endProfile($token, 'mirzaev\yii2\arangodb\Query::query');
             throw new \Exception($ex->getMessage(), (int) $ex->getCode(), $ex);
         }
+
         if (!empty($rows)) {
             $models = $this->createModels($rows);
             if (!empty($this->with)) {

mirzaev/yii2/arangodb/ActiveRecord.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 use Yii;
 use yii\base\InvalidConfigException;
@@ -102,13 +102,12 @@ abstract class ActiveRecord extends BaseActiveRecord
      * // FOR customer IN customer FILTER customer.age>30 RETURN customer
      * $customers = Customer::find()->where('age>30')->all();
      *
-     * @return ActiveQueryInterface the newly created [[ActiveQueryInterface|ActiveQuery]] instance.
      */
-    public static function find()
+    public static function find(): ActiveQuery
     {
         /** @var ActiveQuery $query */
-        $query = \Yii::createObject(ActiveQuery::className(), [get_called_class()]);
-        $query->from(static::collectionName())->select(static::collectionName());
+        $query = Yii::createObject(ActiveQuery::class, [get_called_class()]);
+        $query->in(static::collectionName())->select(static::collectionName());
 
         return $query;
     }
@@ -123,6 +122,14 @@ abstract class ActiveRecord extends BaseActiveRecord
             $row = $row->getAll();
         }
 
+        if (!is_iterable($row)) {
+            // Если нельзя обработать полученные данные
+            // Например, если прочитан NULL, то далее будет ошибка при обработке в foreach
+
+            // Реинициализация
+            $row = [];
+        }
+
         parent::populateRecord($record, $row);
     }
 
@@ -163,6 +170,7 @@ abstract class ActiveRecord extends BaseActiveRecord
         if ($runValidation && !$this->validate($attributes)) {
             return false;
         }
+
         $result = $this->insertInternal($attributes, $options);
 
         return $result;
@@ -182,7 +190,9 @@ abstract class ActiveRecord extends BaseActiveRecord
         }
 
         $newId = static::getDb()->getDocumentHandler()->save(static::collectionName(), $values);
+
         static::populateRecord($this, static::getDb()->getDocument(static::collectionName(), $newId));
+
         $this->setIsNewRecord(false);
 
         $changedAttributes = array_fill_keys(array_keys($values), null);
@@ -210,8 +220,11 @@ abstract class ActiveRecord extends BaseActiveRecord
             $this->afterSave(false, $values);
             return 0;
         }
+
         $condition = $this->getOldPrimaryKey(true);
+
         $lock = $this->optimisticLock();
+
         if ($lock !== null) {
             if (!isset($values[$lock])) {
                 $values[$lock] = $this->$lock + 1;
@@ -223,12 +236,17 @@ abstract class ActiveRecord extends BaseActiveRecord
             $this->setAttribute($key, $attribute);
         }
 
-        $rows = (new Query())->options($options)->update(
-            static::collectionName(),
+        $rows = (new Query())
+            ->options($options)
+            ->in(static::collectionName())
+            ->where(['_key' => $this->getOldAttribute('_key')])
+            ->update(
+                array_merge(
                     $values,
                     [
                         '_key' => $this->getOldAttribute('_key'),
                     ]
+                )
             );
 
         if ($lock !== null && !$rows) {
@@ -251,7 +269,7 @@ abstract class ActiveRecord extends BaseActiveRecord
      */
     public static function getDb()
     {
-        return \Yii::$app->get('arangodb');
+        return Yii::$app->get('arangodb');
     }
 
     protected static function findByCondition($condition)
@@ -291,7 +309,7 @@ abstract class ActiveRecord extends BaseActiveRecord
      */
     public static function updateAll($attributes, $condition = [], $options = [])
     {
-        return (new Query())->options($options)->update(static::collectionName(), $attributes, $condition);
+        return (new Query())->options($options)->in(static::collectionName())->update($attributes, $condition);
     }
 
     /**
@@ -312,7 +330,7 @@ abstract class ActiveRecord extends BaseActiveRecord
      */
     public static function deleteAll($condition = [], $options = [])
     {
-        return (new Query())->options($options)->remove(static::collectionName(), $condition);
+        return (new Query())->options($options)->in(static::collectionName())->remove($condition);
     }
 
     public static function truncate()
@@ -362,6 +380,7 @@ abstract class ActiveRecord extends BaseActiveRecord
     public function delete($options = [])
     {
         $result = false;
+
         if ($this->beforeDelete()) {
             $result = $this->deleteInternal($options);
             $this->afterDelete();
@@ -377,14 +396,23 @@ abstract class ActiveRecord extends BaseActiveRecord
     protected function deleteInternal($options = [])
     {
         $condition = $this->getOldPrimaryKey(true);
+
         $lock = $this->optimisticLock();
+
         if ($lock !== null) {
             $condition[$lock] = $this->$lock;
         }
-        $result = (new Query())->options($options)->remove(static::collectionName(), $condition);
+
+        $result = (new Query())
+            ->options($options)
+            ->in(static::collectionName())
+            ->where($condition)
+            ->remove();
+
         if ($lock !== null && !$result) {
             throw new StaleObjectException('The object being deleted is outdated.');
         }
+
         $this->setOldAttributes(null);
 
         return $result;

mirzaev/yii2/arangodb/AqlExpression.php

@@ -1,15 +1,10 @@
 <?php
-/**
- * User: evgen-d
- * Date: 08.10.14
- * Time: 16:00
- */
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
-use yii\base\Object;
+use yii\base\BaseObject;
 
-class AqlExpression extends Object
+class AqlExpression extends BaseObject
 {
     /**
      * @var string the AQL expression represented by this object
@@ -37,4 +32,3 @@ class AqlExpression extends Object
         return $this->expression;
     }
 }
- 

mirzaev/yii2/arangodb/Connection.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 use ArangoDBClient\EdgeHandler;
 use ArangoDBClient\Export;
@@ -56,16 +56,16 @@ class Connection extends BaseObject
 
         $token = 'Opening ArangoDB connection: ' . $this->connectionOptions[ConnectionOptions::OPTION_ENDPOINT];
         try {
-            Yii::info($token, 'explosivebit\arangodb\Connection::open');
-            Yii::beginProfile($token, 'explosivebit\arangodb\Connection::open');
+            Yii::info($token, 'mirzaev\yii2\arangodb\Connection::open');
+            Yii::beginProfile($token, 'mirzaev\yii2\arangodb\Connection::open');
             $this->connection        = new \ArangoDBClient\Connection($this->connectionOptions);
             $this->collectionHandler = new CollectionHandler($this->connection);
             $this->documentHandler   = new DocumentHandler($this->connection);
             $this->edgeHandler       = new EdgeHandler($this->connection);
             $this->graphHandler      = new GraphHandler($this->connection);
-            Yii::endProfile($token, 'explosivebit\arangodb\Connection::open');
+            Yii::endProfile($token, 'mirzaev\yii2\arangodb\Connection::open');
         } catch (\Exception $ex) {
-            Yii::endProfile($token, 'explosivebit\arangodb\Connection::open');
+            Yii::endProfile($token, 'mirzaev\yii2\arangodb\Connection::open');
             throw new \Exception($ex->getMessage(), (int)$ex->getCode(), $ex);
         }
     }

mirzaev/yii2/arangodb/Exception.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 class Exception extends \yii\base\Exception
 {

mirzaev/yii2/arangodb/Migration.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 use yii\base\Component;
 use yii\db\MigrationInterface;
@@ -22,7 +22,8 @@ abstract class Migration extends Component implements MigrationInterface
     public function init()
     {
         parent::init();
-        $this->db = Instance::ensure($this->db, Connection::className());
+
+        $this->db = Instance::ensure($this->db, Connection::class);
     }
 
     public function execute($aql, $bindValues = [], $params = [])
@@ -86,4 +87,6 @@ abstract class Migration extends Component implements MigrationInterface
         $this->db->getCollectionHandler()->truncate($collection);
         echo " done (time: " . sprintf('%.3f', microtime(true) - $time) . "s)\n";
     }
+
+    // Разработать создание графов и представлений
 }

mirzaev/yii2/arangodb/Serializer.php

@@ -1,11 +1,6 @@
 <?php
-/**
- * User: evgen-d
- * Date: 08.10.14
- * Time: 16:04
- */
 
-namespace explosivebit\arangodb;
+namespace mirzaev\yii2\arangodb;
 
 use yii\base\Arrayable;
 
@@ -56,4 +51,3 @@ class Serializer
         return $data;
     }
 }
- 

mirzaev/yii2/arangodb/console/controllers/MigrateController.php

@@ -1,11 +1,11 @@
 <?php
 
-namespace explosivebit\arangodb\console\controllers;
+namespace mirzaev\yii2\arangodb\console\controllers;
 
-use explosivebit\arangodb\Connection;
-use explosivebit\arangodb\Exception;
-use explosivebit\arangodb\Migration;
-use explosivebit\arangodb\Query;
+use mirzaev\yii2\arangodb\Connection;
+use mirzaev\yii2\arangodb\Exception;
+use mirzaev\yii2\arangodb\Migration;
+use mirzaev\yii2\arangodb\Query;
 
 use yii;
 use yii\console\controllers\BaseMigrateController;
@@ -17,15 +17,18 @@ class MigrateController extends BaseMigrateController
      * @var string the name of the collection for keeping applied migration information.
      */
     public $migrationCollection = 'migration';
+
     /**
      * @var string the directory storing the migration classes. This can be either
      * a path alias or a directory.
      */
     public $migrationPath = '@app/migrations/arangodb';
+
     /**
      * @inheritdoc
      */
-    public $templateFile = '@explosivebit/arangodb/views/migration.php';
+    public $templateFile = '@mirzaev/yii2/arangodb/views/migration.php';
+
     /**
      * @var Connection|string the DB connection object or the application
      * component ID of the DB connection.
@@ -55,7 +58,7 @@ class MigrateController extends BaseMigrateController
         if (parent::beforeAction($action)) {
             if ($action->id !== 'create') {
                 if (is_string($this->db)) {
-                    $this->db = \Yii::$app->get($this->db);
+                    $this->db = yii::$app->get($this->db);
                 }
                 if (!$this->db instanceof Connection) {
                     throw new Exception("The 'db' option must refer to the application component ID of a ArangoDB connection.");
@@ -104,7 +107,7 @@ class MigrateController extends BaseMigrateController
     {
         $query = new Query;
         $rows = $query->select(['version' => 'version', 'apply_time' => 'apply_time'])
-            ->from($this->migrationCollection)
+            ->collection($this->migrationCollection)
             ->orderBy('version DESC')
             ->limit($limit)
             ->all($this->db);

mirzaev/yii2/arangodb/panels/arangodb/ArangoDbPanel.php

@@ -1,9 +1,9 @@
 <?php
 
-namespace explosivebit\arangodb\panels\arangodb;
+namespace mirzaev\yii2\arangodb\panels\arangodb;
 
-use explosivebit\arangodb\panels\arangodb\models\ArangoDb;
-use Yii;
+use mirzaev\yii2\arangodb\panels\arangodb\models\ArangoDb;
+use yii;
 use yii\debug\Panel;
 use yii\log\Logger;
 
@@ -31,11 +31,11 @@ class ArangoDbPanel extends Panel
             $target->messages,
             Logger::LEVEL_PROFILE,
             [
-                'explosivebit\arangodb\Query::query',
-                'explosivebit\arangodb\Query::insert',
-                'explosivebit\arangodb\Query::update',
-                'explosivebit\arangodb\Query::remove',
-                'explosivebit\arangodb\Query::execute',
+                'mirzaev\yii2\arangodb\Query::query',
+                'mirzaev\yii2\arangodb\Query::insert',
+                'mirzaev\yii2\arangodb\Query::update',
+                'mirzaev\yii2\arangodb\Query::remove',
+                'mirzaev\yii2\arangodb\Query::execute',
             ]
         );
     }
@@ -48,7 +48,7 @@ class ArangoDbPanel extends Panel
     protected function calculateTimings()
     {
         if ($this->_timings === null) {
-            $this->_timings = Yii::getLogger()->calculateTimings($this->data['arango-messages']);
+            $this->_timings = yii::getLogger()->calculateTimings($this->data['arango-messages']);
         }
 
         return $this->_timings;
@@ -82,8 +82,8 @@ class ArangoDbPanel extends Panel
         $queryCount = count($timings);
         $queryTime = number_format($this->getTotalQueryTime($timings) * 1000) . ' ms';
 
-        return \Yii::$app->view->render(
-            '@explosivebit/arangodb/panels/arangodb/views/summary',
+        return \yii::$app->view->render(
+            '@mirzaev/yii2/arangodb/panels/arangodb/views/summary',
             [
                 'timings' => $this->calculateTimings(),
                 'queryCount' => $queryCount,
@@ -99,9 +99,9 @@ class ArangoDbPanel extends Panel
     public function getDetail()
     {
         $searchModel = new ArangoDb();
-        $dataProvider = $searchModel->search(Yii::$app->request->getQueryParams(), $this->getModels());
+        $dataProvider = $searchModel->search(yii::$app->request->getQueryParams(), $this->getModels());
 
-        return Yii::$app->view->render('@explosivebit/arangodb/panels/arangodb/views/detail', [
+        return yii::$app->view->render('@mirzaev/yii2/arangodb/panels/arangodb/views/detail', [
                 'panel' => $this,
                 'dataProvider' => $dataProvider,
                 'searchModel' => $searchModel,
@@ -136,15 +136,15 @@ class ArangoDbPanel extends Panel
 
     protected function getQueryType($category) {
         switch ($category) {
-            case 'explosivebit\arangodb\Query::query' :
+            case 'mirzaev\yii2\arangodb\Query::query' :
                 return 'SELECT';
-            case 'explosivebit\arangodb\Query::insert' :
+            case 'mirzaev\yii2\arangodb\Query::insert' :
                 return 'INSERT';
-            case 'explosivebit\arangodb\Query::update' :
+            case 'mirzaev\yii2\arangodb\Query::update' :
                 return 'UPDATE';
-            case 'explosivebit\arangodb\Query::remove' :
+            case 'mirzaev\yii2\arangodb\Query::remove' :
                 return 'REMOVE';
-            case 'explosivebit\arangodb\Query::execute' :
+            case 'mirzaev\yii2\arangodb\Query::execute' :
                 return 'EXECUTE';
             default :
                 return '';

mirzaev/yii2/arangodb/panels/arangodb/models/ArangoDb.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace explosivebit\arangodb\panels\arangodb\models;
+namespace mirzaev\yii2\arangodb\panels\arangodb\models;
 
 use yii;
 use yii\data\ArrayDataProvider;

mirzaev/yii2/arangodb/views/migration.php

@@ -0,0 +1,32 @@
+<?php
+/**
+ * This view is used by console/controllers/MigrateController.php
+ * The following variables are available in this view:
+ */
+
+/* @var $className string the new migration class name */
+
+echo <<<HTML
+<?php
+
+use mirzaev\yii2\arangodb\Migration;
+
+class $className extends Migration
+{
+    public function up()
+    {
+        /**
+         * @param string Название коллекции
+         * @param array Тип коллекции (2 - документ, 3 - ребро)
+         */
+        \$this->createCollection('$className', ['type' => 2]);
+    }
+
+    public function down()
+    {
+        \$this->dropCollection('$className');
+    }
+}
+HTML;
+
+?>