Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0004129: Allow different subselect sql based on DATA_EVENT_TYPE (#94)
  • Loading branch information
woehrl01 authored and erilong committed Oct 28, 2019
1 parent 3401bfd commit c809094
Showing 1 changed file with 3 additions and 1 deletion.
Expand Up @@ -82,7 +82,9 @@ public Set<String> routeToNodes(SimpleRouterContext routingContext, DataMetaData
sqlParams.put("NODE_GROUP_ID", dataMetaData.getRouter().getNodeGroupLink()
.getTargetNodeGroupId());
sqlParams.put("EXTERNAL_DATA", dataMetaData.getData().getExternalData());
sqlParams.put("DATA_EVENT_TYPE", dataMetaData.getData().getDataEventType().name());
sqlParams.put("TABLE_NAME", dataMetaData.getData().getTableName());

ISqlTemplate template = symmetricDialect.getPlatform().getSqlTemplate();
List<String> ids = template.query(String.format("%s%s", sql, subSelect),
new StringMapper(), sqlParams);
Expand All @@ -104,4 +106,4 @@ public Set<String> routeToNodes(SimpleRouterContext routingContext, DataMetaData
return nodeIds;
}

}
}

0 comments on commit c809094

Please sign in to comment.