projects
/
m6w6
/
ext-pq
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
|
github
raw
|
inline
| side by side
fix async queries not cleared prior some sync queries
[m6w6/ext-pq]
/
src
/
php_pqconn.c
diff --git
a/src/php_pqconn.c
b/src/php_pqconn.c
index 3a44a952a944548d4d5c94945874c1aa9f546877..6278323627ebad84f102a12de5a0f6f2eb827f76 100644
(file)
--- a/
src/php_pqconn.c
+++ b/
src/php_pqconn.c
@@
-590,7
+590,7
@@
static inline PGresult *unlisten(PGconn *conn, const char *channel_str, size_t c
smart_str_appends(&cmd, quoted_channel);
smart_str_0(&cmd);
smart_str_appends(&cmd, quoted_channel);
smart_str_0(&cmd);
- res =
PQ
exec(conn, smart_str_v(&cmd));
+ res =
php_pq_
exec(conn, smart_str_v(&cmd));
smart_str_free(&cmd);
PQfreemem(quoted_channel);
smart_str_free(&cmd);
PQfreemem(quoted_channel);
@@
-990,7
+990,7
@@
static PHP_METHOD(pqconn, notify) {
PGresult *res;
char *params[2] = {channel_str, message_str};
PGresult *res;
char *params[2] = {channel_str, message_str};
- res =
PQexecP
arams(obj->intern->conn, "select pg_notify($1, $2)", 2, NULL, (const char *const*) params, NULL, NULL, 0);
+ res =
php_pq_exec_p
arams(obj->intern->conn, "select pg_notify($1, $2)", 2, NULL, (const char *const*) params, NULL, NULL, 0);
if (!res) {
throw_exce(EX_RUNTIME, "Failed to notify listeners (%s)", PHP_PQerrorMessage(obj->intern->conn));
if (!res) {
throw_exce(EX_RUNTIME, "Failed to notify listeners (%s)", PHP_PQerrorMessage(obj->intern->conn));
@@
-1224,7
+1224,7
@@
static PHP_METHOD(pqconn, execParams) {
php_pq_params_t *params;
params = php_pq_params_init(&obj->intern->converters, ztypes ? Z_ARRVAL_P(ztypes) : NULL, Z_ARRVAL_P(zparams));
php_pq_params_t *params;
params = php_pq_params_init(&obj->intern->converters, ztypes ? Z_ARRVAL_P(ztypes) : NULL, Z_ARRVAL_P(zparams));
- res =
PQexecP
arams(obj->intern->conn, query_str, params->param.count, params->type.oids, (const char *const*) params->param.strings, NULL, NULL, 0);
+ res =
php_pq_exec_p
arams(obj->intern->conn, query_str, params->param.count, params->type.oids, (const char *const*) params->param.strings, NULL, NULL, 0);
php_pq_params_free(¶ms);
if (!res) {
php_pq_params_free(¶ms);
if (!res) {