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

do not use 1 con per shardid

reuse-connections-for-logical-ref-fkeys-2
Onder Kalaci 2022-09-14 18:27:44 +03:00
parent 708a5829f5
commit 8be8d9ceb9
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/backend/distributed/operations/shard_split.c
View File

@ -1016,10 +1016,14 @@ CreateObjectOnPlacement(List *objectCreationCommandList,
WorkerNode *workerPlacementNode)
{
char *currentUser = CurrentUserName();
SendCommandListToWorkerOutsideTransaction(workerPlacementNode->workerName,
workerPlacementNode->workerPort,
currentUser,
objectCreationCommandList);
int connectionFlags = 0;
MultiConnection *workerConnection = GetNodeUserDatabaseConnection(connectionFlags,
workerPlacementNode->workerName, workerPlacementNode->workerPort,
currentUser, NULL);
SendCommandListToWorkerInSeparateTransaction(workerConnection,
objectCreationCommandList);
}
@ -2245,7 +2249,7 @@ GetNextShardIdForSplitChild()
appendStringInfo(nextValueCommand, "SELECT nextval(%s);", quote_literal_cstr(
"pg_catalog.pg_dist_shardid_seq"));
int connectionFlag = FORCE_NEW_CONNECTION;
int connectionFlag = 0;
MultiConnection *connection = GetNodeUserDatabaseConnection(connectionFlag,
LocalHostName,
PostPortNumber,
@ -2269,7 +2273,9 @@ GetNextShardIdForSplitChild()
}
shardId = SafeStringToUint64(PQgetvalue(result, 0, 0 /* nodeId column*/));
CloseConnection(connection);
//CloseConnection(connection);
PQclear(result);
ForgetResults(connection);
return shardId;
}