Перенос в репозиторий и небольшая переработка
This commit is contained in:
Arsen Mirzaev Tatyano-Muradovich
commit
13b2b4c00e
|
|
@ -0,0 +1 @@
|
|||
vendor
|
||||
|
|
@ -0,0 +1,35 @@
|
|||
{
|
||||
"name": "mirzaev/arangodb",
|
||||
"description": "Реализация управления хранилищем данных ArangoDB",
|
||||
"keywords": [
|
||||
"ArangoDB"
|
||||
],
|
||||
"type": "library",
|
||||
"license": "WTFPL",
|
||||
"homepage": "https://git.hood.su/mirzaev/arangodb",
|
||||
"authors": [
|
||||
{
|
||||
"name": "Arsen Mirzaev Tatyano-Muradovich",
|
||||
"email": "arsen@mirzaev.sexy",
|
||||
"homepage": "https://mirzaev.sexy",
|
||||
"role": "Developer"
|
||||
}
|
||||
],
|
||||
"require": {
|
||||
"php": "^8.0.0",
|
||||
"triagens/arangodb": "~3.2"
|
||||
},
|
||||
"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
|
|
@ -0,0 +1,83 @@
|
|||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace mirzaev\arangodb;
|
||||
|
||||
use mirzaev\arangodb\terminal;
|
||||
|
||||
use ArangoDBClient\Connection as _connection;
|
||||
use ArangoDBClient\Collection as _collection;
|
||||
use ArangoDBClient\CollectionHandler as _collection_handler;
|
||||
|
||||
/**
|
||||
* Коллекция
|
||||
*
|
||||
* @package mirzaev\arangodb
|
||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||
*/
|
||||
class collection
|
||||
{
|
||||
/**
|
||||
* Инициализация
|
||||
*
|
||||
* @param _connection $connection Инстанция соединения
|
||||
* @param string $name Название
|
||||
* @param bool $edge Это ребро? (иначе: вершина)
|
||||
*
|
||||
* @return string|null Идентификатор
|
||||
*/
|
||||
public static function init(_connection $connection, string $name, bool $edge = false): ?string
|
||||
{
|
||||
// Инициализация
|
||||
$collections = new _collection_handler($connection);
|
||||
|
||||
if (!$collections->has($name)) {
|
||||
// Коллекция не найдена
|
||||
|
||||
// Запись в вывод
|
||||
terminal::write("Коллекция \"$name\" не найдена");
|
||||
|
||||
// Инициализация
|
||||
$collection = new _collection();
|
||||
|
||||
// Настройка
|
||||
$collection->setName($name);
|
||||
$collection->setType($edge ? 'edge' : 'document');
|
||||
|
||||
// Запись коллекции на сервер и его ответ в буфер возврата
|
||||
$id = $collections->create($name);
|
||||
|
||||
if ($collections->has($name)) {
|
||||
// Коллекция найдена (записана)
|
||||
|
||||
// Запись в вывод
|
||||
terminal::write("Создана коллекция \"$name\"");
|
||||
|
||||
// Возврат идентификатора коллекции
|
||||
return $id;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Поиск
|
||||
*
|
||||
* @param _connection $connection Соединение
|
||||
* @param string $collection Название
|
||||
* @param array $condition Условия
|
||||
*
|
||||
* @return array|null Коллекция, если найдена
|
||||
*/
|
||||
public static function search(_connection $connection, string $name, array $condition): ?array
|
||||
{
|
||||
// Инициализация
|
||||
$collections = new _collection_handler($connection);
|
||||
|
||||
if ($collections->has($name)) {
|
||||
// Коллекция найдена
|
||||
|
||||
return $collections->byExample($name, $condition)->getAll();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,177 @@
|
|||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace mirzaev\arangodb;
|
||||
|
||||
use ArangoDBClient\Connection as _connection;
|
||||
use ArangoDBClient\Exception as _exception;
|
||||
use ArangoDBClient\UpdatePolicy as _update;
|
||||
use ArangoDBClient\ConnectionOptions as _options;
|
||||
|
||||
use exception;
|
||||
|
||||
/**
|
||||
* Подключение
|
||||
*
|
||||
* @package mirzaev\arangodb
|
||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||
*/
|
||||
final class connection
|
||||
{
|
||||
/**
|
||||
* Адрес
|
||||
*/
|
||||
protected string $adress = 'tcp://127.0.0.1:8529';
|
||||
|
||||
/**
|
||||
* Хранилище (название)
|
||||
*/
|
||||
protected string $storage = 'root';
|
||||
|
||||
/**
|
||||
* Тип аутентификации
|
||||
*/
|
||||
protected string $auth = 'Basic';
|
||||
|
||||
/**
|
||||
* Псевдоним пользователя
|
||||
*/
|
||||
protected string $name = 'root';
|
||||
|
||||
/**
|
||||
* Пароль пользователя
|
||||
*/
|
||||
protected string $password = '';
|
||||
|
||||
/**
|
||||
* Тип соединения
|
||||
*/
|
||||
protected string $connection = 'Keep-Alive';
|
||||
|
||||
/**
|
||||
* Время ожидания соединения
|
||||
*/
|
||||
protected int $timeout_connect = 3;
|
||||
|
||||
/**
|
||||
* Время ожидания запроса
|
||||
*/
|
||||
protected int $timeout_request = 3;
|
||||
|
||||
/**
|
||||
* Переподключиться ли при разрыве соединения
|
||||
*/
|
||||
protected bool $reconnect = true;
|
||||
|
||||
/**
|
||||
* Создавать ли коллекцию, если она не существует
|
||||
*/
|
||||
protected bool $create = true;
|
||||
|
||||
/**
|
||||
* Действия при обновлении коллекции
|
||||
*/
|
||||
protected string $update = _update::LAST;
|
||||
|
||||
/**
|
||||
* Активация журналирования
|
||||
*/
|
||||
protected bool $journal = false;
|
||||
|
||||
/**
|
||||
* Сессия соединения
|
||||
*/
|
||||
protected _connection $session;
|
||||
|
||||
/**
|
||||
* Конструктор
|
||||
*
|
||||
* @param array $settings Настройки
|
||||
*/
|
||||
public function __construct(array $settings = null)
|
||||
{
|
||||
// Запись
|
||||
$this->__set('adress', $settings['adress'] ?? $settings['endpoint'] ?? null);
|
||||
$this->__set('storage', $settings['storage'] ?? $settings['database'] ?? null);
|
||||
$this->__set('auth', $settings['auth'] ?? null);
|
||||
$this->__set('name', $settings['name'] ?? null);
|
||||
$this->__set('password', $settings['password'] ?? null);
|
||||
$this->__set('connection', $settings['connection'] ?? null);
|
||||
$this->__set('timeout_connect', $settings['timeout_connect'] ?? null);
|
||||
$this->__set('timeout_request', $settings['timeout_request'] ?? null);
|
||||
$this->__set('reconnect', $settings['reconnect'] ?? null);
|
||||
$this->__set('create', $settings['create'] ?? null);
|
||||
$this->__set('update', $settings['update'] ?? $settings['policy'] ?? null);
|
||||
$this->__set('journal', $settings['journal'] ?? null);
|
||||
|
||||
if ($this->journal) {
|
||||
// Запрос на активацию журналирования
|
||||
|
||||
_exception::enableLogging();
|
||||
}
|
||||
|
||||
// Подключение
|
||||
$this->session = new _connection([
|
||||
_options::OPTION_ENDPOINT => $this->adress,
|
||||
_options::OPTION_DATABASE => $this->storage,
|
||||
_options::OPTION_AUTH_TYPE => $this->auth,
|
||||
_options::OPTION_AUTH_USER => $this->name,
|
||||
_options::OPTION_AUTH_PASSWD => $this->password,
|
||||
_options::OPTION_CONNECTION => $this->connection,
|
||||
_options::OPTION_CONNECT_TIMEOUT => $this->timeout_connect,
|
||||
_options::OPTION_REQUEST_TIMEOUT => $this->timeout_request,
|
||||
_options::OPTION_RECONNECT => $this->reconnect,
|
||||
_options::OPTION_CREATE => $this->create,
|
||||
_options::OPTION_UPDATE_POLICY => $this->update,
|
||||
]);
|
||||
}
|
||||
|
||||
/**
|
||||
* Записать свойство
|
||||
*
|
||||
* @param mixed $name Название
|
||||
* @param mixed $value Значение
|
||||
*/
|
||||
public function __set(string $name, mixed $value): void
|
||||
{
|
||||
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,
|
||||
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
||||
};
|
||||
}
|
||||
|
||||
/**
|
||||
* Прочитать свойство
|
||||
*
|
||||
* @param mixed $name Название
|
||||
*/
|
||||
public function __get(string $name): mixed
|
||||
{
|
||||
return match ($name) {
|
||||
'adress', 'endpoint' => $this->adress,
|
||||
'storage', 'database', 'db' => $this->storage,
|
||||
'auth' => $this->auth,
|
||||
'name' => $this->name,
|
||||
'password' => $this->password,
|
||||
'connection' => $this->connection,
|
||||
'timeout_connect' => $this->timeout_connect,
|
||||
'timeout_request' => $this->timeout_request,
|
||||
'reconnect' => $this->reconnect,
|
||||
'create' => $this->create,
|
||||
'update', 'policy' => $this->update,
|
||||
'session' => $this->session,
|
||||
default => throw new exception("Свойство \"$name\" не найдено", 404)
|
||||
};
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,82 @@
|
|||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace mirzaev\arangodb;
|
||||
|
||||
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\EdgeHandler as _edge_handler;
|
||||
|
||||
/**
|
||||
* Документ
|
||||
*
|
||||
* @package mirzaev\arangodb
|
||||
* @author Arsen Mirzaev Tatyano-Muradovich <arsen@mirzaev.sexy>
|
||||
*/
|
||||
class document
|
||||
{
|
||||
/**
|
||||
* Записать
|
||||
*
|
||||
* @param _connection $connection Инстанция соединения
|
||||
* @param string $collection Коллекция
|
||||
* @param array $data Данные
|
||||
*
|
||||
* @return string|null Идентификатор
|
||||
*/
|
||||
public static function write(_connection $connection, string $collection, array $data): ?string
|
||||
{
|
||||
// Инициализация коллекции
|
||||
collection::init($connection, $collection, isset($data['_from'], $data['_to']));
|
||||
|
||||
if (isset($data['_from'], $data['_to'])) {
|
||||
// Ребро
|
||||
|
||||
// Инициализация обработчика рёбер
|
||||
$documents = new _edge_handler($connection);
|
||||
|
||||
// Инициализация ребра
|
||||
$document = new _edge();
|
||||
|
||||
// Инициализация вершин
|
||||
$_from = $data['_from'];
|
||||
$_to = $data['_to'];
|
||||
|
||||
// Деинициализация из входных данных
|
||||
unset($data['_from'], $data['_to']);
|
||||
} else {
|
||||
// Вершина
|
||||
|
||||
// Инициализация обработчика вершин
|
||||
$documents = new _collection_handler($connection);
|
||||
|
||||
// Инициализация вершины
|
||||
$document = new _document();
|
||||
}
|
||||
|
||||
// Настройка
|
||||
foreach ($data as $key => $value) {
|
||||
// Перебор параметров
|
||||
|
||||
$document->set($key, $value);
|
||||
}
|
||||
|
||||
// Запись на сервер и его ответ в буфер возврата
|
||||
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->save($collection, $document);
|
||||
|
||||
if ($documents->has($collection, $id)) {
|
||||
// Документ записан
|
||||
|
||||
// Запись в вывод
|
||||
terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
||||
|
||||
// Возврат идентификатора коллекции
|
||||
return $id;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,31 @@
|
|||
<?php
|
||||
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace mirzaev\arangodb;
|
||||
|
||||
class terminal
|
||||
{
|
||||
/**
|
||||
* Префикс
|
||||
*/
|
||||
protected const PREFIX = 'arangodb';
|
||||
|
||||
/**
|
||||
* Запись в вывод
|
||||
*
|
||||
* @param string $text Текст сообщения
|
||||
*/
|
||||
public static function write(string $text): void
|
||||
{
|
||||
echo self::generate_prefix() . ' ' . $text . PHP_EOL;
|
||||
}
|
||||
|
||||
/**
|
||||
* Генерация префикса
|
||||
*/
|
||||
public static function generate_prefix(): string
|
||||
{
|
||||
return '[' . self::PREFIX . ']';
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue