save_point_inval
Onder Kalaci 2022-11-29 16:33:34 +01:00
parent bc118ee551
commit 035c91ae7f
1 changed files with 7 additions and 0 deletions

View File

@ -196,6 +196,13 @@ StringJoinParams(List *stringList, char delimiter, char *prefix, char *postfix)
}
appendStringInfoString(joinedString, command);
curIndex++;
if (curIndex % 50 == 0)
{
appendStringInfoChar(joinedString, delimiter);
appendStringInfo(joinedString, "SAVEPOINT citus_int_%d;", curIndex);
}
}
if (postfix != NULL)