1 files changed, 31 insertions, 0 deletions
diff --git a/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlSession.java b/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlSession.java
new file mode 100644
index 0000000..3caa621
--- /dev/null
+++ b/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlSession.java
@@ -0,0 +1,31 @@
+package io.trygvis.persistence.sql;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.List;
+
+public class SqlSession {
+    private final Connection c;
+
+    public SqlSession(Connection c) {
+        this.c = c;
+    }
+
+    public void commit() throws SQLException {
+        c.commit();
+    }
+
+    public void close() throws SQLException {
+        c.close();
+    }
+
+    public void executeUpdate(String sql) throws SQLException {
+        Statement stmt = c.createStatement();
+        stmt.executeUpdate(sql);
+    }
+
+    public <T> List<T> query(SqlExecutor.QueryCommand<T> query) throws SQLException {
+        return query.run(c);
+    }
+}