kenmirrors
/
freeswitch
mirror of https://github.com/signalwire/freeswitch.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

[mod_pgsql] Use PQcmdTuples() to get number of effected rows to support UPDATE and INSERT without RETURNING.

This commit is contained in:
Aron Podrigal 2021-03-18 17:13:01 -05:00 committed by GitHub
parent 9c589b7750
commit fddc6adf8d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/mod/databases/mod_pgsql/mod_pgsql.c
View File

@ -633,6 +633,7 @@ error:
switch_status_t pgsql_next_result_timed(switch_pgsql_handle_t *handle, switch_pgsql_result_t **result_out, int msec) switch_status_t pgsql_next_result_timed(switch_pgsql_handle_t *handle, switch_pgsql_result_t **result_out, int msec)
{ {
char *affected_rows = NULL;
switch_pgsql_result_t *res; switch_pgsql_result_t *res;
switch_time_t start; switch_time_t start;
switch_time_t ctime; switch_time_t ctime;
@ -747,6 +748,11 @@ switch_status_t pgsql_next_result_timed(switch_pgsql_handle_t *handle, switch_pg
res->result = PQgetResult(handle->con); res->result = PQgetResult(handle->con);
if (res->result) { if (res->result) {
affected_rows = PQcmdTuples(res->result);
if (!zstr(affected_rows)) {
handle->affected_rows = atoi(affected_rows);
}
*result_out = res; *result_out = res;
res->status = PQresultStatus(res->result); res->status = PQresultStatus(res->result);
switch (res->status) { switch (res->status) {
@ -757,7 +763,6 @@ switch_status_t pgsql_next_result_timed(switch_pgsql_handle_t *handle, switch_pg
case PGRES_TUPLES_OK: case PGRES_TUPLES_OK:
{ {
res->rows = PQntuples(res->result); res->rows = PQntuples(res->result);
handle->affected_rows = res->rows;
res->cols = PQnfields(res->result); res->cols = PQnfields(res->result);
} }
break; break;