diff --git a/symmetric/src/test/java/org/jumpmind/symmetric/db/DbTriggerTest.java b/symmetric/src/test/java/org/jumpmind/symmetric/db/DbTriggerTest.java
index cccf6f1135..b48acb33c8 100644
--- a/symmetric/src/test/java/org/jumpmind/symmetric/db/DbTriggerTest.java
+++ b/symmetric/src/test/java/org/jumpmind/symmetric/db/DbTriggerTest.java
@@ -183,14 +183,11 @@ public void validateTransactionFunctionailty() throws Exception {
         SymmetricEngine[] engines2test = SymmetricEngineTestFactory
                 .getUnitTestableEngines();
         for (SymmetricEngine engine : engines2test) {
-            IDbDialect dbDialect = (IDbDialect) engine.getApplicationContext().getBean(Constants.DB_DIALECT);
-            if (dbDialect.supportsTransactionId()) {
-                validateTransactionFunctionailty(engine);
-            }
+            validateTransactionFunctionailty(engine);
         }
     }
 
-    void validateTransactionFunctionailty(SymmetricEngine engine)
+    void validateTransactionFunctionailty(final SymmetricEngine engine)
             throws Exception {
         JdbcTemplate jdbcTemplate = getJdbcTemplate(engine);
         jdbcTemplate.execute(new ConnectionCallback() {
@@ -212,7 +209,10 @@ public Object doInConnection(Connection c) throws SQLException,
                 if (rs.next()) {
                     batchId = rs.getString(1);
                 }
-                Assert.assertNotNull(batchId);
+                IDbDialect dbDialect = (IDbDialect) engine.getApplicationContext().getBean(Constants.DB_DIALECT);
+                if (dbDialect.supportsTransactionId()) {
+                    Assert.assertNotNull(batchId);
+                }
                 stmt.close();
                 return null;
             }