diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java index 5334f8e00e..33172df250 100644 --- a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java +++ b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/nuodb/NuoDbSymmetricDialect.java @@ -28,6 +28,7 @@ import org.jumpmind.symmetric.common.ParameterConstants; import org.jumpmind.symmetric.db.AbstractSymmetricDialect; import org.jumpmind.symmetric.db.ISymmetricDialect; +import org.jumpmind.symmetric.model.Trigger; import org.jumpmind.symmetric.service.IParameterService; public class NuoDbSymmetricDialect extends AbstractSymmetricDialect implements ISymmetricDialect { @@ -46,8 +47,13 @@ public NuoDbSymmetricDialect(IParameterService parameterService, IDatabasePlatfo @Override public boolean supportsTransactionId() { - return false; - } + return true; + } + + public String getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, + Trigger trigger) { + return "(select transid from system.connections where connid = getconnectionid())"; + } @Override public void createRequiredDatabaseObjects() { @@ -122,6 +128,16 @@ public void cleanDatabase() { // } // } + @Override + public boolean isClobSyncSupported() { + return false; + } + + @Override + public boolean isBlobSyncSupported() { + return false; + } + @Override public BinaryEncoding getBinaryEncoding() { return BinaryEncoding.NONE;