1 files changed, 14 insertions, 1 deletions
diff --git a/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlDao.java b/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlDao.java
index c253229..361fd95 100644
--- a/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlDao.java
+++ b/sql-persistence/src/main/java/io/trygvis/persistence/sql/SqlDao.java
@@ -36,10 +36,19 @@ public abstract class SqlDao<Id, T, S extends SqlSession, Row> {
     protected abstract T newEntity(Row row) throws SQLException;
 
     protected List<T> runQuery(final String sql) throws SQLException {
+        return runQuery(new Preparator() {
+            @Override
+            public void prepare(PreparedStatement stmt) throws SQLException {
+            }
+        }, sql);
+    }
+
+    protected List<T> runQuery(final Preparator preparator, final String sql) throws SQLException {
         return session.query(new SqlExecutor.QueryCommand<T>() {
             @Override
             public List<T> run(Connection c) throws SQLException {
                 try (PreparedStatement stmt = c.prepareStatement(sql)) {
+                    preparator.prepare(stmt);
                     ResultSet rs = stmt.executeQuery();
 
                     List<Row> rows = new ArrayList<>();
@@ -47,7 +56,7 @@ public abstract class SqlDao<Id, T, S extends SqlSession, Row> {
                         rows.add(newRow(rs));
                     }
 
-                    List<T> entities = new ArrayList<T>(rows.size());
+                    List<T> entities = new ArrayList<>(rows.size());
                     for (Row row : rows) {
                         entities.add(newEntity(row));
                     }
@@ -57,4 +66,8 @@ public abstract class SqlDao<Id, T, S extends SqlSession, Row> {
             }
         });
     }
+
+    protected static interface Preparator {
+        void prepare(PreparedStatement stmt) throws SQLException;
+    }
 }