HARMONY/arangodb
1
0
Fork 0
forked from mirzaev/arangodb
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Исправление инициализации и переход на PHP8.1

Browse Source
This commit is contained in:
Arsen Mirzaev Tatyano-Muradovich
2022-10-09 04:12:30 +10:00
parent e0955a2034
commit f6c1d756d2
5 changed files with 228 additions and 250 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
mirzaev/arangodb/system/collection.php
View File

@@ -8,6 +8,8 @@ use mirzaev\arangodb\terminal;
use ArangoDBClient\Connection as _connection;
use ArangoDBClient\Collection as _collection;
use ArangoDBClient\Statement as _statement;
use ArangoDBClient\Document as _document;
use ArangoDBClient\CollectionHandler as _collection_handler;
/**
@@ -21,63 +23,95 @@ class collection
/**
* Инициализация
*
* @param _connection $connection Инстанция соединения
* @param _connection $session Сессия соединения с базой данных
* @param string $name Название
* @param bool $edge Это ребро? (иначе: вершина)
*
* @return string|null Идентификатор
* @return string|null Идентификатор коллекции
*/
public static function init(_connection $connection, string $name, bool $edge = false): ?string
public static function init(_connection $session, string $name, bool $edge = false): ?string
{
// Инициализация
$collections = new _collection_handler($connection);
$collections = new _collection_handler($session);
if (!$collections->has($name)) {
// Коллекция не найдена
// Не найдана коллекция
// Запись в вывод
terminal::write("Коллекция \"$name\" не найдена");
// Инициализация
$collection = new _collection();
// Настройка
$collection->setName($name);
$collection->setType($edge ? 'edge' : 'document');
// Запись коллекции на сервер и его ответ в буфер возврата
$id = $collections->create($name);
$id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
if ($collections->has($name)) {
// Коллекция найдена (записана)
// Запись в вывод
terminal::write("Создана коллекция \"$name\"");
terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
// Возврат идентификатора коллекции
return $id;
}
} else {
// Найдена коллекция
// Возврат идентификатора коллекции
return $name;
}
return null;
}
/**
* Поиск
*
* @param _connection $connection Соединение
* @param string $collection Название
* @param array $condition Условия
* @param _connection $session Сессия соединения с базой данных
* @param string $query AQL-запрос
*
* @return array|null Коллекция, если найдена
* @return _document|null Инстанция документа
*/
public static function search(_connection $connection, string $name, array $condition): ?array
public static function search(_connection $session, string $query): ?_document
{
// Поиск журнала
$journal = (new _statement(
$session,
[
'query' => $query,
"batchSize" => 1000,
"sanitize" => true
]
))->execute();
// Инициализация буфера вывода
$buffer = [];
foreach ($journal as $key => $value) {
$buffer[$key] = $value;
}
return $buffer[0] ?? null;
}
/**
* Очистка
*
* @param _connection $session Сессия соединения с базой данных
* @param string $name Название
*
* @return bool Статус выполнения
*/
public static function truncate(_connection $session, string $name): bool
{
// Инициализация
$collections = new _collection_handler($connection);
$collections = new _collection_handler($session);
if ($collections->has($name)) {
// Коллекция найдена
// Найдена коллекция
return $collections->byExample($name, $condition)->getAll();
// Очистка
return $collections->truncate($name);
}
return false;
}
}

21
mirzaev/arangodb/system/connection.php
View File

