From fc961070e9993ede1bba5fff4f043ce5456eb36d Mon Sep 17 00:00:00 2001 From: Davide D'Alto Date: Sat, 10 Feb 2018 23:45:30 +0000 Subject: [PATCH] OGM-1397 Use table.pkColumnValue for an Infinispan counter name --- .../counter/TableClusteredCounterHandler.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/infinispan-embedded/src/main/java/org/hibernate/ogm/datastore/infinispan/persistencestrategy/counter/TableClusteredCounterHandler.java b/infinispan-embedded/src/main/java/org/hibernate/ogm/datastore/infinispan/persistencestrategy/counter/TableClusteredCounterHandler.java index 379ad5ef9b..a659cd9b7e 100644 --- a/infinispan-embedded/src/main/java/org/hibernate/ogm/datastore/infinispan/persistencestrategy/counter/TableClusteredCounterHandler.java +++ b/infinispan-embedded/src/main/java/org/hibernate/ogm/datastore/infinispan/persistencestrategy/counter/TableClusteredCounterHandler.java @@ -26,8 +26,16 @@ public TableClusteredCounterHandler(EmbeddedCacheManager cacheManager) { @Override public Number nextValue(NextValueRequest request) { - String counterName = request.getKey().getColumnValue(); + String counterName = counterName( request ); StrongCounter strongCounter = getCounterOrCreateIt( counterName, request.getInitialValue() ); return nextValue( request, strongCounter ); } + + private String counterName(NextValueRequest request) { + StringBuilder builder = new StringBuilder(); + builder.append( request.getKey().getTable() ); + builder.append( "." ); + builder.append( request.getKey().getColumnValue() ); + return builder.toString(); + } }