classPgSqlCopySupport

packages/ztd-query-postgres/src/Connection/Copy/PgSqlCopySupport.php:17

final class PgSqlCopySupport
    implements CopySupport

Copy support for PostgreSQL queries.

Methods§

public function tableName(string $relation): string

source §

Resolves the unqualified table name selected by the COPY arguments.

Parameters

$relation string

Returns

string

Test cases 1

PgSqlCopySupportTest::testTableNameResolvesTheFinalQualifiedComponent calls

Calls 3

method-call TargetColumns::relationParts() line 24
new TargetColumns line 24
function-call count line 26

public function target(
    string $relation,
    ?string $fields,
    TableDefinition $definition,
): CopyTarget

source §

Resolves COPY relation and column arguments against the reflected schema.

Parameters

`$relation`	`string`
`$fields`	`?string`
`$definition`	`TableDefinition`

Returns

CopyTarget

Throws

ValueError

Test cases 2

Calls 5

method-call TargetColumns::columns() line 35
new TargetColumns line 35
new ValueError line 37
new CopyTarget line 40
method-call TargetColumns::relationParts() line 40

public function selectSql(CopyTarget $target): string

source §

Builds the SELECT statement that supplies COPY output rows.

Parameters

$target CopyTarget

Returns

string

Test cases 2

Calls 4

function-call sprintf line 48
method-call TargetSql::columnListSql() line 50
new TargetSql line 50
method-call TargetSql::relationSql() line 51

public function insertSql(CopyTarget $target, int $rowCount, bool $overrideSystemValue): string

source §

Builds the INSERT statement for one decoded COPY input row.

Parameters

`$target`	`CopyTarget`
`$rowCount`	`int`
`$overrideSystemValue`	`bool`

Returns

string

Throws

ValueError

Test cases 1

PgSqlCopySupportTest::testInsertSqlNumbersEveryRowAndPreservesIdentityOverride calls

Calls 6

new ValueError line 62
function-call implode line 72
function-call sprintf line 75
method-call TargetSql::relationSql() line 77
new TargetSql line 77
method-call TargetSql::columnListSql() line 78

public function isCopyStatement(string $sql): bool

source §

Recognizes PostgreSQL COPY statements.

Parameters

$sql string

Returns

bool

Test cases 1

PgSqlCopySupportTest::testIsCopyStatementReadsTheFirstSignificantKeyword calls

Calls 2

static-call SqlTokenStream::tokenize() line 89
static-call PgSqlLexerProfile::create() line 89

public function encodeRow(list<mixed> $values, string $separator, string $nullAs): string

source §

Parameters

`$values`	`list<mixed>`
`$separator`	`string`
`$nullAs`	`string`

Returns

string

Throws

ValueError

Test cases 2

Calls 14

method-call TextFields::validateSeparator() line 98
new TextFields line 98
function-call is_string line 106
function-call is_int line 106
function-call is_float line 106
function-call is_bool line 108
function-call is_resource line 110
function-call stream_get_contents line 111
new ValueError line 113
function-call bin2hex line 115
function-call sprintf line 117
function-call get_debug_type line 117
method-call TextFields::escape() line 119
function-call implode line 122

public function decodeRow(string $row, string $separator, string $nullAs): list<string|null>

source §

Parameters

`$row`	`string`
`$separator`	`string`
`$nullAs`	`string`

Returns

list<string|null>

Throws

ValueError

Test cases 4

Calls 7

method-call TextFields::validateSeparator() line 131
new TextFields line 131
function-call str_ends_with line 132
function-call substr line 133
function-call str_contains line 137
new ValueError line 138
method-call TextFields::decodeFields() line 144

Test cases 12§

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

Dedicated tests 11

Other tests reaching this symbol 1

PgSqlSessionFactoryTest::testCreateReturnsSession calls

Relations§

Instantiated in 1

new ZtdQuery\Platform\Postgres\PgSqlSessionFactory::create() packages/ztd-query-postgres/src/PgSqlSessionFactory.php:85