Compare commits
No commits in common. "stable" and "0.1.0" have entirely different histories.
|
|
@ -1,3 +1 @@
|
||||||
vendor
|
vendor
|
||||||
composer.lock
|
|
||||||
!.gitignore
|
|
||||||
|
|
|
||||||
11
LICENSE
11
LICENSE
|
|
@ -1,11 +0,0 @@
|
||||||
DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
|
|
||||||
Version 2, December 2004
|
|
||||||
|
|
||||||
Copyright (C) 2004 Sam Hocevar <sam@hocevar.net>
|
|
||||||
|
|
||||||
Everyone is permitted to copy and distribute verbatim or modified copies of this license document, and changing it is allowed as long as the name is changed.
|
|
||||||
|
|
||||||
DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE
|
|
||||||
TERMS AND CONDITIONS FOR COPYING, DISTRIBUTION AND MODIFICATION
|
|
||||||
|
|
||||||
0. You just DO WHAT THE FUCK YOU WANT TO.
|
|
||||||
|
|
@ -1,3 +0,0 @@
|
||||||
# PHP 8.3 Framework for working with ArangoDB
|
|
||||||
|
|
||||||
🤟 Very simple and flexible, easy to scale and integrate
|
|
||||||
|
|
@ -1,47 +1,35 @@
|
||||||
{
|
{
|
||||||
"name": "mirzaev/arangodb",
|
"name": "mirzaev/arangodb",
|
||||||
"description": "Simple PHP-framework for ArangoDB",
|
"description": "Реализация управления хранилищем данных ArangoDB",
|
||||||
"readme": "README.md",
|
"keywords": [
|
||||||
"keywords": [
|
"ArangoDB"
|
||||||
"ArangoDB"
|
],
|
||||||
],
|
"type": "library",
|
||||||
"type": "framework",
|
"license": "WTFPL",
|
||||||
"license": "WTFPL",
|
"homepage": "https://git.hood.su/mirzaev/arangodb",
|
||||||
"homepage": "https://git.hood.su/mirzaev/arangodb",
|
"authors": [
|
||||||
"authors": [
|
{
|
||||||
{
|
"name": "Arsen Mirzaev Tatyano-Muradovich",
|
||||||
"name": "Arsen Mirzaev Tatyano-Muradovich",
|
"email": "arsen@mirzaev.sexy",
|
||||||
"email": "arsen@mirzaev.sexy",
|
"homepage": "https://mirzaev.sexy",
|
||||||
"homepage": "https://mirzaev.sexy",
|
"role": "Developer"
|
||||||
"role": "Developer"
|
}
|
||||||
}
|
],
|
||||||
],
|
"require": {
|
||||||
"support": {
|
"php": "^8.0.0",
|
||||||
"email": "arsen@mirzaev.sexy",
|
"triagens/arangodb": "~3.2"
|
||||||
"wiki": "https://git.mirzaev.sexy/mirzaev/arangodb/manual",
|
},
|
||||||
"issues": "https://git.mirzaev.sexy/mirzaev/arangodb/issues"
|
"require-dev": {
|
||||||
},
|
"phpunit/phpunit": "^9.3.3"
|
||||||
"funding": [
|
},
|
||||||
{
|
"autoload": {
|
||||||
"type": "funding",
|
"psr-4": {
|
||||||
"url": "https://fund.mirzaev.sexy"
|
"mirzaev\\arangodb\\": "mirzaev/arangodb/system"
|
||||||
}
|
}
|
||||||
],
|
},
|
||||||
"require": {
|
"autoload-dev": {
|
||||||
"php": "^8.2",
|
"psr-4": {
|
||||||
"triagens/arangodb": "~3.8"
|
"mirzaev\\arangodb\\tests\\": "mirzaev/arangodb/tests"
|
||||||
},
|
}
|
||||||
"require-dev": {
|
}
|
||||||
"phpunit/phpunit": "^9.3.3"
|
}
|
||||||
},
|
|
||||||
"autoload": {
|
|
||||||
"psr-4": {
|
|
||||||
"mirzaev\\arangodb\\": "mirzaev/arangodb/system"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
"autoload-dev": {
|
|
||||||
"psr-4": {
|
|
||||||
"mirzaev\\arangodb\\tests\\": "mirzaev/arangodb/tests"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
File diff suppressed because it is too large
Load Diff
|
|
@ -1,204 +1,83 @@
|
||||||
<?php
|
<?php
|
||||||
|
|
||||||
declare(strict_types=1);
|
declare(strict_types=1);
|
||||||
|
|
||||||
namespace mirzaev\arangodb;
|
namespace mirzaev\arangodb;
|
||||||
|
|
||||||
// Files of the project
|
use mirzaev\arangodb\terminal;
|
||||||
use mirzaev\arangodb\connection,
|
|
||||||
mirzaev\arangodb\terminal,
|
use ArangoDBClient\Connection as _connection;
|
||||||
mirzaev\arangodb\enumerations\collection\type;
|
use ArangoDBClient\Collection as _collection;
|
||||||
|
use ArangoDBClient\CollectionHandler as _collection_handler;
|
||||||
// Library for ArangoDB
|
|
||||||
use ArangoDBClient\Statement as _statement,
|
/**
|
||||||
ArangoDBClient\Document as _document,
|
* Коллекция
|
||||||
ArangoDBClient\CollectionHandler as _collection_handler,
|
*
|
||||||
ArangoDBClient\Cursor as cursor;
|
* @package mirzaev\arangodb
|
||||||
|
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||||
// Built-in libraries
|
*/
|
||||||
use exception;
|
class collection
|
||||||
|
{
|
||||||
/**
|
/**
|
||||||
* Collection
|
* Инициализация
|
||||||
*
|
*
|
||||||
* @package mirzaev\arangodb
|
* @param _connection $connection Инстанция соединения
|
||||||
*
|
* @param string $name Название
|
||||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
* @param bool $edge Это ребро? (иначе: вершина)
|
||||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
*
|
||||||
*/
|
* @return string|null Идентификатор
|
||||||
class collection
|
*/
|
||||||
{
|
public static function init(_connection $connection, string $name, bool $edge = false): ?string
|
||||||
/**
|
{
|
||||||
* Initialize a collection
|
// Инициализация
|
||||||
*
|
$collections = new _collection_handler($connection);
|
||||||
* @param string $collection Name of the collection
|
|
||||||
* @param type $type Type of the collection
|
if (!$collections->has($name)) {
|
||||||
* @param ?terminal $terminal Инстанция терминала
|
// Коллекция не найдена
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
*
|
// Запись в вывод
|
||||||
* @return string|null Identifier of the collection
|
terminal::write("Коллекция \"$name\" не найдена");
|
||||||
*/
|
|
||||||
public static function initialize(string $name, type $type = type::document, ?terminal $terminal = null, array &$errors = []): ?string
|
// Инициализация
|
||||||
{
|
$collection = new _collection();
|
||||||
try {
|
|
||||||
// Инициализация
|
// Настройка
|
||||||
$collections = new _collection_handler(connection::$session);
|
$collection->setName($name);
|
||||||
|
$collection->setType($edge ? 'edge' : 'document');
|
||||||
if (!$collections->has($name)) {
|
|
||||||
// Не найдана коллекция
|
// Запись коллекции на сервер и его ответ в буфер возврата
|
||||||
|
$id = $collections->create($name);
|
||||||
// Запись в вывод
|
|
||||||
if ($terminal instanceof terminal) $terminal::write("Not found $type collection: $name");
|
if ($collections->has($name)) {
|
||||||
|
// Коллекция найдена (записана)
|
||||||
// Запись коллекции на сервер и его ответ в буфер возврата
|
|
||||||
$id = $collections->create($name, ['type' => $type->code()]);
|
// Запись в вывод
|
||||||
|
terminal::write("Создана коллекция \"$name\"");
|
||||||
if ($collections->has($name)) {
|
|
||||||
// Коллекция найдена (записана)
|
// Возврат идентификатора коллекции
|
||||||
|
return $id;
|
||||||
// Запись в вывод
|
}
|
||||||
if ($terminal instanceof terminal) $terminal::write("Created $type collection: $name");
|
}
|
||||||
|
}
|
||||||
// Возврат идентификатора коллекции
|
|
||||||
return $id;
|
/**
|
||||||
}
|
* Поиск
|
||||||
} else {
|
*
|
||||||
// Найдена коллекция
|
* @param _connection $connection Соединение
|
||||||
|
* @param string $collection Название
|
||||||
// Возврат идентификатора коллекции
|
* @param array $condition Условия
|
||||||
return $name;
|
*
|
||||||
}
|
* @return array|null Коллекция, если найдена
|
||||||
} catch (exception $e) {
|
*/
|
||||||
// Writing to registry of errors
|
public static function search(_connection $connection, string $name, array $condition): ?array
|
||||||
$errors[] = [
|
{
|
||||||
'text' => $e->getMessage(),
|
// Инициализация
|
||||||
'file' => $e->getFile(),
|
$collections = new _collection_handler($connection);
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
if ($collections->has($name)) {
|
||||||
];
|
// Коллекция найдена
|
||||||
}
|
|
||||||
|
return $collections->byExample($name, $condition)->getAll();
|
||||||
return null;
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
/**
|
|
||||||
* Execute
|
|
||||||
*
|
|
||||||
* @param string $query Query (AQL)
|
|
||||||
* @param array $parameters Binded parameters for placeholders [placholder => parameter]
|
|
||||||
* @param bool $flat Not implement record?
|
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
*
|
|
||||||
* @return _document|array|string|int|null Instance of the document
|
|
||||||
*/
|
|
||||||
public static function execute(string $query, array $parameters = [], bool $flat = false, array &$errors = []): _document|string|array|int|null
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
// Statement instance initialization
|
|
||||||
$instance = new _statement(
|
|
||||||
connection::$session,
|
|
||||||
[
|
|
||||||
'query' => $query,
|
|
||||||
'batchSize' => 1000,
|
|
||||||
'sanitize' => true,
|
|
||||||
cursor::ENTRY_FLAT => $flat
|
|
||||||
]
|
|
||||||
);
|
|
||||||
|
|
||||||
// Binds application
|
|
||||||
$instance->bind($parameters);
|
|
||||||
|
|
||||||
// Sending the request
|
|
||||||
$response = $instance->execute();
|
|
||||||
|
|
||||||
// Инициализация буфера вывода
|
|
||||||
$buffer = [];
|
|
||||||
|
|
||||||
foreach ($response->getAll() as $key => $value) {
|
|
||||||
$buffer[$key] = $value;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (success)
|
|
||||||
return is_array($buffer) && count($buffer) > 1 ? $buffer : $buffer[0] ?? null;
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Truncate
|
|
||||||
*
|
|
||||||
* @param string $name Name of the collection
|
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
*
|
|
||||||
* @return bool Статус выполнения
|
|
||||||
*/
|
|
||||||
public static function truncate(string $collection, array &$errors = []): bool
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
// Initizlizing of the collection handler
|
|
||||||
$collections = new _collection_handler(connection::$session);
|
|
||||||
|
|
||||||
if ($collections->has($collection)) {
|
|
||||||
// Fount the collection
|
|
||||||
|
|
||||||
// Truncate and exit (success)
|
|
||||||
return $collections->truncate($collection);
|
|
||||||
}
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Count documents in ArangoDB
|
|
||||||
*
|
|
||||||
* @param string $collection Name of the collection
|
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
*
|
|
||||||
* @return int|null Amount of documents in ArangoDB
|
|
||||||
*/
|
|
||||||
public static function count(string $collection, array &$errors = []): ?int
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
// Count and exit (success)
|
|
||||||
return static::execute(
|
|
||||||
<<<'AQL'
|
|
||||||
RETURN LENGTH(@@collection)
|
|
||||||
AQL,
|
|
||||||
[
|
|
||||||
'@collection' => $collection
|
|
||||||
]
|
|
||||||
);
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -4,205 +4,198 @@ declare(strict_types=1);
|
||||||
|
|
||||||
namespace mirzaev\arangodb;
|
namespace mirzaev\arangodb;
|
||||||
|
|
||||||
// Library for ArangoDB
|
use ArangoDBClient\Connection as _connection;
|
||||||
use ArangoDBClient\Connection as _connection,
|
use ArangoDBClient\Exception as _exception;
|
||||||
ArangoDBClient\Exception as _exception,
|
use ArangoDBClient\UpdatePolicy as _update;
|
||||||
ArangoDBClient\UpdatePolicy as _update,
|
use ArangoDBClient\ConnectionOptions as _options;
|
||||||
ArangoDBClient\ConnectionOptions as _options;
|
|
||||||
|
|
||||||
// Built-in libraries
|
|
||||||
use exception;
|
use exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Connection
|
* Подключение
|
||||||
*
|
*
|
||||||
* @package mirzaev\arangodb
|
* @package mirzaev\arangodb
|
||||||
*
|
|
||||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
|
||||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||||
*/
|
*/
|
||||||
final class connection
|
final class connection
|
||||||
{
|
{
|
||||||
/**
|
/**
|
||||||
* Адрес
|
* Адрес
|
||||||
*/
|
*/
|
||||||
protected string $adress = 'tcp://127.0.0.1:8529';
|
protected string $adress = 'tcp://127.0.0.1:8529';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Хранилище (название)
|
* Хранилище (название)
|
||||||
*/
|
*/
|
||||||
protected string $storage = 'root';
|
protected string $storage = 'root';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Тип аутентификации
|
* Тип аутентификации
|
||||||
*/
|
*/
|
||||||
protected string $auth = 'Basic';
|
protected string $auth = 'Basic';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Псевдоним пользователя
|
* Псевдоним пользователя
|
||||||
*/
|
*/
|
||||||
protected string $name = 'root';
|
protected string $name = 'root';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Пароль пользователя
|
* Пароль пользователя
|
||||||
*/
|
*/
|
||||||
protected string $password = '';
|
protected string $password = '';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Тип соединения
|
* Тип соединения
|
||||||
*/
|
*/
|
||||||
protected string $connection = 'Keep-Alive';
|
protected string $connection = 'Keep-Alive';
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Время ожидания соединения
|
* Время ожидания соединения
|
||||||
*/
|
*/
|
||||||
protected int $timeout_connect = 3;
|
protected int $timeout_connect = 3;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Время ожидания запроса
|
* Время ожидания запроса
|
||||||
*/
|
*/
|
||||||
protected int $timeout_request = 3;
|
protected int $timeout_request = 3;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Переподключиться ли при разрыве соединения
|
* Переподключиться ли при разрыве соединения
|
||||||
*/
|
*/
|
||||||
protected bool $reconnect = true;
|
protected bool $reconnect = true;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Создавать ли коллекцию, если она не существует
|
* Создавать ли коллекцию, если она не существует
|
||||||
*/
|
*/
|
||||||
protected bool $create = true;
|
protected bool $create = true;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Действия при обновлении коллекции
|
* Действия при обновлении коллекции
|
||||||
*/
|
*/
|
||||||
protected string $update = _update::LAST;
|
protected string $update = _update::LAST;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Активация журналирования
|
* Активация журналирования
|
||||||
*/
|
*/
|
||||||
protected bool $journal = false;
|
protected bool $journal = false;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Сессия соединения
|
* Сессия соединения
|
||||||
*/
|
*/
|
||||||
public static _connection $session;
|
protected _connection $session;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Конструктор
|
* Конструктор
|
||||||
*
|
*
|
||||||
* @param array $settings Настройки
|
* @param array $settings Настройки
|
||||||
*
|
*/
|
||||||
* @todo ПЕРЕДЕЛАТЬ ПОЛНОСТЬЮ
|
public function __construct(array $settings = null)
|
||||||
*/
|
{
|
||||||
public function __construct(array $settings = null)
|
// Запись
|
||||||
{
|
@$this->__set('adress', $settings['adress'] ?? $settings['endpoint']);
|
||||||
// Запись
|
@$this->__set('storage', $settings['storage'] ?? $settings['database']);
|
||||||
@$this->__set('adress', $settings['adress'] ?? $settings['endpoint']);
|
@$this->__set('auth', $settings['auth']);
|
||||||
@$this->__set('storage', $settings['storage'] ?? $settings['database']);
|
@$this->__set('name', $settings['name']);
|
||||||
@$this->__set('auth', $settings['auth']);
|
@$this->__set('password', $settings['password']);
|
||||||
@$this->__set('name', $settings['name']);
|
@$this->__set('connection', $settings['connection']);
|
||||||
@$this->__set('password', $settings['password']);
|
@$this->__set('timeout_connect', $settings['timeout_connect']);
|
||||||
@$this->__set('connection', $settings['connection']);
|
@$this->__set('timeout_request', $settings['timeout_request']);
|
||||||
@$this->__set('timeout_connect', $settings['timeout_connect']);
|
@$this->__set('reconnect', $settings['reconnect']);
|
||||||
@$this->__set('timeout_request', $settings['timeout_request']);
|
@$this->__set('create', $settings['create']);
|
||||||
@$this->__set('reconnect', $settings['reconnect']);
|
@$this->__set('update', $settings['update'] ?? $settings['policy']);
|
||||||
@$this->__set('create', $settings['create']);
|
@$this->__set('journal', $settings['journal']);
|
||||||
@$this->__set('update', $settings['update'] ?? $settings['policy']);
|
|
||||||
@$this->__set('journal', $settings['journal']);
|
|
||||||
|
|
||||||
if ($this->journal) {
|
if ($this->journal) {
|
||||||
// Запрос на активацию журналирования
|
// Запрос на активацию журналирования
|
||||||
|
|
||||||
_exception::enableLogging();
|
_exception::enableLogging();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Подключение
|
// Подключение
|
||||||
static::$session = new _connection([
|
$this->session = new _connection([
|
||||||
_options::OPTION_ENDPOINT => $this->adress,
|
_options::OPTION_ENDPOINT => $this->adress,
|
||||||
_options::OPTION_DATABASE => $this->storage,
|
_options::OPTION_DATABASE => $this->storage,
|
||||||
_options::OPTION_AUTH_TYPE => $this->auth,
|
_options::OPTION_AUTH_TYPE => $this->auth,
|
||||||
_options::OPTION_AUTH_USER => $this->name,
|
_options::OPTION_AUTH_USER => $this->name,
|
||||||
_options::OPTION_AUTH_PASSWD => $this->password,
|
_options::OPTION_AUTH_PASSWD => $this->password,
|
||||||
_options::OPTION_CONNECTION => $this->connection,
|
_options::OPTION_CONNECTION => $this->connection,
|
||||||
_options::OPTION_CONNECT_TIMEOUT => $this->timeout_connect,
|
_options::OPTION_CONNECT_TIMEOUT => $this->timeout_connect,
|
||||||
_options::OPTION_REQUEST_TIMEOUT => $this->timeout_request,
|
_options::OPTION_REQUEST_TIMEOUT => $this->timeout_request,
|
||||||
_options::OPTION_RECONNECT => $this->reconnect,
|
_options::OPTION_RECONNECT => $this->reconnect,
|
||||||
_options::OPTION_CREATE => $this->create,
|
_options::OPTION_CREATE => $this->create,
|
||||||
_options::OPTION_UPDATE_POLICY => $this->update,
|
_options::OPTION_UPDATE_POLICY => $this->update,
|
||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Записать свойство
|
* Записать свойство
|
||||||
*
|
*
|
||||||
* @param mixed $name Название
|
* @param mixed $name Название
|
||||||
* @param mixed $value Значение
|
* @param mixed $value Значение
|
||||||
*/
|
*/
|
||||||
public function __set(string $name, mixed $value): void
|
public function __set(string $name, mixed $value): void
|
||||||
{
|
{
|
||||||
match ($name) {
|
match ($name) {
|
||||||
'adress', 'endpoint' => $this->adress = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
|
'adress', 'endpoint' => $this->adress = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
|
||||||
'storage', 'database', 'db' => $this->storage = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
|
'storage', 'database', 'db' => $this->storage = $value ?? throw new exception("Свойство \"$name\" не может быть пустым", 500),
|
||||||
'auth' => !$value ?: $this->auth = $value,
|
'auth' => $this->auth = $value,
|
||||||
'name' => !$value ?: $this->name = $value,
|
'name' => $this->name = $value,
|
||||||
'password' => !$value ?: $this->password = $value,
|
'password' => $this->password = $value,
|
||||||
'connection' => !$value ?: $this->connection = $value,
|
'connection' => $this->connection = $value,
|
||||||
'timeout_connect' => !$value ?: $this->timeout_connect = $value,
|
'timeout_connect' => $this->timeout_connect = $value,
|
||||||
'timeout_request' => !$value ?: $this->timeout_request = $value,
|
'timeout_request' => $this->timeout_request = $value,
|
||||||
'reconnect' => !$value ?: $this->reconnect = $value,
|
'reconnect' => $this->reconnect = $value,
|
||||||
'create' => !$value ?: $this->create = $value,
|
'create' => $this->create = $value,
|
||||||
'update', 'policy' => !$value ?: $this->update = $value,
|
'update', 'policy' => $this->update = $value,
|
||||||
'journal' => !$value ?: $this->journal = $value,
|
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
||||||
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
};
|
||||||
};
|
}
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Прочитать свойство
|
* Прочитать свойство
|
||||||
*
|
*
|
||||||
* @param mixed $name Название
|
* @param mixed $name Название
|
||||||
*/
|
*/
|
||||||
public function __get(string $name): mixed
|
public function __get(string $name): mixed
|
||||||
{
|
{
|
||||||
return match ($name) {
|
return match ($name) {
|
||||||
'adress', 'endpoint' => $this->adress,
|
'adress', 'endpoint' => $this->adress,
|
||||||
'storage', 'database', 'db' => $this->storage,
|
'storage', 'database', 'db' => $this->storage,
|
||||||
'auth' => $this->auth,
|
'auth' => $this->auth,
|
||||||
'name' => $this->name,
|
'name' => $this->name,
|
||||||
'password' => $this->password,
|
'password' => $this->password,
|
||||||
'connection' => $this->connection,
|
'connection' => $this->connection,
|
||||||
'timeout_connect' => $this->timeout_connect,
|
'timeout_connect' => $this->timeout_connect,
|
||||||
'timeout_request' => $this->timeout_request,
|
'timeout_request' => $this->timeout_request,
|
||||||
'reconnect' => $this->reconnect,
|
'reconnect' => $this->reconnect,
|
||||||
'create' => $this->create,
|
'create' => $this->create,
|
||||||
'update', 'policy' => $this->update,
|
'update', 'policy' => $this->update,
|
||||||
'journal' => $this->journal,
|
'session' => $this->session,
|
||||||
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Проверить свойство на инициализированность
|
* Проверить свойство на инициализированность
|
||||||
*
|
*
|
||||||
* @param mixed $name Название
|
* @param mixed $name Название
|
||||||
*/
|
*/
|
||||||
public function __isset(string $name): bool
|
public function __isset(string $name): bool
|
||||||
{
|
{
|
||||||
return match ($name) {
|
return match ($name) {
|
||||||
'adress', 'endpoint' => isset($this->adress),
|
'adress', 'endpoint' => isset($this->adress),
|
||||||
'storage', 'database', 'db' => isset($this->storage),
|
'storage', 'database', 'db' => isset($this->storage),
|
||||||
'auth' => isset($this->auth),
|
'auth' => isset($this->auth),
|
||||||
'name' => isset($this->name),
|
'name' => isset($this->name),
|
||||||
'password' => isset($this->password),
|
'password' => isset($this->password),
|
||||||
'connection' => isset($this->connection),
|
'connection' => isset($this->connection),
|
||||||
'timeout_connect' => isset($this->timeout_connect),
|
'timeout_connect' => isset($this->timeout_connect),
|
||||||
'timeout_request' => isset($this->timeout_request),
|
'timeout_request' => isset($this->timeout_request),
|
||||||
'reconnect' => isset($this->reconnect),
|
'reconnect' => isset($this->reconnect),
|
||||||
'create' => isset($this->create),
|
'create' => isset($this->create),
|
||||||
'update', 'policy' => isset($this->update),
|
'update', 'policy' => isset($this->update),
|
||||||
'journal' => isset($this->journal),
|
'session' => isset($this->session),
|
||||||
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -1,189 +1,82 @@
|
||||||
<?php
|
<?php
|
||||||
|
|
||||||
declare(strict_types=1);
|
declare(strict_types=1);
|
||||||
|
|
||||||
namespace mirzaev\arangodb;
|
namespace mirzaev\arangodb;
|
||||||
|
|
||||||
// Files of the project
|
use mirzaev\arangodb\terminal;
|
||||||
use mirzaev\arangodb\terminal,
|
|
||||||
mirzaev\arangodb\connection,
|
use ArangoDBClient\Connection as _connection;
|
||||||
mirzaev\arangodb\enumerations\collection\type;
|
use ArangoDBClient\Document as _document;
|
||||||
|
use ArangoDBClient\Edge as _edge;
|
||||||
// Librsry for ArangoDB
|
use ArangoDBClient\CollectionHandler as _collection_handler;
|
||||||
use ArangoDBClient\Connection as _connection,
|
use ArangoDBClient\EdgeHandler as _edge_handler;
|
||||||
ArangoDBClient\Document as _document,
|
|
||||||
ArangoDBClient\Edge as _edge,
|
/**
|
||||||
ArangoDBClient\DocumentHandler as _document_handler,
|
* Документ
|
||||||
ArangoDBClient\EdgeHandler as _edge_handler;
|
*
|
||||||
|
* @package mirzaev\arangodb
|
||||||
// Built-in libraries
|
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||||
use exception;
|
*/
|
||||||
|
class document
|
||||||
/**
|
{
|
||||||
* Document
|
/**
|
||||||
*
|
* Записать
|
||||||
* Handlers of document in ArangoDB
|
*
|
||||||
*
|
* @param _connection $connection Инстанция соединения
|
||||||
* @package mirzaev\arangodb
|
* @param string $collection Коллекция
|
||||||
*
|
* @param array $data Данные
|
||||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
*
|
||||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
* @return string|null Идентификатор
|
||||||
*/
|
*/
|
||||||
class document
|
public static function write(_connection $connection, string $collection, array $data): ?string
|
||||||
{
|
{
|
||||||
/**
|
// Инициализация коллекции
|
||||||
* Write
|
collection::init($connection, $collection, isset($data['_from'], $data['_to']));
|
||||||
*
|
|
||||||
* @param string $collection Коллекция
|
if (isset($data['_from'], $data['_to'])) {
|
||||||
* @param ?array $data Данные
|
// Ребро
|
||||||
* @param bool $check Проверка на запись в базу данных
|
|
||||||
* @param ?terminal $terminal Instance of the terminal
|
// Инициализация обработчика рёбер
|
||||||
* @param array &$errors Registry of errors
|
$documents = new _edge_handler($connection);
|
||||||
*
|
|
||||||
* @return string|null Идентификатор
|
// Инициализация ребра
|
||||||
*
|
$document = new _edge();
|
||||||
* @todo
|
|
||||||
* 1. Bind parameters
|
// Инициализация вершин
|
||||||
*/
|
$_from = $data['_from'];
|
||||||
public static function write(
|
$_to = $data['_to'];
|
||||||
string $collection,
|
|
||||||
?array $data = [],
|
// Деинициализация из входных данных
|
||||||
bool $check = false,
|
unset($data['_from'], $data['_to']);
|
||||||
?terminal $terminal = null,
|
} else {
|
||||||
array &$errors = []
|
// Вершина
|
||||||
): string|null|false {
|
|
||||||
try {
|
// Инициализация обработчика вершин
|
||||||
// Инициализация коллекции
|
$documents = new _collection_handler($connection);
|
||||||
collection::initialize($collection, isset($data['_from'], $data['_to']) ? type::edge : type::document);
|
|
||||||
|
// Инициализация вершины
|
||||||
if (isset($data['_from'], $data['_to'])) {
|
$document = new _document();
|
||||||
// Ребро
|
}
|
||||||
|
|
||||||
// Инициализация обработчика рёбер
|
// Настройка
|
||||||
$documents = new _edge_handler(connection::$session);
|
foreach ($data as $key => $value) {
|
||||||
|
// Перебор параметров
|
||||||
// Инициализация ребра
|
|
||||||
$document = new _edge();
|
$document->set($key, $value);
|
||||||
|
}
|
||||||
// Инициализация вершин
|
|
||||||
$_from = $data['_from'];
|
// Запись на сервер и его ответ в буфер возврата
|
||||||
$_to = $data['_to'];
|
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->save($collection, $document);
|
||||||
|
|
||||||
// Деинициализация из входных данных
|
if ($documents->has($collection, $id)) {
|
||||||
unset($data['_from'], $data['_to']);
|
// Документ записан
|
||||||
} else {
|
|
||||||
// Вершина
|
// Запись в вывод
|
||||||
|
terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
||||||
// Инициализация обработчика вершин
|
|
||||||
$documents = new _document_handler(connection::$session);
|
// Возврат идентификатора коллекции
|
||||||
|
return $id;
|
||||||
// Инициализация вершины
|
}
|
||||||
$document = new _document();
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Инициализация даты создания
|
|
||||||
$created = time();
|
|
||||||
|
|
||||||
foreach (['created' => $created, 'updated' => $created] + $data as $key => $value) {
|
|
||||||
// Перебор параметров
|
|
||||||
|
|
||||||
// Запись в инстанцию документа
|
|
||||||
$document->set($key, $value);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Запись на сервер и его ответ в буфер возврата
|
|
||||||
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
|
|
||||||
|
|
||||||
if ($check && $documents->has($collection, $id)) {
|
|
||||||
// Найден записанный документ
|
|
||||||
|
|
||||||
// Запись в вывод
|
|
||||||
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
|
||||||
} else if ($check) {
|
|
||||||
// Не найден записанный документ
|
|
||||||
|
|
||||||
// Запись в вывод
|
|
||||||
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" не удалось найти созданный или создать документ");
|
|
||||||
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Возврат идентификатора коллекции
|
|
||||||
return $id;
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Update
|
|
||||||
*
|
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
* @param _document $document Instance of the document
|
|
||||||
*
|
|
||||||
* @return bool Has the document been updated?
|
|
||||||
*/
|
|
||||||
public static function update(_document $document, array &$errors = []): bool
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
// Initialize the handler of documents
|
|
||||||
$documents = new _document_handler(connection::$session);
|
|
||||||
|
|
||||||
// Writing date of the updating to the updating document
|
|
||||||
$document->set('updated', time());
|
|
||||||
|
|
||||||
// Writing and exit (success)
|
|
||||||
return $documents->update($document);
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Delete
|
|
||||||
*
|
|
||||||
* @param _document $document Instance of the document
|
|
||||||
* @param array &$errors Registry of errors
|
|
||||||
*
|
|
||||||
* @return bool Has the document been deleted?
|
|
||||||
*/
|
|
||||||
public static function delete(_document $document, array &$errors = []): bool
|
|
||||||
{
|
|
||||||
try {
|
|
||||||
// Initialize the handler of documents
|
|
||||||
$documents = new _document_handler(connection::$session);
|
|
||||||
|
|
||||||
// Delete abd exit (success)
|
|
||||||
return $documents->remove($document);
|
|
||||||
} catch (exception $e) {
|
|
||||||
// Writing to registry of errors
|
|
||||||
$errors[] = [
|
|
||||||
'text' => $e->getMessage(),
|
|
||||||
'file' => $e->getFile(),
|
|
||||||
'line' => $e->getLine(),
|
|
||||||
'stack' => $e->getTrace()
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
// Exit (fail)
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
|
|
@ -1,36 +0,0 @@
|
||||||
<?php
|
|
||||||
|
|
||||||
declare(strict_types=1);
|
|
||||||
|
|
||||||
namespace mirzaev\arangodb\enumerations\collection;
|
|
||||||
|
|
||||||
// Library for ArangoDB
|
|
||||||
use ArangoDBClient\Collection as _collection;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Types of collections
|
|
||||||
*
|
|
||||||
* @package mirzaev\arangodb\enumerations\collection
|
|
||||||
*
|
|
||||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
|
||||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
|
||||||
*/
|
|
||||||
enum type
|
|
||||||
{
|
|
||||||
case document;
|
|
||||||
case edge;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Read code of the type from library for ArangoDB
|
|
||||||
*
|
|
||||||
* @return int Code of the type
|
|
||||||
*/
|
|
||||||
public function code(): int
|
|
||||||
{
|
|
||||||
// Exit (success)
|
|
||||||
return match ($this) {
|
|
||||||
type::document => _collection::TYPE_DOCUMENT,
|
|
||||||
type::edge => _collection::TYPE_EDGE
|
|
||||||
};
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -1,37 +1,31 @@
|
||||||
<?php
|
<?php
|
||||||
|
|
||||||
declare(strict_types=1);
|
declare(strict_types=1);
|
||||||
|
|
||||||
namespace mirzaev\arangodb;
|
namespace mirzaev\arangodb;
|
||||||
|
|
||||||
// Built-in libraries
|
class terminal
|
||||||
use exception;
|
{
|
||||||
|
/**
|
||||||
/**
|
* Префикс
|
||||||
* Terminal
|
*/
|
||||||
*
|
protected const PREFIX = 'arangodb';
|
||||||
* lol sorry
|
|
||||||
* i did not want to do this
|
/**
|
||||||
*
|
* Запись в вывод
|
||||||
* @package mirzaev\arangodb
|
*
|
||||||
*
|
* @param string $text Текст сообщения
|
||||||
* @license http://www.wtfpl.net/ Do What The Fuck You Want To Public License
|
*/
|
||||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
public static function write(string $text): void
|
||||||
*/
|
{
|
||||||
class terminal
|
echo self::generate_prefix() . ' ' . $text . PHP_EOL;
|
||||||
{
|
}
|
||||||
/**
|
|
||||||
* Префикс
|
/**
|
||||||
*/
|
* Генерация префикса
|
||||||
protected const string PREFIX = 'arangodb';
|
*/
|
||||||
|
public static function generate_prefix(): string
|
||||||
/**
|
{
|
||||||
* Запись в вывод
|
return '[' . self::PREFIX . ']';
|
||||||
*
|
}
|
||||||
* @param string $text Текст сообщения
|
}
|
||||||
*/
|
|
||||||
public static function write(string $text): void
|
|
||||||
{
|
|
||||||
echo sprintf("[%s] $text\n", self::PREFIX);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue