classConnectionExecution

packages/ztd-query-pdo-adapter/src/Session/ConnectionExecution.php:23

final class ConnectionExecution

Restricted visibility: declared "@visibility ZtdQuery\Adapter\Pdo". Code outside that scope must not name this declaration.

Coordinates native connection execution with its shadow session.

Methods§

public function __construct(
    private PDO $pdo,
    ?ZtdConfig $config = null,
    ?Platform $platform = null,
)

source §

Create a shadow session for the supplied native connection.

Parameters

`$pdo`	`PDO`
`$config`	`?ZtdConfig`
`$platform`	`?Platform`

Calls 5

method-call DriverPlatform::forConnection() line 32
new DriverPlatform line 32
new QueryExecutor line 33
new PdoConnection line 33
static-call ZtdConfig::default() line 33

public function native(): PDO

source §

Return the wrapped native connection.

Returns

PDO

Test cases 1

ConnectionExecutionTest::testNativeTransactionStatementsKeepTheSessionSynchronized calls

Called from 6

public function executor(): QueryExecutor

source §

Return the core executor shared by all statements on this connection.

Returns

QueryExecutor

Test cases 4

Called from 3

public function prepare<TOption>(
    string $query,
    array<TOption> $options,
    Closure(PDOStatement, QueryExecutor, RewritePlan, PreparedQuery, int): PDOStatement $wrap,
): PDOStatement|false

source §

Prepare native SQL and let the facade wrap the resulting execution plan.

Parameters

`$query`	`string`
`$options`	`array<TOption>`	Opaque options forwarded to the native driver.
`$wrap`	`Closure(PDOStatement, QueryExecutor, RewritePlan, PreparedQuery, int): PDOStatement`

Returns

PDOStatement|false

Throws

ZtdPdoException When rewriting cannot prepare the statement.

Test cases 1

ConnectionExecutionTest::testPreparePreservesOpaqueNativeDriverOptions calls

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::prepare() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:168

Calls 11

method-call QueryExecutor::session() line 62
method-call PDO::prepare() line 63
new PreparedQuery line 68
method-call PreparedQuery::rewrite() line 69
method-call QueryExecutor::platform() line 70
method-call PreparedQuery::prepare() line 71
new ZtdPdoException line 73
method-call PDO::getAttribute() line 76
class-const PDO::ATTR_DEFAULT_FETCH_MODE() line 76
function-call is_int line 83
class-const PDO::FETCH_BOTH() line 83

public function query<TFetchArgument>(
    string $query,
    ?int $fetchMode,
    array<TFetchArgument> $fetchModeArgs,
    Closure(string): PDOStatement|false $prepare,
): PDOStatement|false

source §

Execute a query through the facade's preparation dispatch.

Parameters

`$query`	`string`
`$fetchMode`	`?int`
`$fetchModeArgs`	`array<TFetchArgument>`	Native fetch options.
`$prepare`	`Closure(string): PDOStatement\|false`

Returns

PDOStatement|false

Test cases 1

ConnectionExecutionTest::testQueryPreservesPreparationDispatchAndFetchArguments calls

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::query() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:196

Calls 3

method-call QueryExecutor::session() line 96
method-call QueryExecutor::transactionStatement() line 97
method-call PDO::query() line 99

public function exec(string $statement, Closure(string): int|false $execute): int|false

source §

Execute statements and synchronize native transaction and shadow state.

Parameters

`$statement`	`string`
`$execute`	`Closure(string): int\|false`	Preserve facade dispatch for each batch statement.

Returns

int|false

Throws

ZtdPdoException When shadow execution rejects the SQL.

Test cases 2

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::exec() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:221

Calls 7

method-call QueryExecutor::session() line 132
method-call PDO::exec() line 133
method-call QueryExecutor::splitStatements() line 136
function-call count line 137
method-call QueryExecutor::transactionStatement() line 150
method-call QueryExecutor::execStatement() line 161
new ZtdPdoException line 163

public function beginTransaction(): bool

source §

Begin the native transaction before opening a shadow transaction.

Returns

bool

Test cases 4

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::beginTransaction() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:268

Calls 2

method-call PDO::beginTransaction() line 172
method-call QueryExecutor::session() line 174

public function commit(): bool

source §

Commit the shadow transaction after the native commit succeeds.

Returns

bool

Test cases 2

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::commit() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:287

Calls 2

method-call PDO::commit() line 185
method-call QueryExecutor::session() line 187

public function rollBack(): bool

source §

Roll back shadow state after the native rollback succeeds.

Returns

bool

Test cases 2

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::rollBack() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:305

Calls 2

method-call PDO::rollBack() line 198
method-call QueryExecutor::session() line 200

public function lastInsertId(?string $name = null): string|false

source §

Prefer the shadow-generated key when ZTD handles an unnamed sequence.

Parameters

$name ?string

Returns

string|false

Test cases 1

ConnectionExecutionTest::testLastInsertIdChoosesShadowOrNativeState calls

Called from 1

method-call ZtdQuery\Adapter\Pdo\ZtdPdo::lastInsertId() packages/ztd-query-pdo-adapter/src/ZtdPdo.php:337

Calls 2

method-call QueryExecutor::session() line 211
method-call PDO::lastInsertId() line 218

Private surface 2§

Implementation details, listed for orientation only.

private QueryExecutor $executor

private PDO $pdo

Test cases 18§

Test cases that cover or call this symbol, from the coverage report and from the analyzed test sources.

Dedicated tests 9

Other tests reaching this symbol 9

Relations§

Instantiated in 2

Method calls 16

Type declarations 1

type ZtdQuery\Adapter\Pdo\ZtdPdo packages/ztd-query-pdo-adapter/src/ZtdPdo.php:42