Skip to content
Permalink
Browse files

0004097: add transaction flush

  • Loading branch information...
erilong committed Oct 3, 2019
1 parent 085b7b1 commit 6ebb2ff7a8b233add793624f9672d2758d351bda
@@ -212,7 +212,8 @@ protected void queueEvents(ChannelRouterContext context, ISqlTransaction transac
final int typeForId = engine.getSymmetricDialect().getSqlTypeForIds();
boolean isPostgres = engine.getDatabasePlatform().getName().equals(DatabaseNamesConstants.POSTGRESQL);
long ts = System.currentTimeMillis();

transaction.flush();

for (TableInfo tableInfo : tableInfos) {
RouterInfo routerInfo = tableInfo.getRouterInfo();
String placeHolders = StringUtils.repeat("?", ", ", tableInfo.getPkColumnNames().length + 1);

0 comments on commit 6ebb2ff

Please sign in to comment.
You can’t perform that action at this time.