classRowMutationResolver

packages/ztd-query-postgres/src/Shadow/Mutation/Row/RowMutationResolver.php:29

final class RowMutationResolver

Restricted visibility: declared "@visibility root". Code outside that scope must not name this declaration.

Dml resolver operations for PostgreSQL mutation.

Methods§

public function __construct(
    PgSqlParser $parser,
    TableDefinitionRegistry $registry,
    ShadowStore $shadowStore,
)

source §

Supplies the dependencies used by this RowMutationResolver.

Parameters

`$parser`	`PgSqlParser`
`$registry`	`TableDefinitionRegistry`
`$shadowStore`	`ShadowStore`

public function resolveInsert(string $sql): ShadowMutation

source §

Resolve insert.

Parameters

$sql string

Returns

ShadowMutation

Throws

UnsupportedSqlException

Test cases 2

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\PgSqlMutationResolver::resolve() packages/ztd-query-postgres/src/Shadow/PgSqlMutationResolver.php:53

Calls 13

method-call PgSqlParser::extractInsertTable() line 51
new UnsupportedSqlException line 53
method-call TableDefinitionRegistry::get() line 56
method-call StorageTable::storageTable() line 58
new StorageTable line 58
method-call PgSqlParser::hasOnConflict() line 60
method-call PgSqlParser::extractOnConflictUpdateColumns() line 61
method-call PgSqlParser::extractOnConflictTarget() line 65
new PgSqlUpsertExpressionParser line 75
method-call RowMutationResolver::resolveUpsert() line 78
new InsertMutation line 81
method-call PgSqlUpsertExpressionParser::parse() line 87
method-call RowMutationResolver::resolvePlainInsert() line 92

public function resolvePlainInsert(
    string $sql,
    string $storageTable,
    list<string> $primaryKeys,
    ?TableDefinition $definition,
): ShadowMutation

source §

Preserve the reflected constraints when resolving an ordinary INSERT.

Parameters

`$sql`	`string`
`$storageTable`	`string`
`$primaryKeys`	`list<string>`
`$definition`	`?TableDefinition`

Returns

ShadowMutation

Test cases 1

RowMutationResolverTest::testResolvePlainInsertRejectsNullViolationsAtomically calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\Mutation\Row\RowMutationResolver::resolveInsert() packages/ztd-query-postgres/src/Shadow/Mutation/Row/RowMutationResolver.php:92

Calls 1

new InsertMutation line 102

public function resolveUpdate(string $sql): ShadowMutation

source §

Resolve update.

Parameters

$sql string

Returns

ShadowMutation

Throws

UnknownSchemaException

UnsupportedSqlException

Test cases 1

RowMutationResolverTest::testResolveUpdatePreservesTheTargetIdentity calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\PgSqlMutationResolver::resolve() packages/ztd-query-postgres/src/Shadow/PgSqlMutationResolver.php:54

Calls 10

method-call PgSqlParser::extractUpdateTable() line 120
new UnsupportedSqlException line 122
method-call TableDefinitionRegistry::get() line 125
method-call ShadowStore::state() line 126
class-const ShadowTableState::Initialized() line 126
new UnknownSchemaException line 127
method-call StorageTable::storageTable() line 130
new StorageTable line 130
method-call ShadowStore::ensure() line 131
new UpdateMutation line 134

public function resolveDelete(string $sql): ShadowMutation

source §

Resolve delete.

Parameters

$sql string

Returns

ShadowMutation

Throws

UnknownSchemaException

UnsupportedSqlException

Test cases 1

RowMutationResolverTest::testResolveDeleteMatchesThePrimaryKey calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\PgSqlMutationResolver::resolve() packages/ztd-query-postgres/src/Shadow/PgSqlMutationResolver.php:55

Calls 10

method-call PgSqlParser::extractDeleteTable() line 144
new UnsupportedSqlException line 146
method-call TableDefinitionRegistry::get() line 149
method-call ShadowStore::state() line 150
class-const ShadowTableState::Initialized() line 150
new UnknownSchemaException line 151
method-call StorageTable::storageTable() line 154
new StorageTable line 154
method-call ShadowStore::ensure() line 155
new DeleteMutation line 158

public function resolveMerge(string $sql): ShadowMutation

source §

Resolve merge.

Parameters

$sql string

Returns

ShadowMutation

Throws

UnknownSchemaException

Test cases 1

RowMutationResolverTest::testResolveMergeSynchronizesTheProjectedTarget calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\PgSqlMutationResolver::resolve() packages/ztd-query-postgres/src/Shadow/PgSqlMutationResolver.php:56

Calls 9

method-call PgSqlMergeParser::parse() line 167
new PgSqlMergeParser line 167
method-call TableDefinitionRegistry::get() line 168
method-call ShadowStore::state() line 170
class-const ShadowTableState::Initialized() line 170
new UnknownSchemaException line 172
new SynchronizeMutation line 175
method-call StorageTable::storageTable() line 176
new StorageTable line 176

public function resolveTruncate(string $sql): ShadowMutation

source §

Resolve truncate.

Parameters

$sql string

Returns

ShadowMutation

Throws

UnsupportedSqlException

Test cases 1

RowMutationResolverTest::testResolveTruncateIncludesEveryExplicitTarget calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\PgSqlMutationResolver::resolve() packages/ztd-query-postgres/src/Shadow/PgSqlMutationResolver.php:57

Calls 5

method-call PgSqlParser::extractTruncateTables() line 188
new UnsupportedSqlException line 190
function-call count line 192
new MultiTruncateMutation line 193
new TruncateMutation line 196

public function resolveUpsert(
    string $sql,
    string $tableName,
    string $storageTable,
    list<string> $primaryKeys,
    array{columns: list<string>, values: array<string, string>} $conflictInfo,
    ?CandidateKeySet $candidateKeys,
    ?string $conflictPredicate,
): ShadowMutation

source §

Resolves update expressions using database evaluation whenever a candidate key permits it.

Parameters

`$sql`	`string`
`$tableName`	`string`
`$storageTable`	`string`
`$primaryKeys`	`list<string>`
`$conflictInfo`	`array{columns: list<string>, values: array<string, string>}`
`$candidateKeys`	`?CandidateKeySet`
`$conflictPredicate`	`?string`

Returns

ShadowMutation

Throws

UnsupportedSqlException

Test cases 1

RowMutationResolverTest::testResolveUpsertEvaluatesAssignmentsWithoutNativeCandidateKeys calls

Called from 1

method-call ZtdQuery\Platform\Postgres\Shadow\Mutation\Row\RowMutationResolver::resolveInsert() packages/ztd-query-postgres/src/Shadow/Mutation/Row/RowMutationResolver.php:78

Calls 5

new PgSqlUpsertExpressionParser line 206
method-call PgSqlUpsertExpressionParser::parseIfSupported() line 215
method-call PgSqlUpsertExpressionParser::parse() line 216
method-call PgSqlParser::extractOnConflictUpdateWhere() line 218
new UpsertMutation line 220

Private surface 3§

Implementation details, listed for orientation only.

private PgSqlParser $parser

private TableDefinitionRegistry $registry

private ShadowStore $shadowStore

Test cases 12§

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

Dedicated tests 8

Other tests reaching this symbol 4

Relations§

Instantiated in 5

Method calls 5