summaryrefslogtreecommitdiff
path: root/ext/pdo_pgsql/pgsql_statement.c
diff options
context:
space:
mode:
authorAnatol Belski <ab@php.net>2016-04-05 15:13:17 +0200
committerAnatol Belski <ab@php.net>2016-04-05 15:13:17 +0200
commitea4d27f47c47a197e3178f2a73e5f6d5655cbc02 (patch)
treee947b5ed0844138edd1f20e897df21c5319e20c5 /ext/pdo_pgsql/pgsql_statement.c
parentb132aa49d1dced234ffc65a5757f46fe6c0450c7 (diff)
parentdf8f927446a53a7b4482d663295fe9ce2d72ec62 (diff)
downloadphp-git-ea4d27f47c47a197e3178f2a73e5f6d5655cbc02.tar.gz
Merge branch 'PHP-7.0'
* PHP-7.0: update NEWS fix and extend test Don't roundtrip to the database to get the column type if you already know it
Diffstat (limited to 'ext/pdo_pgsql/pgsql_statement.c')
-rw-r--r--ext/pdo_pgsql/pgsql_statement.c81
1 files changed, 56 insertions, 25 deletions
diff --git a/ext/pdo_pgsql/pgsql_statement.c b/ext/pdo_pgsql/pgsql_statement.c
index efa0aa787e..6a18d6dfb0 100644
--- a/ext/pdo_pgsql/pgsql_statement.c
+++ b/ext/pdo_pgsql/pgsql_statement.c
@@ -36,13 +36,27 @@
#endif
/* from postgresql/src/include/catalog/pg_type.h */
+#define BOOLLABEL "bool"
#define BOOLOID 16
+#define BYTEALABEL "bytea"
#define BYTEAOID 17
-#define INT8OID 20
+#define DATELABEL "date"
+#define DATEOID 1082
+#define INT2LABEL "int2"
#define INT2OID 21
+#define INT4LABEL "int4"
#define INT4OID 23
-#define TEXTOID 25
+#define INT8LABEL "int8"
+#define INT8OID 20
#define OIDOID 26
+#define TEXTLABEL "text"
+#define TEXTOID 25
+#define TIMESTAMPLABEL "timestamp"
+#define TIMESTAMPOID 1114
+#define VARCHARLABEL "varchar"
+#define VARCHAROID 1043
+
+
static int pgsql_stmt_dtor(pdo_stmt_t *stmt)
{
@@ -591,29 +605,46 @@ static int pgsql_stmt_get_column_meta(pdo_stmt_t *stmt, zend_long colno, zval *r
array_init(return_value);
add_assoc_long(return_value, "pgsql:oid", S->cols[colno].pgsql_type);
- /* Fetch metadata from Postgres system catalogue */
- spprintf(&q, 0, "SELECT TYPNAME FROM PG_TYPE WHERE OID=%u", S->cols[colno].pgsql_type);
- res = PQexec(S->H->server, q);
- efree(q);
-
- status = PQresultStatus(res);
-
- if (status != PGRES_TUPLES_OK) {
- /* Failed to get system catalogue, but return success
- * with the data we have collected so far
- */
- goto done;
- }
-
- /* We want exactly one row returned */
- if (1 != PQntuples(res)) {
- goto done;
- }
-
- add_assoc_string(return_value, "native_type", PQgetvalue(res, 0, 0));
-done:
- PQclear(res);
- return 1;
+ switch (S->cols[colno].pgsql_type) {
+ case BOOLOID:
+ add_assoc_string(return_value, "native_type", BOOLLABEL);
+ break;
+ case BYTEAOID:
+ add_assoc_string(return_value, "native_type", BYTEALABEL);
+ break;
+ case INT8OID:
+ add_assoc_string(return_value, "native_type", INT8LABEL);
+ break;
+ case INT2OID:
+ add_assoc_string(return_value, "native_type", INT2LABEL);
+ break;
+ case INT4OID:
+ add_assoc_string(return_value, "native_type", INT4LABEL);
+ break;
+ case TEXTOID:
+ add_assoc_string(return_value, "native_type", TEXTLABEL);
+ break;
+ case VARCHAROID:
+ add_assoc_string(return_value, "native_type", VARCHARLABEL);
+ break;
+ case DATEOID:
+ add_assoc_string(return_value, "native_type", DATELABEL);
+ break;
+ case TIMESTAMPOID:
+ add_assoc_string(return_value, "native_type", TIMESTAMPLABEL);
+ break;
+ default:
+ /* Fetch metadata from Postgres system catalogue */
+ spprintf(&q, 0, "SELECT TYPNAME FROM PG_TYPE WHERE OID=%u", S->cols[colno].pgsql_type);
+ res = PQexec(S->H->server, q);
+ efree(q);
+ status = PQresultStatus(res);
+ if (status == PGRES_TUPLES_OK && 1 == PQntuples(res)) {
+ add_assoc_string(return_value, "native_type", PQgetvalue(res, 0, 0));
+ }
+ PQclear(res);
+ }
+ return 1;
}
static int pdo_pgsql_stmt_cursor_closer(pdo_stmt_t *stmt)