MonetDB: HTM - Add sendControlCommand statement for pre/persist-...

[Dimitar Nedev]

Changeset: ae733c0472fa for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=ae733c0472fa
Modified Files:
        java/src/nl/cwi/monetdb/jdbc/MonetTwoStageCommit.java
Branch: HTM
Log Message:

Add sendControlCommand statement for pre/persist-commit


diffs (39 lines):

diff --git a/java/src/nl/cwi/monetdb/jdbc/MonetTwoStageCommit.java 
b/java/src/nl/cwi/monetdb/jdbc/MonetTwoStageCommit.java
--- a/java/src/nl/cwi/monetdb/jdbc/MonetTwoStageCommit.java
+++ b/java/src/nl/cwi/monetdb/jdbc/MonetTwoStageCommit.java
@@ -19,7 +19,6 @@
 
 package nl.cwi.monetdb.jdbc;
 
-import java.sql.Connection;
 import java.sql.SQLException;
 import java.sql.Savepoint;
 
@@ -33,9 +32,9 @@ import java.sql.Savepoint;
  * 
  */
 public class MonetTwoStageCommit {
-       Connection connection;
+       private final MonetConnection connection;
        
-       MonetTwoStageCommit(Connection connection) {
+       MonetTwoStageCommit(MonetConnection connection) {
                this.connection = connection;
        }
        
@@ -46,13 +45,13 @@ public class MonetTwoStageCommit {
                        throw new SQLException("Cannot execute preCommit - 
autocommit enabled", "3B000");
                }
                savepoint = connection.setSavepoint(name);
-               // TODO execute precommit
+               connection.sendControlCommand("pre_commit");
                
                return savepoint;
        }
        
        public void persistCommit(Savepoint savepoint) throws SQLException {
-               // TODO execute persistCommit
+               connection.sendControlCommand("presist_commit");
                connection.releaseSavepoint(savepoint);
                return;
        }
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list