Compare commits
2 Commits
cb1388722c
...
d0ce9e47af
| Author | SHA1 | Date | |
|---|---|---|---|
 Arsen Mirzaev Tatyano-Muradovich
|
d0ce9e47af | ||
|
Arsen Mirzaev Tatyano-Muradovich
|
b2088df8fb |
|
|
@ -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|array|string|int|null Инстанция документа
|
*
|
||||||
*/
|
* @return _document|array|string|int|null Инстанция документа
|
||||||
public static function search(_connection $session, string $query): _document|string|array|int|null
|
*/
|
||||||
{
|
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 is_array($buffer) && count($buffer) > 1 ? $buffer : $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;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -20,89 +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 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 = [], bool $check = false, ?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($data['_from'], $data['_to'])) {
|
||||||
// Ребро
|
// Ребро
|
||||||
|
|
||||||
// Инициализация обработчика рёбер
|
// Инициализация обработчика рёбер
|
||||||
$documents = new _edge_handler($session);
|
$documents = new _edge_handler($session);
|
||||||
|
|
||||||
// Инициализация ребра
|
// Инициализация ребра
|
||||||
$document = new _edge();
|
$document = new _edge();
|
||||||
|
|
||||||
// Инициализация вершин
|
// Инициализация вершин
|
||||||
$_from = $data['_from'];
|
$_from = $data['_from'];
|
||||||
$_to = $data['_to'];
|
$_to = $data['_to'];
|
||||||
|
|
||||||
// Деинициализация из входных данных
|
// Деинициализация из входных данных
|
||||||
unset($data['_from'], $data['_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 (['created' => time()] + $data 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 && $documents->has($collection, $id)) {
|
// Запись на сервер и его ответ в буфер возврата
|
||||||
// Найден записанный документ
|
$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\" не удалось найти созданный или создать документ");
|
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" создан документ \"$id\"");
|
||||||
|
} else if ($check) {
|
||||||
|
// Не найден записанный документ
|
||||||
|
|
||||||
return null;
|
// Запись в вывод
|
||||||
}
|
if ($terminal instanceof terminal) $terminal::write("В коллекции \"$collection\" не удалось найти созданный или создать документ");
|
||||||
|
|
||||||
// Возврат идентификатора коллекции
|
return null;
|
||||||
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);
|
* Обновить
|
||||||
}
|
*
|
||||||
|
* @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);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue