aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/task/TaskDao.java
diff options
context:
space:
mode:
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.java26
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;
- }
- }
-}