PostgresConnection
class PostgresConnection extends Connection (View source)
Особенности
| DetectsConcurrencyErrors | |
| DetectsLostConnections | |
| ManagesTransactions |
Свойства
| protected PDO|Closure | $pdo | Активное подключение PDO. | из Connection |
| protected PDO|Closure | $readPdo | Активное подключение PDO, используемое для чтения. | из Connection |
| protected string | $database | Имя подключенной базы данных. | из Connection |
| protected string | $tablePrefix | Префикс таблиц для подключения. | из Connection |
| protected array | $config | Параметры конфигурации подключения к базе данных. | из Connection |
| protected callable | $reconnector | Экземпляр reconnector для подключения. | из Connection |
| protected Grammar | $queryGrammar | Реализация синтаксического анализа запросов. | из Connection |
| protected Grammar | $schemaGrammar | Реализация синтаксического анализа схемы. | из Connection |
| protected Processor | $postProcessor | Реализация постпроцессора запросов. | из Connection |
| protected Dispatcher | $events | Экземпляр диспетчера событий. | из Connection |
| protected int | $fetchMode | Режим извлечения по умолчанию для подключения. | из Connection |
| protected int | $transactions | Количество активных транзакций. | из Connection |
| protected int | $recordsModified | Указывает, были ли внесены изменения в базу данных. | из Connection |
| protected array | $queryLog | Все запросы, выполненные к подключению. | из Connection |
| protected bool | $loggingQueries | Указывает, регистрируются ли запросы. | из Connection |
| protected bool | $pretending | Указывает, находится ли подключение в режиме "сухого прогона". | из Connection |
| protected Connection | $doctrineConnection | Экземпляр подключения Doctrine. | из Connection |
| static protected array | $resolvers | Резолверы подключений. | из Connection |
Методы
| bool | causedByConcurrencyError(Throwable $e)
Определить, было ли данное исключение вызвано ошибкой конкурентного доступа, такой как тупик или сбой сериализации. | from DetectsConcurrencyErrors |
| bool | causedByLostConnection(Throwable $e)
Определить, было ли данное исключение вызвано потерей соединения. | from DetectsLostConnections |
| mixed | transaction(Closure $callback, int $attempts = 1)
Выполнить замыкание в рамках транзакции. | from ManagesTransactions |
| void | handleTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при выполнении транзакционного оператора. | from ManagesTransactions |
| void | beginTransaction()
Начать новую базу данных транзакции. | from ManagesTransactions |
| void | createTransaction()
Создать транзакцию в базе данных. | from ManagesTransactions |
| void | createSavepoint()
Создать точку сохранения в базе данных. | from ManagesTransactions |
| void | handleBeginTransactionException(Throwable $e)
Обработать исключение при начале транзакции. | from ManagesTransactions |
| void | commit()
Подтвердить активную транзакцию базы данных. | from ManagesTransactions |
| void | handleCommitTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при подтверждении транзакции. | from ManagesTransactions |
| void | rollBack(int|null $toLevel = null)
Отменить активную транзакцию базы данных. | from ManagesTransactions |
| void | performRollBack(int $toLevel)
Выполнить откат в базе данных. | from ManagesTransactions |
| void | handleRollBackException(Throwable $e)
Обработать исключение при отмене. | from ManagesTransactions |
| int | transactionLevel()
Получить количество активных транзакций. | from ManagesTransactions |
| void | __construct(PDO|Closure $pdo, string $database = '', string $tablePrefix = '', array $config = [])
Создать новый экземпляр подключения к базе данных. | from Connection |
| void | useDefaultQueryGrammar()
Установить синтаксический анализатор запросов по умолчанию. | from Connection |
| Grammar | getDefaultQueryGrammar()
Получить экземпляр синтаксического анализатора запросов по умолчанию. | |
| void | useDefaultSchemaGrammar()
Установить синтаксический анализатор схемы по умолчанию. | from Connection |
| Grammar | getDefaultSchemaGrammar()
Получить экземпляр синтаксического анализатора схемы по умолчанию. | |
| void | useDefaultPostProcessor()
Установить обработчик результатов запросов по умолчанию. | from Connection |
| Processor | getDefaultPostProcessor()
Получить экземпляр обработчика результатов запросов по умолчанию. | |
| Builder | getSchemaBuilder()
Получить экземпляр генератора схем для подключения. | |
| Builder | table(Closure|Builder|string $table, string|null $as = null)
Начать построение запроса к таблице базы данных. | from Connection |
| Builder | query()
Получить новый экземпляр билдера запросов. | from Connection |
| mixed | selectOne(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить оператор выбора и вернуть единственный результат. | from Connection |
| array | selectFromWriteConnection(string $query, array $bindings = [])
Выполнить оператор выбора в базе данных. | from Connection |
| array | select(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить оператор выбора в базе данных. | from Connection |
| Generator | cursor(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить оператор select в базе данных и вернуть генератор. | from Connection |
| PDOStatement | prepared(PDOStatement $statement)
Настроить оператор PDO prepared. | from Connection |
| PDO | getPdoForSelect(bool $useReadPdo = true)
Получить подключение PDO для запроса select. | from Connection |
| bool | insert(string $query, array $bindings = [])
Выполнить оператор insert в базе данных. | from Connection |
| int | update(string $query, array $bindings = [])
Выполнить оператор update в базе данных. | from Connection |
| int | delete(string $query, array $bindings = [])
Выполнить оператор delete в базе данных. | from Connection |
| bool | statement(string $query, array $bindings = [])
Выполнить SQL-запрос и вернуть boolean результат. | from Connection |
| int | affectingStatement(string $query, array $bindings = [])
Выполнить SQL-запрос и получить количество измененных строк. | from Connection |
| bool | unprepared(string $query)
Выполнить сырой, неподготовленный запрос к подключению PDO. | from Connection |
| array | pretend(Closure $callback)
Выполнить заданный обратный вызов в режиме «сухого запуска». | from Connection |
| array | withFreshQueryLog(Closure $callback)
Выполнить заданный обратный вызов в режиме «сухого запуска». | from Connection |
| void | bindValues(PDOStatement $statement, array $bindings)
Связать значения с их параметрами в данном операторе. | |
| array | prepareBindings(array $bindings)
Подготовить параметры запроса для выполнения. | from Connection |
| mixed | run(string $query, array $bindings, Closure $callback)
Выполнить SQL-запрос и записать контекст его выполнения. | from Connection |
| mixed | runQueryCallback(string $query, array $bindings, Closure $callback)
Выполнить SQL-запрос. | from Connection |
| void | logQuery(string $query, array $bindings, float|null $time = null)
Записать запрос в журнал запросов подключения. | from Connection |
| float | getElapsedTime(int $start)
Получить время, прошедшее с заданной начальной точки. | from Connection |
| mixed | handleQueryException(QueryException $e, string $query, array $bindings, Closure $callback)
Обработать исключение запроса. | from Connection |
| mixed | tryAgainIfCausedByLostConnection(QueryException $e, string $query, array $bindings, Closure $callback)
Обработать исключение запроса, произошедшее во время выполнения запроса. | from Connection |
| void | reconnect()
Подключиться к базе данных снова. | from Connection |
| void | reconnectIfMissingConnection()
Подключиться к базе данных снова, если подключение PDO отсутствует. | from Connection |
| void | disconnect()
Отключиться от базового подключения PDO. | from Connection |
| void | listen(Closure $callback)
Зарегистрировать обработчик запросов базы данных с подключением. | from Connection |
| array|null | fireConnectionEvent(string $event)
Вызвать событие для этого подключения. | from Connection |
| void | event(mixed $event)
Вызвать заданное событие, если это возможно. | from Connection |
| Expression | raw(mixed $value)
Получить новое выражение SQL-запроса. | from Connection |
| void | recordsHaveBeenModified(bool $value = true)
Указать, были ли изменены какие-либо записи. | from Connection |
| bool | isDoctrineAvailable()
Доступен ли Doctrine? | from Connection |
| Column | getDoctrineColumn(string $table, string $column)
Получить экземпляр Doctrine Schema Column. | from Connection |
| AbstractSchemaManager | getDoctrineSchemaManager()
Получить менеджер схемы Doctrine DBAL для соединения. | from Connection |
| Connection | getDoctrineConnection()
Получить экземпляр подключения к базе данных Doctrine DBAL. | from Connection |
| PDO | getPdo()
Получить текущее PDO подключение. | from Connection |
| PDO|Closure|null | getRawPdo()
Получить параметр текущего PDO подключения без выполнения логики повторного подключения. | from Connection |
| PDO | getReadPdo()
Получить текущее PDO подключение, используемое для чтения. | from Connection |
| PDO|Closure|null | getRawReadPdo()
Получить параметр текущего PDO подключения для чтения без выполнения логики повторного подключения. | from Connection |
| $this | setPdo(PDO|Closure|null $pdo)
Установить PDO подключение. | from Connection |
| $this | setReadPdo(PDO|Closure|null $pdo)
Установить PDO подключение, используемое для чтения. | from Connection |
| $this | setReconnector(callable $reconnector)
Установить экземпляр повторного подключения к соединению. | from Connection |
| string|null | getName()
Получить имя подключения к базе данных. | from Connection |
| mixed | getConfig(string|null $option = null)
Получить параметр из параметров конфигурации. | from Connection |
| string | getDriverName()
Получить имя драйвера PDO. | from Connection |
| Grammar | getQueryGrammar()
Получить синтаксический анализатор запросов, используемый подключением. | from Connection |
| $this | setQueryGrammar(Grammar $grammar)
Установить синтаксический анализатор запросов, используемый подключением. | from Connection |
| Grammar | getSchemaGrammar()
Получить синтаксический анализатор схем, используемый подключением. | from Connection |
| $this | setSchemaGrammar(Grammar $grammar)
Установить синтаксический анализатор схем, используемый подключением. | from Connection |
| Processor | getPostProcessor()
Получить обработчик запросов после выполнения, используемый подключением. | from Connection |
| $this | setPostProcessor(Processor $processor)
Установить обработчик запросов после выполнения, используемый подключением. | from Connection |
| Dispatcher | getEventDispatcher()
Получить диспетчер событий, используемый подключением. | from Connection |
| $this | setEventDispatcher(Dispatcher $events)
Установить экземпляр диспетчера событий для подключения. | from Connection |
| void | unsetEventDispatcher()
Удалить диспетчер событий для этого подключения. | from Connection |
| bool | pretending()
Определить, находится ли подключение в режиме "сухого запуска". | from Connection |
| array | getQueryLog()
Получить журнал запросов подключения. | from Connection |
| void | flushQueryLog()
Очистить журнал запросов. | from Connection |
| void | enableQueryLog()
Включить журнал запросов для подключения. | from Connection |
| void | disableQueryLog()
Отключить журнал запросов для подключения. | from Connection |
| bool | logging()
Определить, ведем ли мы журнал запросов. | from Connection |
| string | getDatabaseName()
Получить имя подключенной базы данных. | from Connection |
| $this | setDatabaseName(string $database)
Установить имя подключенной базы данных. | from Connection |
| string | getTablePrefix()
Получить префикс таблиц для подключения. | from Connection |
| $this | setTablePrefix(string $prefix)
Установить префикс таблицы, используемый соединением. | from Connection |
| Grammar | withTablePrefix(Grammar $grammar)
Установить префикс таблицы и вернуть грамматику. | from Connection |
| static void | resolverFor(string $driver, Closure $callback)
Зарегистрировать решатель соединений. | from Connection |
| static mixed | getResolver(string $driver)
Получить решатель соединений для заданного драйвера. | from Connection |
| Driver | getDoctrineDriver()
Получить драйвер Doctrine DBAL. |
Подробности
protected bool causedByConcurrencyError(Throwable $e)
Определить, вызвана ли данная исключительная ситуация ошибкой одновременного доступа, такой как тупик или ошибка сериализации.
protected bool causedByLostConnection(Throwable $e)
Определить, вызвана ли данная исключительная ситуация потерей соединения.
mixed transaction(Closure $callback, int $attempts = 1)
Выполнить Closure в рамках транзакции.
protected void handleTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при выполнении транзакционного оператора.
void beginTransaction()
Начать новую базу данных транзакции.
protected void createTransaction()
Создать транзакцию в базе данных.
protected void createSavepoint()
Создать точку сохранения в базе данных.
protected void handleBeginTransactionException(Throwable $e)
Обработать исключение при начале транзакции.
void commit()
Подтвердить активную базу данных транзакции.
protected void handleCommitTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при подтверждении транзакции.
void rollBack(int|null $toLevel = null)
Отменить активную базу данных транзакции.
protected void performRollBack(int $toLevel)
Выполнить откат в базе данных.
protected void handleRollBackException(Throwable $e)
Обработать исключение при отмене.
int transactionLevel()
Получить количество активных транзакций.
void __construct(PDO|Closure $pdo, string $database = '', string $tablePrefix = '', array $config = [])
Создать новый экземпляр подключения к базе данных.
void useDefaultQueryGrammar()
Установить синтаксический анализатор запросов на значение по умолчанию.
protected Grammar getDefaultQueryGrammar()
Получить экземпляр синтаксического анализатора запросов по умолчанию.
void useDefaultSchemaGrammar()
Установить синтаксический анализатор схем на значение по умолчанию.
protected Grammar getDefaultSchemaGrammar()
Получить экземпляр синтаксического анализатора схем по умолчанию.
void useDefaultPostProcessor()
Установить обработчик запросов на значение по умолчанию.
protected Processor getDefaultPostProcessor()
Получить экземпляр обработчика запросов по умолчанию.
Builder getSchemaBuilder()
Получить экземпляр конструктора схем для подключения.
Builder table(Closure|Builder|string $table, string|null $as = null)
Начать работу с таблицей базы данных с помощью цепочки методов.
Builder query()
Получить новый экземпляр конструктора запросов.
mixed selectOne(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить запрос SELECT и вернуть единственный результат.
array selectFromWriteConnection(string $query, array $bindings = [])
Выполнить запрос SELECT в базе данных.
array select(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить запрос SELECT в базе данных.
Generator cursor(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить запрос SELECT в базе данных и вернуть генератор.
protected PDOStatement prepared(PDOStatement $statement)
Настроить подготовленное выражение PDO.
protected PDO getPdoForSelect(bool $useReadPdo = true)
Получить соединение PDO для запроса SELECT.
bool insert(string $query, array $bindings = [])
Выполнить запрос INSERT в базе данных.
int update(string $query, array $bindings = [])
Выполнить запрос UPDATE в базе данных.
int delete(string $query, array $bindings = [])
Выполнить операцию удаления в базе данных.
bool statement(string $query, array $bindings = [])
Выполнить SQL-запрос и вернуть булево значение результата.
int affectingStatement(string $query, array $bindings = [])
Выполнить SQL-запрос и получить количество изменённых строк.
bool unprepared(string $query)
Выполнить неподготовленный SQL-запрос к соединению PDO.
array pretend(Closure $callback)
Выполнить указанный обратный вызов в режиме "сухого запуска".
protected array withFreshQueryLog(Closure $callback)
Выполнить указанный обратный вызов в режиме "сухого запуска".
void bindValues(PDOStatement $statement, array $bindings)
Привязать значения к параметрам в данном операторе.
array prepareBindings(array $bindings)
Подготовить привязки к запросу для выполнения.
protected mixed run(string $query, array $bindings, Closure $callback)
Выполнить SQL-запрос и залогировать контекст его выполнения.
protected mixed runQueryCallback(string $query, array $bindings, Closure $callback)
Выполнить SQL-запрос.
void logQuery(string $query, array $bindings, float|null $time = null)
Залогировать запрос в журнале запросов соединения.
protected float getElapsedTime(int $start)
Получить прошедшее время с заданной точки отсчёта.
protected mixed handleQueryException(QueryException $e, string $query, array $bindings, Closure $callback)
Обработать исключение запроса.
protected mixed tryAgainIfCausedByLostConnection(QueryException $e, string $query, array $bindings, Closure $callback)
Обработать исключение запроса, произошедшее во время выполнения.
void reconnect()
Переподключиться к базе данных.
protected void reconnectIfMissingConnection()
Переподключиться к базе данных, если соединение PDO отсутствует.
void disconnect()
Отключиться от базового соединения PDO.
void listen(Closure $callback)
Зарегистрировать слушателя запросов к базе данных с подключением.
protected array|null fireConnectionEvent(string $event)
Вызвать событие для этого подключения.
protected void event(mixed $event)
Вызвать заданное событие, если это возможно.
Expression raw(mixed $value)
Получить новое выражение запроса raw.
void recordsHaveBeenModified(bool $value = true)
Указать, были ли изменены какие-либо записи.
bool isDoctrineAvailable()
Доступен ли Doctrine?
Column getDoctrineColumn(string $table, string $column)
Получить экземпляр Doctrine Schema Column.
AbstractSchemaManager getDoctrineSchemaManager()
Получить менеджер схемы Doctrine DBAL для подключения.
Connection getDoctrineConnection()
Получить экземпляр подключения к базе данных Doctrine DBAL.
PDO getPdo()
Получить текущее подключение PDO.
PDO|Closure|null getRawPdo()
Получить текущий параметр подключения PDO без выполнения логики повторного подключения.
PDO getReadPdo()
Получить текущее подключение PDO, используемое для чтения.
PDO|Closure|null getRawReadPdo()
Получить текущий параметр подключения для чтения PDO без выполнения логики повторного подключения.
$this setReconnector(callable $reconnector)
Установить экземпляр повторного подключения к подключению.
string|null getName()
Получить имя подключения к базе данных.
mixed getConfig(string|null $option = null)
Получить опцию из параметров конфигурации.
string getDriverName()
Получить имя драйвера PDO.
Grammar getQueryGrammar()
Получить синтаксический анализатор запросов, используемый подключением.
$this setQueryGrammar(Grammar $grammar)
Установить синтаксический анализатор запросов, используемый подключением.
Грамматика getSchemaGrammar()
Получить грамматику схемы, используемую подключением.
$this setSchemaGrammar(Грамматика $grammar)
Установить грамматику схемы, используемую подключением.
Обработчик getPostProcessor()
Получить пост-обработчик запросов, используемый подключением.
$this setPostProcessor(Обработчик $processor)
Установить пост-обработчик запросов, используемый подключением.
Диспечер событий getEventDispatcher()
Получить диспечер событий, используемый подключением.
$this setEventDispatcher(Диспечер событий $events)
Установить экземпляр диспечера событий для подключения.
void unsetEventDispatcher()
Удалить диспечер событий для этого подключения.
bool pretending()
Определить, находится ли подключение в режиме "сухого запуска".
array getQueryLog()
Получить журнал запросов подключения.
void flushQueryLog()
Очистить журнал запросов.
void enableQueryLog()
Включить журнал запросов для подключения.
void disableQueryLog()
Отключить журнал запросов для подключения.
bool logging()
Определить, ведем ли мы логирование запросов.
string getDatabaseName()
Получить имя подключенной базы данных.
$this setDatabaseName(string $database)
Установить имя подключенной базы данных.
string getTablePrefix()
Получить префикс таблиц для подключения.
$this setTablePrefix(string $prefix)
Установить используемый префикс таблиц для подключения.
Грамматика withTablePrefix(Грамматика $grammar)
Установить префикс таблиц и вернуть грамматику.
static void resolverFor(string $driver, Closure $callback)
Зарегистрировать решатель подключений.
static mixed getResolver(string $driver)
Получить решатель подключений для заданного драйвера.
protected Driver getDoctrineDriver()
Получить драйвер Doctrine DBAL.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/7.x/Illuminate/Database/PostgresConnection.html