Function PQsendQueryInternal

src/interfaces/libpq/fe-exec.c:1371–1465

}

int
PQsendQueryInternal(PGconn *conn, const char *query, bool newQuery)
{
	PGcmdQueueEntry *entry = NULL;

	if (!PQsendQueryStart(conn, newQuery))
		return 0;

	/* check the argument */
	if (!query)
	{
		appendPQExpBufferStr(&conn->errorMessage,
							 libpq_gettext("command string is a null pointer\n"));
		return 0;
	}

	entry = pqAllocCmdQueueEntry(conn);
	if (entry == NULL)
		return 0;				/* error msg already set */

	/* Send the query message(s) */
	if (conn->pipelineStatus == PQ_PIPELINE_OFF)
	{
		/* construct the outgoing Query message */
		if (pqPutMsgStart('Q', conn) < 0 ||
			pqPuts(query, conn) < 0 ||
			pqPutMsgEnd(conn) < 0)
		{
			/* error message should be set up already */
			pqRecycleCmdQueueEntry(conn, entry);
			return 0;
		}

		/* remember we are using simple query protocol */
		entry->queryclass = PGQUERY_SIMPLE;
		/* and remember the query text too, if possible */
		entry->query = strdup(query);
	}
	else
	{
		/*
		 * In pipeline mode we cannot use the simple protocol, so we send
		 * Parse, Bind, Describe Portal, Execute, Close Portal (with the
		 * unnamed portal).
		 */
		if (pqPutMsgStart('P', conn) < 0 ||
			pqPuts("", conn) < 0 ||
			pqPuts(query, conn) < 0 ||
			pqPutInt(0, 2, conn) < 0 ||
			pqPutMsgEnd(conn) < 0)
			goto sendFailed;
		if (pqPutMsgStart('B', conn) < 0 ||
			pqPuts("", conn) < 0 ||
			pqPuts("", conn) < 0 ||
			pqPutInt(0, 2, conn) < 0 ||
			pqPutInt(0, 2, conn) < 0 ||
			pqPutInt(0, 2, conn) < 0 ||
			pqPutMsgEnd(conn) < 0)