Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
Total | |
0.00% |
0 / 1 |
|
0.00% |
0 / 3 |
CRAP | |
0.00% |
0 / 45 |
PgSqlCaster | |
0.00% |
0 / 1 |
|
0.00% |
0 / 3 |
240 | |
0.00% |
0 / 45 |
castLargeObject | |
0.00% |
0 / 1 |
2 | |
0.00% |
0 / 2 |
|||
castLink | |
0.00% |
0 / 1 |
30 | |
0.00% |
0 / 20 |
|||
castResult | |
0.00% |
0 / 1 |
90 | |
0.00% |
0 / 23 |
1 | <?php |
2 | |
3 | /* |
4 | * This file is part of the Symfony package. |
5 | * |
6 | * (c) Fabien Potencier <fabien@symfony.com> |
7 | * |
8 | * For the full copyright and license information, please view the LICENSE |
9 | * file that was distributed with this source code. |
10 | */ |
11 | |
12 | namespace Symfony\Component\VarDumper\Caster; |
13 | |
14 | use Symfony\Component\VarDumper\Cloner\Stub; |
15 | |
16 | /** |
17 | * Casts pqsql resources to array representation. |
18 | * |
19 | * @author Nicolas Grekas <p@tchwork.com> |
20 | * |
21 | * @final |
22 | */ |
23 | class PgSqlCaster |
24 | { |
25 | private static $paramCodes = [ |
26 | 'server_encoding', |
27 | 'client_encoding', |
28 | 'is_superuser', |
29 | 'session_authorization', |
30 | 'DateStyle', |
31 | 'TimeZone', |
32 | 'IntervalStyle', |
33 | 'integer_datetimes', |
34 | 'application_name', |
35 | 'standard_conforming_strings', |
36 | ]; |
37 | |
38 | private static $transactionStatus = [ |
39 | \PGSQL_TRANSACTION_IDLE => 'PGSQL_TRANSACTION_IDLE', |
40 | \PGSQL_TRANSACTION_ACTIVE => 'PGSQL_TRANSACTION_ACTIVE', |
41 | \PGSQL_TRANSACTION_INTRANS => 'PGSQL_TRANSACTION_INTRANS', |
42 | \PGSQL_TRANSACTION_INERROR => 'PGSQL_TRANSACTION_INERROR', |
43 | \PGSQL_TRANSACTION_UNKNOWN => 'PGSQL_TRANSACTION_UNKNOWN', |
44 | ]; |
45 | |
46 | private static $resultStatus = [ |
47 | \PGSQL_EMPTY_QUERY => 'PGSQL_EMPTY_QUERY', |
48 | \PGSQL_COMMAND_OK => 'PGSQL_COMMAND_OK', |
49 | \PGSQL_TUPLES_OK => 'PGSQL_TUPLES_OK', |
50 | \PGSQL_COPY_OUT => 'PGSQL_COPY_OUT', |
51 | \PGSQL_COPY_IN => 'PGSQL_COPY_IN', |
52 | \PGSQL_BAD_RESPONSE => 'PGSQL_BAD_RESPONSE', |
53 | \PGSQL_NONFATAL_ERROR => 'PGSQL_NONFATAL_ERROR', |
54 | \PGSQL_FATAL_ERROR => 'PGSQL_FATAL_ERROR', |
55 | ]; |
56 | |
57 | private static $diagCodes = [ |
58 | 'severity' => \PGSQL_DIAG_SEVERITY, |
59 | 'sqlstate' => \PGSQL_DIAG_SQLSTATE, |
60 | 'message' => \PGSQL_DIAG_MESSAGE_PRIMARY, |
61 | 'detail' => \PGSQL_DIAG_MESSAGE_DETAIL, |
62 | 'hint' => \PGSQL_DIAG_MESSAGE_HINT, |
63 | 'statement position' => \PGSQL_DIAG_STATEMENT_POSITION, |
64 | 'internal position' => \PGSQL_DIAG_INTERNAL_POSITION, |
65 | 'internal query' => \PGSQL_DIAG_INTERNAL_QUERY, |
66 | 'context' => \PGSQL_DIAG_CONTEXT, |
67 | 'file' => \PGSQL_DIAG_SOURCE_FILE, |
68 | 'line' => \PGSQL_DIAG_SOURCE_LINE, |
69 | 'function' => \PGSQL_DIAG_SOURCE_FUNCTION, |
70 | ]; |
71 | |
72 | public static function castLargeObject($lo, array $a, Stub $stub, bool $isNested) |
73 | { |
74 | $a['seek position'] = pg_lo_tell($lo); |
75 | |
76 | return $a; |
77 | } |
78 | |
79 | public static function castLink($link, array $a, Stub $stub, bool $isNested) |
80 | { |
81 | $a['status'] = pg_connection_status($link); |
82 | $a['status'] = new ConstStub(\PGSQL_CONNECTION_OK === $a['status'] ? 'PGSQL_CONNECTION_OK' : 'PGSQL_CONNECTION_BAD', $a['status']); |
83 | $a['busy'] = pg_connection_busy($link); |
84 | |
85 | $a['transaction'] = pg_transaction_status($link); |
86 | if (isset(self::$transactionStatus[$a['transaction']])) { |
87 | $a['transaction'] = new ConstStub(self::$transactionStatus[$a['transaction']], $a['transaction']); |
88 | } |
89 | |
90 | $a['pid'] = pg_get_pid($link); |
91 | $a['last error'] = pg_last_error($link); |
92 | $a['last notice'] = pg_last_notice($link); |
93 | $a['host'] = pg_host($link); |
94 | $a['port'] = pg_port($link); |
95 | $a['dbname'] = pg_dbname($link); |
96 | $a['options'] = pg_options($link); |
97 | $a['version'] = pg_version($link); |
98 | |
99 | foreach (self::$paramCodes as $v) { |
100 | if (false !== $s = pg_parameter_status($link, $v)) { |
101 | $a['param'][$v] = $s; |
102 | } |
103 | } |
104 | |
105 | $a['param']['client_encoding'] = pg_client_encoding($link); |
106 | $a['param'] = new EnumStub($a['param']); |
107 | |
108 | return $a; |
109 | } |
110 | |
111 | public static function castResult($result, array $a, Stub $stub, bool $isNested) |
112 | { |
113 | $a['num rows'] = pg_num_rows($result); |
114 | $a['status'] = pg_result_status($result); |
115 | if (isset(self::$resultStatus[$a['status']])) { |
116 | $a['status'] = new ConstStub(self::$resultStatus[$a['status']], $a['status']); |
117 | } |
118 | $a['command-completion tag'] = pg_result_status($result, \PGSQL_STATUS_STRING); |
119 | |
120 | if (-1 === $a['num rows']) { |
121 | foreach (self::$diagCodes as $k => $v) { |
122 | $a['error'][$k] = pg_result_error_field($result, $v); |
123 | } |
124 | } |
125 | |
126 | $a['affected rows'] = pg_affected_rows($result); |
127 | $a['last OID'] = pg_last_oid($result); |
128 | |
129 | $fields = pg_num_fields($result); |
130 | |
131 | for ($i = 0; $i < $fields; ++$i) { |
132 | $field = [ |
133 | 'name' => pg_field_name($result, $i), |
134 | 'table' => sprintf('%s (OID: %s)', pg_field_table($result, $i), pg_field_table($result, $i, true)), |
135 | 'type' => sprintf('%s (OID: %s)', pg_field_type($result, $i), pg_field_type_oid($result, $i)), |
136 | 'nullable' => (bool) pg_field_is_null($result, $i), |
137 | 'storage' => pg_field_size($result, $i).' bytes', |
138 | 'display' => pg_field_prtlen($result, $i).' chars', |
139 | ]; |
140 | if (' (OID: )' === $field['table']) { |
141 | $field['table'] = null; |
142 | } |
143 | if ('-1 bytes' === $field['storage']) { |
144 | $field['storage'] = 'variable size'; |
145 | } elseif ('1 bytes' === $field['storage']) { |
146 | $field['storage'] = '1 byte'; |
147 | } |
148 | if ('1 chars' === $field['display']) { |
149 | $field['display'] = '1 char'; |
150 | } |
151 | $a['fields'][] = new EnumStub($field); |
152 | } |
153 | |
154 | return $a; |
155 | } |
156 | } |