postgres
diff --git a/‎doc/src/sgml/libpq.sgml
Lines changed: 502 additions & 0 deletions b/‎doc/src/sgml/libpq.sgml
Lines changed: 502 additions & 0 deletions
diff --git a/‎doc/src/sgml/lobj.sgml
Lines changed: 4 additions & 0 deletions b/‎doc/src/sgml/lobj.sgml
Lines changed: 4 additions & 0 deletions
diff --git a/‎src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
Lines changed: 3 additions & 0 deletions b/‎src/backend/replication/libpqwalreceiver/libpqwalreceiver.c
Lines changed: 3 additions & 0 deletions
diff --git a/‎src/interfaces/libpq/exports.txt
Lines changed: 5 additions & 0 deletions b/‎src/interfaces/libpq/exports.txt
Lines changed: 5 additions & 0 deletions
diff --git a/‎src/interfaces/libpq/fe-connect.c
Lines changed: 27 additions & 0 deletions b/‎src/interfaces/libpq/fe-connect.c
Lines changed: 27 additions & 0 deletions
@@ -130,6 +130,10 @@
     <application>libpq</application> library.
    </para>
 
+   <para>
+    Client applications cannot use these functions while libpq connection is in batch mode.
+   </para>
+
    <sect2 id="lo-create">
     <title>Creating a Large Object</title>
 
 
@@ -1022,6 +1022,9 @@ libpqrcv_exec(WalReceiverConn *conn, const char *query,
 			walres->status = WALRCV_ERROR;
 			walres->err = pchomp(PQerrorMessage(conn->streamConn));
 			break;
+		default:
+		/* This is just to keep compiler quiet */
+			break;
 	}
 
 	PQclear(pgres);
 
@@ -179,3 +179,8 @@ PQgetgssctx               176
 PQsetSSLKeyPassHook_OpenSSL         177
 PQgetSSLKeyPassHook_OpenSSL         178
 PQdefaultSSLKeyPassHook_OpenSSL     179
+PQenterBatchMode	      180
+PQexitBatchMode           181
+PQbatchSendQueue	      182
+PQbatchProcessQueue	      183
+PQbatchStatus		      184
@@ -535,6 +535,24 @@ pqDropConnection(PGconn *conn, bool flushInput)
 	}
 }
 
+/*
+ * PQfreeCommandQueue
+ * Free all the entries of PGcommandQueueEntry queue passed.
+ */
+static void
+PQfreeCommandQueue(PGcommandQueueEntry *queue)
+{
+
+	while (queue != NULL)
+	{
+		PGcommandQueueEntry *prev = queue;
+
+		queue = queue->next;
+		if (prev->query)
+			free(prev->query);
+		free(prev);
+	}
+}
 
 /*
  *		pqDropServerData
@@ -554,6 +572,7 @@ pqDropServerData(PGconn *conn)
 {
 	PGnotify   *notify;
 	pgParameterStatus *pstatus;
+	PGcommandQueueEntry *queue;
 
 	/* Forget pending notifies */
 	notify = conn->notifyHead;
@@ -566,6 +585,14 @@ pqDropServerData(PGconn *conn)
 	}
 	conn->notifyHead = conn->notifyTail = NULL;
 
+	queue = conn->cmd_queue_head;
+	PQfreeCommandQueue(queue);
+	conn->cmd_queue_head = conn->cmd_queue_tail = NULL;
+
+	queue = conn->cmd_queue_recycle;
+	PQfreeCommandQueue(queue);
+	conn->cmd_queue_recycle = NULL;
+
 	/* Reset ParameterStatus data, as well as variables deduced from it */
 	pstatus = conn->pstatus;
 	while (pstatus != NULL)
Original file line number	Diff line number	Diff line change
`@@ -1022,6 +1022,9 @@ libpqrcv_exec(WalReceiverConn conn, const char query,`
`1022`	`1022`	`walres->status = WALRCV_ERROR;`
`1023`	`1023`	`walres->err = pchomp(PQerrorMessage(conn->streamConn));`
`1024`	`1024`	`break;`
	`1025`	`+ default:`
	`1026`	`+ /* This is just to keep compiler quiet */`
	`1027`	`+ break;`
`1025`	`1028`	`}`
`1026`	`1029`
`1027`	`1030`	`PQclear(pgres);`