forked from mirzaev/arangodb
Compare commits
No commits in common. "stable" and "0.3.0" have entirely different histories.
|
@ -1,7 +1,6 @@
|
||||||
{
|
{
|
||||||
"name": "mirzaev/arangodb",
|
"name": "mirzaev/arangodb",
|
||||||
"description": "Simple PHP-framework for ArangoDB",
|
"description": "Реализация управления хранилищем данных ArangoDB",
|
||||||
"readme": "README.md",
|
|
||||||
"keywords": [
|
"keywords": [
|
||||||
"ArangoDB"
|
"ArangoDB"
|
||||||
],
|
],
|
||||||
|
@ -16,17 +15,6 @@
|
||||||
"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.1",
|
||||||
"triagens/arangodb": "~3.8"
|
"triagens/arangodb": "~3.8"
|
||||||
|
|
|
@ -26,17 +26,18 @@ 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 = null, ?array $metadata = null, 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($data['_from'], $data['_to'])) {
|
if (isset($metadata['_from'], $metadata['_to'])) {
|
||||||
// Ребро
|
// Ребро
|
||||||
|
|
||||||
// Инициализация обработчика рёбер
|
// Инициализация обработчика рёбер
|
||||||
|
@ -46,11 +47,11 @@ class document
|
||||||
$document = new _edge();
|
$document = new _edge();
|
||||||
|
|
||||||
// Инициализация вершин
|
// Инициализация вершин
|
||||||
$_from = $data['_from'];
|
$_from = $metadata['_from'];
|
||||||
$_to = $data['_to'];
|
$_to = $metadata['_to'];
|
||||||
|
|
||||||
// Деинициализация из входных данных
|
// Деинициализация из входных данных
|
||||||
unset($data['_from'], $data['_to']);
|
unset($metadata['_from'], $metadata['_to']);
|
||||||
} else {
|
} else {
|
||||||
// Вершина
|
// Вершина
|
||||||
|
|
||||||
|
@ -61,7 +62,7 @@ class document
|
||||||
$document = new _document();
|
$document = new _document();
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach (['created' => time()] + $data as $key => $value) {
|
foreach (['data' => $data, 'metadata' => ($metadata ?? []) + ['created' => time()]] as $key => $value) {
|
||||||
// Перебор параметров
|
// Перебор параметров
|
||||||
|
|
||||||
// Запись в инстанцию документа
|
// Запись в инстанцию документа
|
||||||
|
@ -71,18 +72,11 @@ class document
|
||||||
// Запись на сервер и его ответ в буфер возврата
|
// Запись на сервер и его ответ в буфер возврата
|
||||||
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
|
$id = isset($_from, $_to) ? $documents->saveEdge($collection, $_from, $_to, $document) : $documents->insert($collection, $document);
|
||||||
|
|
||||||
if ($check && $documents->has($collection, $id)) {
|
if ($check && $terminal instanceof terminal && $documents->has($collection, $id)) {
|
||||||
// Найден записанный документ
|
// Документ записан
|
||||||
|
|
||||||
// Запись в вывод
|
// Запись в вывод
|
||||||
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
$terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
||||||
} else if ($check) {
|
|
||||||
// Не найден записанный документ
|
|
||||||
|
|
||||||
// Запись в вывод
|
|
||||||
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" не удалось найти созданный или создать документ");
|
|
||||||
|
|
||||||
return null;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Возврат идентификатора коллекции
|
// Возврат идентификатора коллекции
|
||||||
|
@ -97,8 +91,7 @@ class document
|
||||||
*
|
*
|
||||||
* @return bool Статус обработки
|
* @return bool Статус обработки
|
||||||
*/
|
*/
|
||||||
public static function update(_connection $session, _document $document): bool
|
public static function update(_connection $session, _document $document): bool {
|
||||||
{
|
|
||||||
// Инициализация обработчика вершин
|
// Инициализация обработчика вершин
|
||||||
$documents = new _document_handler($session);
|
$documents = new _document_handler($session);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue