DatabaseBatchRepository

класс DatabaseBatchRepository реализует PrunableBatchRepository (Просмотреть исходный код)

Свойства

protected BatchFactory	$factory	Экземпляр фабрики патчей.
protected Connection	$connection	Экземпляр подключения к базе данных.
protected string	$table	Таблица базы данных, используемая для хранения информации о патчах.

Методы

__construct(BatchFactory $factory, Connection $connection, string $table) Создать новый экземпляр репозитория партий.
Batch[]	get(int $limit = 50, mixed $before = null) Получить список партий.
Batch\|null	find(string $batchId) Получить информацию о существующей партии.
Batch	store(PendingBatch $batch) Сохранить новую ожидающую партию.
void	incrementTotalJobs(string $batchId, int $amount) Увеличить общее количество задач в партии.
UpdatedBatchJobCounts	decrementPendingJobs(string $batchId, string $jobId) Уменьшить общее количество ожидающих задач для партии.
UpdatedBatchJobCounts	incrementFailedJobs(string $batchId, string $jobId) Увеличить общее количество завершившихся с ошибкой задач для партии.
int\|null	updateAtomicValues(string $batchId, Closure $callback) Обновить атомарное значение в партии.
void	markAsFinished(string $batchId) Отметить партию с заданным идентификатором как завершенную.
void	cancel(string $batchId) Отменить партию с заданным идентификатором.
void	delete(string $batchId) Удалить партию с заданным идентификатором.
int	prune(DateTimeInterface $before) Удалить все записи, старше указанной даты.
int	pruneUnfinished(DateTimeInterface $before) Удалить все незавершенные записи, старше указанной даты.
int	pruneCancelled(DateTimeInterface $before) Удалить все отмененные записи, старше указанной даты.
mixed	transaction(Closure $callback) Выполнить заданный Closure в рамках транзакции, специфичной для хранилища.
void	rollBack() Откатить последнюю базу данных транзакцию для подключения.
string	serialize(mixed $value) Сериализовать заданное значение.
mixed	unserialize(string $serialized) Десериализовать заданное значение.
Batch	toBatch(object $batch) Преобразовать переданную партию в объект Batch.
Connection	getConnection() Получить базу данных подключение.

void

setConnection(Connection $connection)

Установить базу данных.

Подробности

__construct(BatchFactory $factory, Connection $connection, string $table)

Создать новый экземпляр хранилища партий.

Параметры

BatchFactory	$factory
Connection	$connection
string	$table

Batch[] get(int $limit = 50, mixed $before = null)

Получить список партий.

Параметры

int	$limit
mixed	$before

Возвращаемое значение

Batch[]

Batch|null find(string $batchId)

Получить информацию о существующей партии.

Параметры

string

$batchId

Возвращаемое значение

Batch|null

Batch store(PendingBatch $batch)

Сохранить новую ожидающую партию.

Параметры

PendingBatch

$batch

Возвращаемое значение

Batch

void incrementTotalJobs(string $batchId, int $amount)

Увеличить общее количество задач в партии.

Параметры

string	$batchId
int	$amount

Возвращаемое значение

void

UpdatedBatchJobCounts decrementPendingJobs(string $batchId, string $jobId)

Уменьшить общее количество ожидающих задач для партии.

Параметры

string	$batchId
string	$jobId

Возвращаемое значение

UpdatedBatchJobCounts

UpdatedBatchJobCounts incrementFailedJobs(string $batchId, string $jobId)

Увеличить общее количество завершенных задач для партии.

Параметры

string	$batchId
string	$jobId

Возвращаемое значение

UpdatedBatchJobCounts

protected int|null updateAtomicValues(string $batchId, Closure $callback)

Обновить атомарное значение в пакетной операции.

Параметры

string	$batchId
Closure	$callback

Значение возврата

int|null

void markAsFinished(string $batchId)

Отметить пакет с заданным идентификатором как завершённый.

Параметры

string

$batchId

Значение возврата

void

void cancel(string $batchId)

Отменить пакет с заданным идентификатором.

Параметры

string

$batchId

Значение возврата

void

void delete(string $batchId)

Удалить пакет с заданным идентификатором.

Параметры

string

$batchId

Значение возврата

void

int prune(DateTimeInterface $before)

Очистить все записи, более старые, чем указанная дата.

Параметры

DateTimeInterface

$before

Значение возврата

int

int pruneUnfinished(DateTimeInterface $before)

Очистить все незавершенные записи, более старые, чем указанная дата.

Параметры

DateTimeInterface

$before

Значение возврата

int

int pruneCancelled(DateTimeInterface $before)

Очистить все отменённые записи, более старые, чем указанная дата.

Параметры

DateTimeInterface

$before

Значение возврата

int

mixed transaction(Closure $callback)

Выполнить заданный Closure в рамках транзакции, специфичной для хранилища.

Параметры

Closure

$callback

Значение возврата

mixed

void rollBack()

Откатить последнюю базу данных транзакцию для подключения.

Значение возврата

void

protected string serialize(mixed $value)

Сериализовать заданное значение.

Параметры

mixed

$value

Значение возврата

string

protected mixed unserialize(string $serialized)

Десериализовать заданное значение.

Параметры

строка

$serialized

Возвращаемое значение

смешанный тип

protected Batch toBatch(object $batch)

Преобразовать заданный сырой пакет в объект Batch.

Параметры

объект

$batch

Возвращаемое значение

Batch

Подключение getConnection()

Получить базовое подключение к базе данных.

Возвращаемое значение

Подключение

void setConnection(Подключение $connection)

Установить базовое подключение к базе данных.

Параметры

Подключение

$connection

Возвращаемое значение

void

© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/10.x/Illuminate/Bus/DatabaseBatchRepository.html