Lines Matching refs:pgsql_result

657 	PGresult *pgsql_result;  in pgsqlCopyFromArray_internal()  local
683 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyFromArray_internal()
684 PQclear(pgsql_result); in pgsqlCopyFromArray_internal()
686 pgsql_result = PQexec(H->server, query); in pgsqlCopyFromArray_internal()
691 if (pgsql_result) { in pgsqlCopyFromArray_internal()
692 status = PQresultStatus(pgsql_result); in pgsqlCopyFromArray_internal()
697 if (status == PGRES_COPY_IN && pgsql_result) { in pgsqlCopyFromArray_internal()
702 PQclear(pgsql_result); in pgsqlCopyFromArray_internal()
743 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyFromArray_internal()
744 if (PGRES_COMMAND_OK != PQresultStatus(pgsql_result)) { in pgsqlCopyFromArray_internal()
745 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromArray_internal()
748 PQclear(pgsql_result); in pgsqlCopyFromArray_internal()
754 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromArray_internal()
755 PQclear(pgsql_result); in pgsqlCopyFromArray_internal()
776 PGresult *pgsql_result; in pgsqlCopyFromFile_internal() local
807 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyFromFile_internal()
808 PQclear(pgsql_result); in pgsqlCopyFromFile_internal()
810 pgsql_result = PQexec(H->server, query); in pgsqlCopyFromFile_internal()
814 if (pgsql_result) { in pgsqlCopyFromFile_internal()
815 status = PQresultStatus(pgsql_result); in pgsqlCopyFromFile_internal()
820 if (status == PGRES_COPY_IN && pgsql_result) { in pgsqlCopyFromFile_internal()
825 PQclear(pgsql_result); in pgsqlCopyFromFile_internal()
844 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyFromFile_internal()
845 if (PGRES_COMMAND_OK != PQresultStatus(pgsql_result)) { in pgsqlCopyFromFile_internal()
846 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromFile_internal()
849 PQclear(pgsql_result); in pgsqlCopyFromFile_internal()
856 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyFromFile_internal()
857 PQclear(pgsql_result); in pgsqlCopyFromFile_internal()
879 PGresult *pgsql_result; in pgsqlCopyToFile_internal() local
903 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyToFile_internal()
904 PQclear(pgsql_result); in pgsqlCopyToFile_internal()
913 pgsql_result = PQexec(H->server, query); in pgsqlCopyToFile_internal()
916 if (pgsql_result) { in pgsqlCopyToFile_internal()
917 status = PQresultStatus(pgsql_result); in pgsqlCopyToFile_internal()
922 if (status == PGRES_COPY_OUT && pgsql_result) { in pgsqlCopyToFile_internal()
923 PQclear(pgsql_result); in pgsqlCopyToFile_internal()
949 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyToFile_internal()
950 PQclear(pgsql_result); in pgsqlCopyToFile_internal()
955 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyToFile_internal()
956 PQclear(pgsql_result); in pgsqlCopyToFile_internal()
979 PGresult *pgsql_result; in pgsqlCopyToArray_internal() local
994 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyToArray_internal()
995 PQclear(pgsql_result); in pgsqlCopyToArray_internal()
1004 pgsql_result = PQexec(H->server, query); in pgsqlCopyToArray_internal()
1007 if (pgsql_result) { in pgsqlCopyToArray_internal()
1008 status = PQresultStatus(pgsql_result); in pgsqlCopyToArray_internal()
1013 if (status == PGRES_COPY_OUT && pgsql_result) { in pgsqlCopyToArray_internal()
1014 PQclear(pgsql_result); in pgsqlCopyToArray_internal()
1032 while ((pgsql_result = PQgetResult(H->server))) { in pgsqlCopyToArray_internal()
1033 PQclear(pgsql_result); in pgsqlCopyToArray_internal()
1036 pdo_pgsql_error(dbh, PGRES_FATAL_ERROR, pdo_pgsql_sqlstate(pgsql_result)); in pgsqlCopyToArray_internal()
1037 PQclear(pgsql_result); in pgsqlCopyToArray_internal()