PostgresConnection
класс PostgresConnection расширяет Connection (Просмотреть исходный код)
Трейты
| DetectsConcurrencyErrors | |
| DetectsLostConnections | |
| ManagesTransactions |
Свойства
| protected PDO|Closure | $pdo | Активное соединение PDO. | из Connection |
| protected PDO|Closure | $readPdo | Активное соединение PDO, используемое для чтений. | из Connection |
| protected string | $database | Имя подключенной базы данных. | из Connection |
| protected string|null | $readWriteType | Тип соединения. | из Connection |
| protected string | $tablePrefix | Префикс таблиц для соединения. | из Connection |
| protected array | $config | Параметры конфигурации соединения с базой данных. | из Connection |
| protected callable | $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 DatabaseTransactionsManager | $transactionsManager | Экземпляр менеджера транзакций. | из Connection |
| protected bool | $recordsModified | Указывает, были ли внесены изменения в базу данных. | из Connection |
| protected bool | $readOnWriteConnection | Указывает, должно ли соединение использовать соединение PDO "write". | из Connection |
| protected array | $queryLog | Все запросы, выполненные к соединению. | из Connection |
| protected bool | $loggingQueries | Указывает, регистрируются ли запросы. | из Connection |
| protected bool | $pretending | Указывает, находится ли соединение в режиме "сухого запуска". | из Connection |
| protected array | $beforeExecutingCallbacks | Все колбэки, которые должны быть вызваны перед выполнением запроса. | из Connection |
| protected Connection | $doctrineConnection | Экземпляр подключения Doctrine. | из Connection |
| protected array | $doctrineTypeMappings | Сопоставления типов, которые должны быть зарегистрированы с новыми подключениями Doctrine. | из Connection |
| static protected array | $resolvers | Резолверы соединения. | из Connection |
Методы
| bool | causedByConcurrencyError(Throwable $e)
Определить, вызвало ли данное исключение ошибку конкурентного доступа, такую как тупик или сбой сериализации. | из DetectsConcurrencyErrors |
| bool | causedByLostConnection(Throwable $e)
Определить, вызвало ли данное исключение потерю соединения. | из DetectsLostConnections |
| mixed | transaction(Closure $callback, int $attempts = 1)
Выполнить замыкание в рамках транзакции. | из ManagesTransactions |
| void | handleTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при выполнении транзакционного оператора. | из ManagesTransactions |
| void | beginTransaction()
Начать новую базу данных транзакции. | из ManagesTransactions |
| void | createTransaction()
Создать транзакцию в базе данных. | из ManagesTransactions |
| void | createSavepoint()
Создать точку сохранения в базе данных. | из ManagesTransactions |
| void | handleBeginTransactionException(Throwable $e)
Обработать исключение при начале транзакции. | из ManagesTransactions |
| void | commit()
Подтвердить активную базу данных транзакцию. | из ManagesTransactions |
| void | handleCommitTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts)
Обработать исключение, возникшее при подтверждении транзакции. | из ManagesTransactions |
| void | rollBack(int|null $toLevel = null)
Отменить активную базу данных транзакцию. | из ManagesTransactions |
| void | performRollBack(int $toLevel)
Выполнить откат в базе данных. | из ManagesTransactions |
| void | handleRollBackException(Throwable $e)
Обработать исключение от отката. | из ManagesTransactions |
| int | transactionLevel()
Получить количество активных транзакций. | из ManagesTransactions |
| void | afterCommit(callable $callback)
Выполнить обратный вызов после подтверждения транзакции. | из ManagesTransactions |
| void | __construct(PDO|Closure $pdo, string $database = '', string $tablePrefix = '', array $config = [])
Создать новый экземпляр подключения к базе данных. | из Connection |
| void | useDefaultQueryGrammar()
Установить синтаксический анализатор запросов по умолчанию. | из Connection |
| Grammar | getDefaultQueryGrammar()
Получить экземпляр синтаксического анализатора запросов по умолчанию. | |
| void | useDefaultSchemaGrammar()
Установить грамматику схемы по умолчанию. | из Connection |
| Grammar | getDefaultSchemaGrammar()
Получить экземпляр грамматики схемы по умолчанию. | |
| void | useDefaultPostProcessor()
Установить обработчик запросов по умолчанию. | из Connection |
| Processor | getDefaultPostProcessor()
Получить экземпляр обработчика по умолчанию. | |
| Builder | getSchemaBuilder()
Получить экземпляр конструктора схемы для подключения. | |
| Builder | table(Closure|Builder|string $table, string|null $as = null)
Начать создание запроса к таблице базы данных. | из Connection |
| Builder | query()
Получить новый экземпляр конструктора запросов. | из Connection |
| mixed | selectOne(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить оператор select и вернуть один результат. | из Connection |
| array | selectFromWriteConnection(string $query, array $bindings = [])
Выполнить оператор select в базе данных. | из Connection |
| array | select(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить оператор select в базе данных. | из Connection |
| Generator | cursor(string $query, array $bindings = [], bool $useReadPdo = true)
Выполнить запрос SELECT к базе данных и вернуть генератор. | from Connection |
| PDOStatement | prepared(PDOStatement $statement)
Настроить подготовленное выражение PDO. | 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-запрос и вернуть булевый результат. | 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 |
| $this | beforeExecuting(Closure $callback)
Зарегистрировать обработчик, который будет выполнен непосредственно перед выполнением запроса к базе данных. | 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)
Получить новое выражение для сырого запроса. | from Connection |
| bool | hasModifiedRecords()
Определить, модифицировало ли соединение с базой данных какие-либо записи. | from Connection |
| void | recordsHaveBeenModified(bool $value = true)
Указать, были ли изменены какие-либо записи. | from Connection |
| $this | setRecordModificationState(bool $value)
Установить состояние изменения записи. | из Connection |
| void | forgetRecordModificationState()
Сбросить состояние изменения записи. | из Connection |
| $this | useWriteConnectionWhenReading(bool $value = true)
Указать, что соединение должно использовать запись PDO для чтения. | из Connection |
| bool | isDoctrineAvailable()
Доступен ли Doctrine? | из Connection |
| Column | getDoctrineColumn(string $table, string $column)
Получить экземпляр Doctrine Schema Column. | из Connection |
| AbstractSchemaManager | getDoctrineSchemaManager()
Получить менеджер схемы Doctrine DBAL для соединения. | из Connection |
| Connection | getDoctrineConnection()
Получить экземпляр подключения к базе данных Doctrine DBAL. | из Connection |
| void | registerDoctrineType(string $class, string $name, string $type)
Зарегистрировать пользовательский тип сопоставления Doctrine. | из Connection |
| PDO | getPdo()
Получить текущее соединение PDO. | из Connection |
| PDO|Closure|null | getRawPdo()
Получить текущий параметр соединения PDO без выполнения логики повторного подключения. | из Connection |
| PDO | getReadPdo()
Получить текущее соединение PDO, используемое для чтения. | из Connection |
| PDO|Closure|null | getRawReadPdo()
Получить текущий параметр чтения PDO без выполнения любой логики повторного подключения. | из Connection |
| $this | setPdo(PDO|Closure|null $pdo)
Установить соединение PDO. | из Connection |
| $this | setReadPdo(PDO|Closure|null $pdo)
Установить соединение PDO, используемое для чтения. | из Connection |
| $this | setReconnector(callable $reconnector)
Установить экземпляр повторного подключения к соединению. | из Connection |
| string|null | getName()
Получить имя подключения к базе данных. | из Connection |
| string|null | getNameWithReadWriteType()
Получить полное имя подключения к базе данных. | из Connection |
| mixed | getConfig(string|null $option = null)
Получить опцию из конфигурации. | из Connection |
| string | getDriverName()
Получить имя драйвера PDO. | из Connection |
| Grammar | getQueryGrammar()
Получить используемую грамматику запроса. | из Connection |
| $this | setQueryGrammar(Grammar $grammar)
Установить используемую грамматику запроса. | из Connection |
| Grammar | getSchemaGrammar()
Получить используемую грамматику схемы. | из Connection |
| $this | setSchemaGrammar(Grammar $grammar)
Установить используемую грамматику схемы. | из Connection |
| Processor | getPostProcessor()
Получить используемый обработчик запросов. | из Connection |
| $this | setPostProcessor(Processor $processor)
Установить используемый обработчик запросов. | из Connection |
| Dispatcher | getEventDispatcher()
Получить используемый диспетчер событий. | из Connection |
| $this | setEventDispatcher(Dispatcher $events)
Установить экземпляр диспетчера событий. | из Connection |
| void | unsetEventDispatcher()
Удалить диспетчер событий для этого подключения. | из Connection |
| $this | setTransactionManager(DatabaseTransactionsManager $manager)
Установить экземпляр менеджера транзакций для соединения. | из Connection |
| void | unsetTransactionManager()
Удалить менеджер транзакций для этого соединения. | из Connection |
| bool | pretending()
Определить, находится ли соединение в режиме "сухого прогона". | из Connection |
| array | getQueryLog()
Получить журнал запросов соединения. | из Connection |
| void | flushQueryLog()
Очистить журнал запросов. | из Connection |
| void | enableQueryLog()
Включить журнал запросов для соединения. | из Connection |
| void | disableQueryLog()
Выключить журнал запросов для соединения. | из Connection |
| bool | logging()
Определить, ведется ли регистрация запросов. | из Connection |
| string | getDatabaseName()
Получить имя подключенной базы данных. | из Connection |
| $this | setDatabaseName(string $database)
Установить имя подключенной базы данных. | из Connection |
| $this | setReadWriteType(string|null $readWriteType)
Установить тип чтения/записи соединения. | из Connection |
| string | getTablePrefix()
Получить префикс таблицы для соединения. | из Connection |
| $this | setTablePrefix(string $prefix)
Установить префикс таблицы, используемый соединением. | из Connection |
| Grammar | withTablePrefix(Grammar $grammar)
Установить префикс таблицы и вернуть грамматику. | из Connection |
| static void | resolverFor(string $driver, Closure $callback)
Зарегистрировать решатель соединений. | из Connection |
| static mixed | getResolver(string $driver)
Получить решатель соединений для указанного драйвера. | из Connection |
| PostgresSchemaState | getSchemaState(Filesystem $files = null, callable $processFactory = null)
Получить состояние схемы для соединения. | |
| Driver|PostgresDriver | getDoctrineDriver()
Получить драйвер Doctrine DBAL. |
Подробности
protected bool causedByConcurrencyError(Throwable $e)
Определить, была ли данная исключительная ситуация вызвана ошибкой конкурентного выполнения, такой как тупик или ошибка сериализации.
protected bool causedByLostConnection(Throwable $e)
Определить, была ли данная исключительная ситуация вызвана потерей соединения.
mixed transaction(Closure $callback, int $attempts = 1)
Выполнить замыкание в рамках транзакции.
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 afterCommit(callable $callback)
Выполнить обратный вызов после завершения транзакции.
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 = [])
Выполнить оператор DELETE в базе данных.
bool statement(string $query, array $bindings = [])
Выполнить SQL оператор и вернуть булевый результат.
int affectingStatement(string $query, array $bindings = [])
Выполнить SQL оператор и получить количество изменённых строк.
bool unprepared(string $query)
Выполнить сырой, неподготовленный запрос к подключению 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.
$this beforeExecuting(Closure $callback)
Зарегистрировать обработчик, который будет запущен непосредственно перед выполнением запроса к базе данных.
void listen(Closure $callback)
Зарегистрировать слушателя запросов к базе данных с подключением.
protected array|null fireConnectionEvent(string $event)
Вызвать событие для данного подключения.
protected void event(mixed $event)
Вызвать заданное событие, если это возможно.
Expression raw(mixed $value)
Получить новое выражение сырого запроса.
bool hasModifiedRecords()
Определить, модифицировал ли объект подключения базы данных какие-либо записи.
void recordsHaveBeenModified(bool $value = true)
Указать, были ли изменены какие-либо записи.
$this setRecordModificationState(bool $value)
Установить состояние изменения записи.
void forgetRecordModificationState()
Сбросить состояние изменения записи.
$this useWriteConnectionWhenReading(bool $value = true)
Указать, что подключение должно использовать подключение PDO для записи для чтения.
bool isDoctrineAvailable()
Доступен ли Doctrine?
Столбец getDoctrineColumn(string $table, string $column)
Получить экземпляр столбца Doctrine Schema Column.
AbstractSchemaManager getDoctrineSchemaManager()
Получить менеджер схемы Doctrine DBAL для соединения.
Соединение getDoctrineConnection()
Получить экземпляр подключения к базе данных Doctrine DBAL.
void registerDoctrineType(string $class, string $name, string $type)
Зарегистрировать пользовательский тип сопоставления Doctrine.
PDO getPdo()
Получить текущее подключение PDO.
PDO|Closure|null getRawPdo()
Получить текущий параметр подключения PDO без выполнения логики повторного подключения.
PDO getReadPdo()
Получить текущее подключение PDO, используемое для чтения.
PDO|Closure|null getRawReadPdo()
Получить текущий параметр подключения PDO для чтения без выполнения логики повторного подключения.
$this setReconnector(callable $reconnector)
Установить экземпляр повторного подключения для соединения.
string|null getName()
Получить имя подключения к базе данных.
string|null getNameWithReadWriteType()
Получить полное имя подключения к базе данных.
mixed getConfig(string|null $option = null)
Получить параметр из параметров конфигурации.
string getDriverName()
Получить имя драйвера PDO.
Grammar getQueryGrammar()
Получить синтаксический анализатор запросов, используемый подключением.
$this setQueryGrammar(Grammar $grammar)
Установить синтаксический анализатор запросов, используемый подключением.
Grammar getSchemaGrammar()
Получить синтаксический анализатор схемы, используемый подключением.
$this setSchemaGrammar(Grammar $grammar)
Установить синтаксический анализатор схемы, используемый подключением.
Processor getPostProcessor()
Получить обработчик запросов, используемый подключением.
$this setPostProcessor(Processor $processor)
Установить обработчик запросов, используемый соединением.
Dispatcher getEventDispatcher()
Получить диспетчер событий, используемый соединением.
$this setEventDispatcher(Dispatcher $events)
Установить экземпляр диспетчера событий для подключения.
void unsetEventDispatcher()
Удалить диспетчер событий для этого подключения.
$this setTransactionManager(DatabaseTransactionsManager $manager)
Установить экземпляр менеджера транзакций для подключения.
void unsetTransactionManager()
Удалить менеджер транзакций для этого подключения.
bool pretending()
Определить, находится ли подключение в режиме «сухого запуска».
array getQueryLog()
Получить журнал запросов подключения.
void flushQueryLog()
Очистить журнал запросов.
void enableQueryLog()
Включить журнал запросов для подключения.
void disableQueryLog()
Отключить журнал запросов для подключения.
bool logging()
Определить, ведём ли мы логирование запросов.
string getDatabaseName()
Получить имя подключенной базы данных.
$this setDatabaseName(string $database)
Установить имя подключенной базы данных.
$this setReadWriteType(string|null $readWriteType)
Установить тип чтения/записи подключения.
string getTablePrefix()
Получить префикс таблицы для подключения.
$this setTablePrefix(string $prefix)
Установить префикс таблицы, используемый подключением.
static void resolverFor(string $driver, Closure $callback)
Зарегистрировать решатель подключений.
static mixed getResolver(string $driver)
Получить решатель подключений для данного драйвера.
PostgresSchemaState getSchemaState(Filesystem $files = null, callable $processFactory = null)
Получить состояние схемы для подключения.
protected Driver|PostgresDriver getDoctrineDriver()
Получить драйвер Doctrine DBAL.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/8.x/Illuminate/Database/PostgresConnection.html