class Connection implements ConnectionInterface (View source)
DetectsConcurrencyErrors | |
DetectsLostConnections | |
ManagesTransactions |
protected PDO|Closure | $pdo | The active PDO connection. | |
protected PDO|Closure | $readPdo | The active PDO connection used for reads. | |
protected string | $database | The name of the connected database. | |
protected string | $tablePrefix | The table prefix for the connection. | |
protected array | $config | The database connection configuration options. | |
protected callable | $reconnector | The reconnector instance for the connection. | |
protected Grammar | $queryGrammar | The query grammar implementation. | |
protected Grammar | $schemaGrammar | The schema grammar implementation. | |
protected Processor | $postProcessor | The query post processor implementation. | |
protected Dispatcher | $events | The event dispatcher instance. | |
protected int | $fetchMode | The default fetch mode of the connection. | |
protected int | $transactions | The number of active transactions. | |
protected int | $recordsModified | Indicates if changes have been made to the database. | |
protected array | $queryLog | All of the queries run against the connection. | |
protected bool | $loggingQueries | Indicates whether queries are being logged. | |
protected bool | $pretending | Indicates if the connection is in a "dry run". | |
protected Connection | $doctrineConnection | The instance of Doctrine connection. | |
static protected array | $resolvers | The connection resolvers. |
bool | causedByConcurrencyError(Throwable $e) Determine if the given exception was caused by a concurrency error such as a deadlock or serialization failure. | from DetectsConcurrencyErrors |
bool | causedByLostConnection(Throwable $e) Determine if the given exception was caused by a lost connection. | from DetectsLostConnections |
mixed | transaction(Closure $callback, int $attempts = 1) Execute a Closure within a transaction. | from ManagesTransactions |
void | handleTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts) Handle an exception encountered when running a transacted statement. | from ManagesTransactions |
void | beginTransaction() Start a new database transaction. | from ManagesTransactions |
void | createTransaction() Create a transaction within the database. | from ManagesTransactions |
void | createSavepoint() Create a save point within the database. | from ManagesTransactions |
void | handleBeginTransactionException(Throwable $e) Handle an exception from a transaction beginning. | from ManagesTransactions |
void | commit() Commit the active database transaction. | from ManagesTransactions |
void | handleCommitTransactionException(Throwable $e, int $currentAttempt, int $maxAttempts) Handle an exception encountered when committing a transaction. | from ManagesTransactions |
void | rollBack(int|null $toLevel = null) Rollback the active database transaction. | from ManagesTransactions |
void | performRollBack(int $toLevel) Perform a rollback within the database. | from ManagesTransactions |
void | handleRollBackException(Throwable $e) Handle an exception from a rollback. | from ManagesTransactions |
int | transactionLevel() Get the number of active transactions. | from ManagesTransactions |
void | __construct(PDO|Closure $pdo, string $database = '', string $tablePrefix = '', array $config = []) Create a new database connection instance. | |
void | useDefaultQueryGrammar() Set the query grammar to the default implementation. | |
Grammar | getDefaultQueryGrammar() Get the default query grammar instance. | |
void | useDefaultSchemaGrammar() Set the schema grammar to the default implementation. | |
Grammar | getDefaultSchemaGrammar() Get the default schema grammar instance. | |
void | useDefaultPostProcessor() Set the query post processor to the default implementation. | |
Processor | getDefaultPostProcessor() Get the default post processor instance. | |
Builder | getSchemaBuilder() Get a schema builder instance for the connection. | |
Builder | table(Closure|Builder|string $table, string|null $as = null) Begin a fluent query against a database table. | |
Builder | query() Get a new query builder instance. | |
mixed | selectOne(string $query, array $bindings = [], bool $useReadPdo = true) Run a select statement and return a single result. | |
array | selectFromWriteConnection(string $query, array $bindings = []) Run a select statement against the database. | |
array | select(string $query, array $bindings = [], bool $useReadPdo = true) Run a select statement against the database. | |
Generator | cursor(string $query, array $bindings = [], bool $useReadPdo = true) Run a select statement against the database and returns a generator. | |
PDOStatement | prepared(PDOStatement $statement) Configure the PDO prepared statement. | |
PDO | getPdoForSelect(bool $useReadPdo = true) Get the PDO connection to use for a select query. | |
bool | insert(string $query, array $bindings = []) Run an insert statement against the database. | |
int | update(string $query, array $bindings = []) Run an update statement against the database. | |
int | delete(string $query, array $bindings = []) Run a delete statement against the database. | |
bool | statement(string $query, array $bindings = []) Execute an SQL statement and return the boolean result. | |
int | affectingStatement(string $query, array $bindings = []) Run an SQL statement and get the number of rows affected. | |
bool | unprepared(string $query) Run a raw, unprepared query against the PDO connection. | |
array | pretend(Closure $callback) Execute the given callback in "dry run" mode. | |
array | withFreshQueryLog(Closure $callback) Execute the given callback in "dry run" mode. | |
void | bindValues(PDOStatement $statement, array $bindings) Bind values to their parameters in the given statement. | |
array | prepareBindings(array $bindings) Prepare the query bindings for execution. | |
mixed | run(string $query, array $bindings, Closure $callback) Run a SQL statement and log its execution context. | |
mixed | runQueryCallback(string $query, array $bindings, Closure $callback) Run a SQL statement. | |
void | logQuery(string $query, array $bindings, float|null $time = null) Log a query in the connection's query log. | |
float | getElapsedTime(int $start) Get the elapsed time since a given starting point. | |
mixed | handleQueryException(QueryException $e, string $query, array $bindings, Closure $callback) Handle a query exception. | |
mixed | tryAgainIfCausedByLostConnection(QueryException $e, string $query, array $bindings, Closure $callback) Handle a query exception that occurred during query execution. | |
void | reconnect() Reconnect to the database. | |
void | reconnectIfMissingConnection() Reconnect to the database if a PDO connection is missing. | |
void | disconnect() Disconnect from the underlying PDO connection. | |
void | listen(Closure $callback) Register a database query listener with the connection. | |
array|null | fireConnectionEvent(string $event) Fire an event for this connection. | |
void | event(mixed $event) Fire the given event if possible. | |
Expression | raw(mixed $value) Get a new raw query expression. | |
void | recordsHaveBeenModified(bool $value = true) Indicate if any records have been modified. | |
bool | isDoctrineAvailable() Is Doctrine available? | |
Column | getDoctrineColumn(string $table, string $column) Get a Doctrine Schema Column instance. | |
AbstractSchemaManager | getDoctrineSchemaManager() Get the Doctrine DBAL schema manager for the connection. | |
Connection | getDoctrineConnection() Get the Doctrine DBAL database connection instance. | |
PDO | getPdo() Get the current PDO connection. | |
PDO|Closure|null | getRawPdo() Get the current PDO connection parameter without executing any reconnect logic. | |
PDO | getReadPdo() Get the current PDO connection used for reading. | |
PDO|Closure|null | getRawReadPdo() Get the current read PDO connection parameter without executing any reconnect logic. | |
$this | setPdo(PDO|Closure|null $pdo) Set the PDO connection. | |
$this | setReadPdo(PDO|Closure|null $pdo) Set the PDO connection used for reading. | |
$this | setReconnector(callable $reconnector) Set the reconnect instance on the connection. | |
string|null | getName() Get the database connection name. | |
mixed | getConfig(string|null $option = null) Get an option from the configuration options. | |
string | getDriverName() Get the PDO driver name. | |
Grammar | getQueryGrammar() Get the query grammar used by the connection. | |
$this | setQueryGrammar(Grammar $grammar) Set the query grammar used by the connection. | |
Grammar | getSchemaGrammar() Get the schema grammar used by the connection. | |
$this | setSchemaGrammar(Grammar $grammar) Set the schema grammar used by the connection. | |
Processor | getPostProcessor() Get the query post processor used by the connection. | |
$this | setPostProcessor(Processor $processor) Set the query post processor used by the connection. | |
Dispatcher | getEventDispatcher() Get the event dispatcher used by the connection. | |
$this | setEventDispatcher(Dispatcher $events) Set the event dispatcher instance on the connection. | |
void | unsetEventDispatcher() Unset the event dispatcher for this connection. | |
bool | pretending() Determine if the connection is in a "dry run". | |
array | getQueryLog() Get the connection query log. | |
void | flushQueryLog() Clear the query log. | |
void | enableQueryLog() Enable the query log on the connection. | |
void | disableQueryLog() Disable the query log on the connection. | |
bool | logging() Determine whether we're logging queries. | |
string | getDatabaseName() Get the name of the connected database. | |
$this | setDatabaseName(string $database) Set the name of the connected database. | |
string | getTablePrefix() Get the table prefix for the connection. | |
$this | setTablePrefix(string $prefix) Set the table prefix in use by the connection. | |
Grammar | withTablePrefix(Grammar $grammar) Set the table prefix and return the grammar. | |
static void | resolverFor(string $driver, Closure $callback) Register a connection resolver. | |
static mixed | getResolver(string $driver) Get the connection resolver for the given driver. |
Determine if the given exception was caused by a concurrency error such as a deadlock or serialization failure.
Determine if the given exception was caused by a lost connection.
Execute a Closure within a transaction.
Handle an exception encountered when running a transacted statement.
Start a new database transaction.
Create a transaction within the database.
Create a save point within the database.
Handle an exception from a transaction beginning.
Commit the active database transaction.
Handle an exception encountered when committing a transaction.
Rollback the active database transaction.
Perform a rollback within the database.
Handle an exception from a rollback.
Get the number of active transactions.
Create a new database connection instance.
Set the query grammar to the default implementation.
Get the default query grammar instance.
Set the schema grammar to the default implementation.
Get the default schema grammar instance.
Set the query post processor to the default implementation.
Get the default post processor instance.
Get a schema builder instance for the connection.
Begin a fluent query against a database table.
Get a new query builder instance.
Run a select statement and return a single result.
Run a select statement against the database.
Run a select statement against the database.
Run a select statement against the database and returns a generator.
Configure the PDO prepared statement.
Get the PDO connection to use for a select query.
Run an insert statement against the database.
Run an update statement against the database.
Run a delete statement against the database.
Execute an SQL statement and return the boolean result.
Run an SQL statement and get the number of rows affected.
Run a raw, unprepared query against the PDO connection.
Execute the given callback in "dry run" mode.
Execute the given callback in "dry run" mode.
Bind values to their parameters in the given statement.
Prepare the query bindings for execution.
Run a SQL statement and log its execution context.
Run a SQL statement.
Log a query in the connection's query log.
Get the elapsed time since a given starting point.
Handle a query exception.
Handle a query exception that occurred during query execution.
Reconnect to the database.
Reconnect to the database if a PDO connection is missing.
Disconnect from the underlying PDO connection.
Register a database query listener with the connection.
Fire an event for this connection.
Fire the given event if possible.
Get a new raw query expression.
Indicate if any records have been modified.
Is Doctrine available?
Get a Doctrine Schema Column instance.
Get the Doctrine DBAL schema manager for the connection.
Get the Doctrine DBAL database connection instance.
Get the current PDO connection.
Get the current PDO connection parameter without executing any reconnect logic.
Get the current PDO connection used for reading.
Get the current read PDO connection parameter without executing any reconnect logic.
Set the reconnect instance on the connection.
Get the database connection name.
Get an option from the configuration options.
Get the PDO driver name.
Get the query grammar used by the connection.
Set the query grammar used by the connection.
Get the schema grammar used by the connection.
Set the schema grammar used by the connection.
Get the query post processor used by the connection.
Set the query post processor used by the connection.
Get the event dispatcher used by the connection.
Set the event dispatcher instance on the connection.
Unset the event dispatcher for this connection.
Determine if the connection is in a "dry run".
Get the connection query log.
Clear the query log.
Enable the query log on the connection.
Disable the query log on the connection.
Determine whether we're logging queries.
Get the name of the connected database.
Set the name of the connected database.
Get the table prefix for the connection.
Set the table prefix in use by the connection.
Register a connection resolver.
Get the connection resolver for the given driver.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/8.x/Illuminate/Database/Connection.html