Query node api improvements, rollback and savepoint option in Transaction

Author: ZorTik

asql-core/src/main/java/me/zort/sqllib/internal/query/AncestorQueryNode.java

@@ -0,0 +1,18 @@
+package me.zort.sqllib.internal.query;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Top-level query node that is used to build a query.
+ *
+ * @author ZorTik
+ */
+public abstract class AncestorQueryNode extends QueryNode<QueryNode<?>> {
+  public AncestorQueryNode() {
+    this(new ArrayList<>());
+  }
+  public AncestorQueryNode(List<QueryNode<?>> initial) {
+    super(null, initial, QueryPriority.GENERAL);
+  }
+}

asql-core/src/main/java/me/zort/sqllib/internal/query/DeleteQuery.java

@@ -10,7 +10,7 @@
 import java.util.ArrayList;
 import java.util.Objects;
 
-public class DeleteQuery extends QueryNode<QueryNode<?>> implements Executive, Conditional<DeleteQuery>, Limitable<DeleteQuery> {
+public class DeleteQuery extends AncestorQueryNode implements Executive, Conditional<DeleteQuery>, Limitable<DeleteQuery> {
 
   private String table;
 
@@ -26,7 +26,7 @@ public DeleteQuery(@Nullable SQLDatabaseConnection connection) {
   }
 
   public DeleteQuery(@Nullable SQLDatabaseConnection connection, @Nullable String table) {
-    super(null, new ArrayList<>(), QueryPriority.GENERAL);
+    super(new ArrayList<>());
     this.table = table;
     this.connection = connection;
   }

asql-core/src/main/java/me/zort/sqllib/internal/query/InsertQuery.java

@@ -11,7 +11,7 @@
 import java.util.ArrayList;
 import java.util.Objects;
 
-public class InsertQuery extends QueryNode<QueryNode<?>> implements Executive, Conditional<InsertQuery> {
+public class InsertQuery extends AncestorQueryNode implements Executive, Conditional<InsertQuery> {
 
   @Getter
   private String table;
@@ -31,7 +31,7 @@ public InsertQuery(@Nullable SQLDatabaseConnection connection) {
   }
 
   public InsertQuery(@Nullable SQLDatabaseConnection connection, @Nullable String table) {
-    super(null, new ArrayList<>(), QueryPriority.GENERAL);
+    super(new ArrayList<>());
     this.table = table;
     this.connection = connection;
     this.defs = new String[0];

asql-core/src/main/java/me/zort/sqllib/internal/query/SelectQuery.java

@@ -12,7 +12,7 @@
 import java.util.List;
 import java.util.Objects;
 
-public class SelectQuery extends QueryNode<QueryNode<?>> implements
+public class SelectQuery extends AncestorQueryNode implements
         Executive, Conditional<SelectQuery>, Limitable<SelectQuery>, ResultSetAware {
 
   private final List<String> cols;
@@ -30,7 +30,7 @@ public SelectQuery(@Nullable SQLDatabaseConnection connection, String... cols) {
   }
 
   public SelectQuery(@Nullable SQLDatabaseConnection connection, @Nullable String table, List<String> cols) {
-    super(null, new ArrayList<>(), QueryPriority.GENERAL);
+    super(new ArrayList<>());
     this.table = table;
     this.cols = cols;
     this.connection = connection;

asql-core/src/main/java/me/zort/sqllib/internal/query/UpdateQuery.java

@@ -10,7 +10,7 @@
 import java.util.ArrayList;
 import java.util.Objects;
 
-public class UpdateQuery extends QueryNode<QueryNode<?>> implements Executive, Conditional<UpdateQuery> {
+public class UpdateQuery extends AncestorQueryNode implements Executive, Conditional<UpdateQuery> {
 
   private String table;
 
@@ -26,7 +26,7 @@ public UpdateQuery(@Nullable SQLDatabaseConnection connection) {
   }
 
   public UpdateQuery(@Nullable SQLDatabaseConnection connection, @Nullable String table) {
-    super(null, new ArrayList<>(), QueryPriority.GENERAL.getPrior());
+    super(new ArrayList<>());
     this.table = table;
     this.connection = connection;
   }

asql-core/src/main/java/me/zort/sqllib/transaction/Transaction.java

@@ -1,6 +1,7 @@
 package me.zort.sqllib.transaction;
 
 import me.zort.sqllib.SQLDatabaseConnection;
+import me.zort.sqllib.api.data.QueryResult;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -51,6 +52,16 @@ public void rollback() throws SQLException {
     connection.rollback();
   }
 
+  public QueryResult rollback(String savepoint) {
+    verify();
+    return databaseConnection.exec(() -> "ROLLBACK TO " + savepoint + ";");
+  }
+
+  public QueryResult savepoint(String savepoint) {
+    verify();
+    return databaseConnection.exec(() -> "SAVEPOINT " + savepoint + ";");
+  }
+
   public boolean isActive() {
     return !committed;
   }

asql-debezium/src/main/java/me/zort/sqllib/debezium/ASQLDebeziumWatcher.java

@@ -14,7 +14,6 @@
 import java.io.IOException;
 import java.lang.reflect.AnnotatedElement;
 import java.net.URI;
-import java.net.URISyntaxException;
 import java.sql.DatabaseMetaData;
 import java.util.HashMap;
 import java.util.List;
@@ -66,7 +65,7 @@ public final class ASQLDebeziumWatcher
           int port,
           @NotNull String username,
           @NotNull String password
-  ) throws URISyntaxException {
+  ) {
     Configuration.Builder configBuilder = Configuration.create()
             .with("database.hostname", hostname)
             .with("database.port", String.valueOf(port))