external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Convert TableDDLCommandList function to the new connection API

pull/1454/head
velioglu 2017-06-14 17:27:43 +03:00
parent 0aa9572e18
commit d7b68e5647
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/backend/distributed/worker/worker_data_fetch_protocol.c
View File

@ -996,11 +996,20 @@ TableDDLCommandList(const char *nodeName, uint32 nodePort, const char *tableName
{ {
List *ddlCommandList = NIL; List *ddlCommandList = NIL;
StringInfo queryString = NULL; StringInfo queryString = NULL;
MultiConnection *connection = NULL;
PGresult *result = NULL;
uint32 connectionFlag = FORCE_NEW_CONNECTION;
queryString = makeStringInfo(); queryString = makeStringInfo();
appendStringInfo(queryString, GET_TABLE_DDL_EVENTS, tableName); 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; return ddlCommandList;
} }