X-Git-Url: https://git.m6w6.name/?p=m6w6%2Fext-pq;a=blobdiff_plain;f=src%2Fphp_pqconn.c;h=16d3f772c92ad9746bfeecfb941a0257526d937c;hp=dd08ced5170743dddc3d608dccf68f9f949887a6;hb=18f89e2c907e17962ec4bb99d5c9b56b17678a06;hpb=c62ffa9e8cf262c412efeb84c2523d1c78897282

diff --git a/src/php_pqconn.c b/src/php_pqconn.c
index dd08ced..16d3f77 100644
--- a/src/php_pqconn.c
+++ b/src/php_pqconn.c
@@ -1314,11 +1314,6 @@ STATUS php_pqconn_prepare_async(zval *object, php_pqconn_object_t *obj, const ch
 	if (!PQsendPrepare(obj->intern->conn, name, query, params->type.count, params->type.oids)) {
 		rv = FAILURE;
 		throw_exce(EX_IO TSRMLS_CC, "Failed to prepare statement (%s)", PHP_PQerrorMessage(obj->intern->conn));
-#if HAVE_PQSETSINGLEROWMODE
-	} else if (obj->intern->unbuffered && !PQsetSingleRowMode(obj->intern->conn)) {
-		rv = FAILURE;
-		throw_exce(EX_RUNTIME TSRMLS_CC, "Failed to enable unbuffered mode (%s)", PHP_PQerrorMessage(obj->intern->conn));
-#endif
 	} else {
 		rv = SUCCESS;
 		obj->intern->poller = PQconsumeInput;
@@ -1446,11 +1441,6 @@ STATUS php_pqconn_declare_async(zval *object, php_pqconn_object_t *obj, const ch
 	if (!PQsendQuery(obj->intern->conn, decl)) {
 		rv = FAILURE;
 		throw_exce(EX_IO TSRMLS_CC, "Failed to declare cursor (%s)", PHP_PQerrorMessage(obj->intern->conn));
-#if HAVE_PQSETSINGLEROWMODE
-	} else if (obj->intern->unbuffered && !PQsetSingleRowMode(obj->intern->conn)) {
-		rv = FAILURE;
-		throw_exce(EX_RUNTIME TSRMLS_CC, "Failed to enable unbuffered mode (%s)", PHP_PQerrorMessage(obj->intern->conn));
-#endif
 	} else {
 		rv = SUCCESS;
 		obj->intern->poller = PQconsumeInput;
@@ -1621,7 +1611,7 @@ STATUS php_pqconn_start_transaction(zval *zconn, php_pqconn_object_t *conn_obj,
 	} else {
 		PGresult *res;
 		smart_str cmd = {0};
-		const char *il = isolation_level(&isolation);
+		const char *il = php_pq_isolation_level(&isolation);
 
 		smart_str_appends(&cmd, "START TRANSACTION ISOLATION LEVEL ");
 		smart_str_appends(&cmd, il);
@@ -1660,7 +1650,7 @@ STATUS php_pqconn_start_transaction_async(zval *zconn, php_pqconn_object_t *conn
 		throw_exce(EX_UNINITIALIZED TSRMLS_CC, "pq\\Connection not initialized");
 	} else {
 		smart_str cmd = {0};
-		const char *il = isolation_level(&isolation);
+		const char *il = php_pq_isolation_level(&isolation);
 
 		smart_str_appends(&cmd, "START TRANSACTION ISOLATION LEVEL ");
 		smart_str_appends(&cmd, il);
@@ -1746,6 +1736,7 @@ static PHP_METHOD(pqconn, startTransactionAsync) {
 
 			php_pq_object_addref(obj TSRMLS_CC);
 			txn->conn = obj;
+			txn->open = 1;
 			txn->isolation = isolation;
 			txn->readonly = readonly;
 			txn->deferrable = deferrable;