DatabaseBatchRepository

class DatabaseBatchRepository implements PrunableBatchRepository (View source)

Свойства

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) Отметить партию с данным ID как завершенную.
void	cancel(string $batchId) Отменить партию с данным ID.
void	delete(string $batchId) Удалить партию с данным ID.
int	prune(DateTimeInterface $before) Удалить все записи, более старые, чем указанная дата.
int	pruneUnfinished(DateTimeInterface $before) Удалить все незавершенные записи, более старые, чем указанная дата.
int	pruneCancelled(DateTimeInterface $before) Удалить все отмененные записи, более старые, чем указанная дата.
mixed	transaction(Closure $callback) Выполнить переданный замыкание в рамках транзакции, специфичной для хранилища.
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)

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

Parameters

string	$batchId
Closure	$callback

Return Value

int|null

void markAsFinished(string $batchId)

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

Parameters

string

$batchId

Return Value

void

void cancel(string $batchId)

Отменить пакет с заданным ID.

Parameters

string

$batchId

Return Value

void

void delete(string $batchId)

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

Parameters

string

$batchId

Return Value

void

int prune(DateTimeInterface $before)

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

Parameters

DateTimeInterface

$before

Return Value

int

int pruneUnfinished(DateTimeInterface $before)

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

Parameters

DateTimeInterface

$before

Return Value

int

int pruneCancelled(DateTimeInterface $before)

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

Parameters

DateTimeInterface

$before

Return Value

int

mixed transaction(Closure $callback)

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

Parameters

Closure

$callback

Return Value

mixed

void rollBack()

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

Return Value

void

protected string serialize(mixed $value)

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

Parameters

mixed

$value

Return Value

string

protected mixed unserialize(string $serialized)

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

Параметры

строка

$serialized

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

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

protected Batch toBatch(object $batch)

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

Параметры

объект

$batch

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

Batch

Connection getConnection()

Получить базу данных.

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

Connection

void setConnection(Connection $connection)

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

Параметры

Connection

$connection

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

void

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