14 Commits
0.4 ... 1.3.0

9 changed files with 325 additions and 2375 deletions

2
.gitignore vendored Normal file → Executable file
View File

@@ -1 +1,3 @@
vendor vendor
composer.lock
!.gitignore

11
LICENSE Normal file
View File

@@ -0,0 +1,11 @@
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.

3
README.md Normal file
View File

@@ -0,0 +1,3 @@
# PHP 8.2 Framework for working with ArangoDB
🤟 Very simple and flexible, easy to scale and integrate

16
composer.json Normal file → Executable file
View File

@@ -1,6 +1,7 @@
{ {
"name": "mirzaev/arangodb", "name": "mirzaev/arangodb",
"description": "Реализация управления хранилищем данных ArangoDB", "description": "Simple PHP-framework for ArangoDB",
"readme": "README.md",
"keywords": [ "keywords": [
"ArangoDB" "ArangoDB"
], ],
@@ -15,8 +16,19 @@
"role": "Developer" "role": "Developer"
} }
], ],
"support": {
"email": "arsen@mirzaev.sexy",
"wiki": "https://git.mirzaev.sexy/mirzaev/arangodb/manual",
"issues": "https://git.mirzaev.sexy/mirzaev/arangodb/issues"
},
"funding": [
{
"type": "funding",
"url": "https://fund.mirzaev.sexy"
}
],
"require": { "require": {
"php": "^8.1", "php": "^8.2",
"triagens/arangodb": "~3.8" "triagens/arangodb": "~3.8"
}, },
"require-dev": { "require-dev": {

2098
composer.lock generated

File diff suppressed because it is too large Load Diff

165
mirzaev/arangodb/system/collection.php Normal file → Executable file
View File

@@ -20,99 +20,106 @@ use ArangoDBClient\CollectionHandler as _collection_handler;
*/ */
class collection class collection
{ {
/** /**
* Инициализация * Инициализация
* *
* @param _connection $session Сессия соединения с базой данных * @param _connection $session Сессия соединения с базой данных
* @param string $name Название * @param string $name Название
* @param bool $edge Обрабатывать как ребро? (иначе: вершина) * @param bool $edge Обрабатывать как ребро? (иначе: вершина)
* @param ?terminal $terminal Инстанция терминала * @param ?terminal $terminal Инстанция терминала
* *
* @return string|null Идентификатор коллекции * @return string|null Идентификатор коллекции
*/ */
public static function init(_connection $session, string $name, bool $edge = false, ?terminal $terminal = null): ?string public static function init(_connection $session, string $name, bool $edge = false, ?terminal $terminal = null): ?string
{ {
// Инициализация // Инициализация
$collections = new _collection_handler($session); $collections = new _collection_handler($session);
if (!$collections->has($name)) { if (!$collections->has($name)) {
// Не найдана коллекция // Не найдана коллекция
// Запись в вывод // Запись в вывод
if ($terminal instanceof terminal) $terminal::write("Коллекция \"$name\" не найдена"); if ($terminal instanceof terminal) $terminal::write("Коллекция \"$name\" не найдена");
// Запись коллекции на сервер и его ответ в буфер возврата // Запись коллекции на сервер и его ответ в буфер возврата
$id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]); $id = $collections->create($name, ['type' => $edge ? _collection::TYPE_EDGE : _collection::TYPE_DOCUMENT]);
if ($collections->has($name)) { if ($collections->has($name)) {
// Коллекция найдена (записана) // Коллекция найдена (записана)
// Запись в вывод // Запись в вывод
if ($terminal instanceof terminal) $terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ')); if ($terminal instanceof terminal) $terminal::write("Создана коллекция \"$name\" с типом " . ($edge ? 'ребро' : 'документ'));
// Возврат идентификатора коллекции // Возврат идентификатора коллекции
return $id; return $id;
} }
} else { } else {
// Найдена коллекция // Найдена коллекция
// Возврат идентификатора коллекции // Возврат идентификатора коллекции
return $name; return $name;
} }
return null; return null;
} }
/** /**
* Поиск * Поиск
* *
* @param _connection $session Сессия соединения с базой данных * @param _connection $session Сессия соединения с базой данных
* @param string $query AQL-запрос * @param string $query AQL-запрос
* * @param array $binds Binds for query [bind => value]
* @return _document|null Инстанция документа *
*/ * @return _document|array|string|int|null Инстанция документа
public static function search(_connection $session, string $query): ?_document */
{ public static function search(_connection $session, string $query, array $binds = []): _document|string|array|int|null
// Поиск журнала {
$journal = (new _statement( // Statement instance initialization
$session, $instance = new _statement(
[ $session,
'query' => $query, [
"batchSize" => 1000, 'query' => $query,
"sanitize" => true "batchSize" => 1000,
] "sanitize" => true
))->execute(); ]
);
// Инициализация буфера вывода // Binds application
$buffer = []; $instance->bind($binds);
foreach ($journal as $key => $value) { // Sending the request
$buffer[$key] = $value; $response = $instance->execute();
}
return $buffer[0] ?? null; // Инициализация буфера вывода
} $buffer = [];
/** foreach ($response->getAll() as $key => $value) {
* Очистка $buffer[$key] = $value;
* }
* @param _connection $session Сессия соединения с базой данных
* @param string $name Название
*
* @return bool Статус выполнения
*/
public static function truncate(_connection $session, string $name): bool
{
// Инициализация
$collections = new _collection_handler($session);
if ($collections->has($name)) { return is_array($buffer) && count($buffer) > 1 ? $buffer : $buffer[0] ?? null;
// Найдена коллекция }
// Очистка /**
return $collections->truncate($name); * Очистка
} *
* @param _connection $session Сессия соединения с базой данных
* @param string $name Название
*
* @return bool Статус выполнения
*/
public static function truncate(_connection $session, string $name): bool
{
// Инициализация
$collections = new _collection_handler($session);
return false; if ($collections->has($name)) {
} // Найдена коллекция
// Очистка
return $collections->truncate($name);
}
return false;
}
} }

0
mirzaev/arangodb/system/connection.php Normal file → Executable file
View File

139
mirzaev/arangodb/system/document.php Normal file → Executable file
View File

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

0
mirzaev/arangodb/system/terminal.php Normal file → Executable file
View File