diff options
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/task/TaskDao.java')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/task/TaskDao.java | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/task/TaskDao.java b/src/main/java/io/trygvis/esper/testing/task/TaskDao.java deleted file mode 100644 index 242eb2a..0000000 --- a/src/main/java/io/trygvis/esper/testing/task/TaskDao.java +++ /dev/null @@ -1,26 +0,0 @@ -package io.trygvis.esper.testing.task; - -import java.sql.*; -import java.util.*; - -public class TaskDao { - private final Connection c; - private final String table; - - public TaskDao(Connection c, String table) { - this.c = c; - this.table = table; - } - - public List<String> findTasks() throws SQLException { - try (PreparedStatement s = c.prepareStatement("SELECT task_id FROM ? FOR UPDATE")) { - s.setString(1, table); - ResultSet rs = s.executeQuery(); - List<String> list = new ArrayList<>(); - while(rs.next()) { - list.add(rs.getString(1)); - } - return list; - } - } -} |