greenplumn cdbpq 源码
greenplumn cdbpq 代码
文件路径：/src/backend/cdb/dispatcher/cdbpq.c
#include "postgres.h"
#include "libpq-fe.h"
#include "libpq-int.h"
#include "cdb/cdbpq.h"
int
PQsendGpQuery_shared(PGconn *conn, char *shared_query, int query_len, bool nonblock)
{
int ret;
if (!PQsendQueryStart(conn))
return 0;
if (!shared_query)
{
printfPQExpBuffer(&conn->errorMessage,
libpq_gettext("shared mpp-query string is a null pointer\n"));
return 0;
}
if (conn->outBuffer_shared)
{
printfPQExpBuffer(&conn->errorMessage,
libpq_gettext("Cannot overwrite shared query string\n"));
return 0;
}
/*
* Stash the original buffer and switch to the incoming pointer.
* We will restore the buffer after completing to send the shared query.
*/
conn->outBufferSaved = conn->outBuffer;
conn->outBuffer = shared_query;
conn->outBuffer_shared = true;
conn->outMsgStart = 0;
conn->outMsgEnd = query_len;
conn->outCount = query_len;
/* remember we are using simple query protocol */
conn->queryclass = PGQUERY_SIMPLE;
/*
* Give the data a push. In nonblock mode, don't complain if we're unable
* to send it all; PQgetResult() will do any additional flushing needed.
*/
if (nonblock)
ret = pqFlushNonBlocking(conn);
else
ret = pqFlush(conn);
if (ret < 0)
{
/* error message should be set up already */
return 0;
}
/* OK, it's launched! */
conn->asyncStatus = PGASYNC_BUSY;
return 1;
}
相关信息
相关文章
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
7、 openharmony