actually we need per-session dialect

jpos · Sep 9, 2019 · aaa6048 · aaa6048
1 parent ce5a893
commit aaa6048
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/modules/dbsupport/src/main/java/org/jpos/ee/DB.java b/modules/dbsupport/src/main/java/org/jpos/ee/DB.java
@@ -147,6 +147,9 @@ public SessionFactory getSessionFactory() {
             sf = sessionFactories.get(cm);
             if (sf == null)
                 sessionFactories.put(cm, sf = newSessionFactory());
+            if (sf instanceof SessionFactoryImpl) {
+                dialect = ((SessionFactoryImpl) sf).getJdbcServices().getDialect();
+            }
         } catch (IOException | ConfigurationException | DocumentException | InterruptedException e) {
             throw new RuntimeException("Could not configure session factory", e);
         } finally {
@@ -167,11 +170,7 @@ private SessionFactory newSessionFactory() throws IOException, ConfigurationExce
         Metadata md = getMetadata();
         try {
             newSessionSem.acquireUninterruptibly();
-            SessionFactory sf = md.buildSessionFactory();
-            if (sf instanceof SessionFactoryImpl) {
-                dialect = ((SessionFactoryImpl) sf).getJdbcServices().getDialect();
-            }
-            return sf;
+            return md.buildSessionFactory();
         } finally {
             newSessionSem.release();
         }