From d7b68e5647791fb7bfccfdcdd173777f0c774843 Mon Sep 17 00:00:00 2001 From: velioglu Date: Wed, 14 Jun 2017 17:27:43 +0300 Subject: [PATCH] Convert TableDDLCommandList function to the new connection API --- .../distributed/worker/worker_data_fetch_protocol.c | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/src/backend/distributed/worker/worker_data_fetch_protocol.c b/src/backend/distributed/worker/worker_data_fetch_protocol.c index a612cc373..d784d9a87 100644 --- a/src/backend/distributed/worker/worker_data_fetch_protocol.c +++ b/src/backend/distributed/worker/worker_data_fetch_protocol.c @@ -996,11 +996,20 @@ TableDDLCommandList(const char *nodeName, uint32 nodePort, const char *tableName { List *ddlCommandList = NIL; StringInfo queryString = NULL; + MultiConnection *connection = NULL; + PGresult *result = NULL; + uint32 connectionFlag = FORCE_NEW_CONNECTION; queryString = makeStringInfo(); appendStringInfo(queryString, GET_TABLE_DDL_EVENTS, tableName); + connection = GetNodeConnection(connectionFlag, nodeName, nodePort); + + ExecuteOptionalRemoteCommand(connection, queryString->data, &result); + ddlCommandList = ReadFirstColumnAsText(result); + + ForgetResults(connection); + CloseConnection(connection); - ddlCommandList = ExecuteRemoteQuery(nodeName, nodePort, NULL, queryString); return ddlCommandList; }