@@ -138,15 +138,16 @@ final class connection
match ($name) {
'adress', 'endpoint' => $this->adress = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
'storage', 'database', 'db' => $this->storage = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
'auth' => $this->auth = $value,
'name' => $this->name = $value,
'password' => $this->password = $value,
'connection' => $this->connection = $value,
'timeout_connect' => $this->timeout_connect = $value,
'timeout_request' => $this->timeout_request = $value,
'reconnect' => $this->reconnect = $value,
'create' => $this->create = $value,
'update', 'policy' => $this->update = $value,
'auth' => !$value ?: $this->auth = $value,
'name' => !$value ?: $this->name = $value,
'password' => !$value ?: $this->password = $value,
'connection' => !$value ?: $this->connection = $value,
'timeout_connect' => !$value ?: $this->timeout_connect = $value,
'timeout_request' => !$value ?: $this->timeout_request = $value,
'reconnect' => !$value ?: $this->reconnect = $value,
'create' => !$value ?: $this->create = $value,
'update', 'policy' => !$value ?: $this->update = $value,
'journal' => !$value ?: $this->journal = $value,
default => throw new exception("Свойство \"$name\" не найдено", 404)
};
}
@@ -171,6 +172,7 @@ final class connection
'create' => $this->create,
'update', 'policy' => $this->update,
'session' => $this->session,
'journal' => $this->journal,
default => throw new exception("Свойство \"$name\" не найдено", 404)
};
}
@@ -195,6 +197,7 @@ final class connection
'create' => isset($this->create),
'update', 'policy' => isset($this->update),
'session' => isset($this->session),
'journal' => isset($this->journal),
default => throw new exception("Свойство \"$name\" не найдено", 404)
};
}

54
mirzaev/arangodb/system/document.php
View File

@@ -9,7 +9,7 @@ use mirzaev\arangodb\terminal;
use ArangoDBClient\Connection as _connection;
use ArangoDBClient\Document as _document;
use ArangoDBClient\Edge as _edge;
use ArangoDBClient\CollectionHandler as _collection_handler;
use ArangoDBClient\DocumentHandler as _document_handler;
use ArangoDBClient\EdgeHandler as _edge_handler;
/**
@@ -23,60 +23,78 @@ class document
/**
* Записать
*
* @param _connection $connection Инстанция соединения
* @param _connection $session Сессия соединения с базой данных
* @param string $collection Коллекция
* @param array $data Данные
* @param ?array $data Данные
* @param ?array $metadata Метаданные
* @param bool $check Проверка на запись в базу данных
*
* @return string|null Идентификатор
*/
public static function write(_connection $connection, string $collection, array $data): ?string
public static function write(_connection $session, string $collection, ?array $data = null, ?array $metadata = null, bool $check = true): ?string
{
// Инициализация коллекции
collection::init($connection, $collection, isset($data['_from'], $data['_to']));
collection::init($session, $collection, isset($data['_from'], $data['_to']));
if (isset($data['_from'], $data['_to'])) {
if (isset($metadata['_from'], $metadata['_to'])) {
// Ребро
// Инициализация обработчика рёбер
$documents = new _edge_handler($connection);
$documents = new _edge_handler($session);
// Инициализация ребра
$document = new _edge();
// Инициализация вершин
$_from = $data['_from'];
$_to = $data['_to'];
$_from = $metadata['_from'];
$_to = $metadata['_to'];
// Деинициализация из входных данных
unset($data['_from'], $data['_to']);
unset($metadata['_from'], $metadata['_to']);
} else {
// Вершина
// Инициализация обработчика вершин
$documents = new _collection_handler($connection);
$documents = new _document_handler($session);
// Инициализация вершины
$document = new _document();
}
// Настройка
foreach ($data as $key => $value) {
foreach (['data' => $data, 'metadata' => ($metadata ?? []) + ['created' => time()]] as $key => $value) {
// Перебор параметров
// Запись в инстанцию документа
$document->set($key, $value);
}
// Запись на сервер и его ответ в буфер возврата
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->save($collection, $document);
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
if ($documents->has($collection, $id)) {
if ($check && $documents->has($collection, $id)) {
// Документ записан
// Запись в вывод
terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
// Возврат идентификатора коллекции
return $id;
}
// Возврат идентификатора коллекции
return $id;
}
/**
* Обновить
*
* @param _connection $session Сессия соединения с базой данных
* @param _document $document Инстанция документа вершины
*
* @return bool Статус обработки
*/
public static function update(_connection $session, _document $document): bool {
// Инициализация обработчика вершин
$documents = new _document_handler($session);
// Запись в базу данных
return $documents->update($document);
}
}