diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-08 22:24:01 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-08 22:24:01 +0100 |
commit | 2eae4836279646050e7e342752cde6e8f7c5b6cb (patch) | |
tree | d768a8ec4ef09cf62a09f73c499ae5a17677287a /src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java | |
parent | ddbf5d1ac05d0f03f7cbe9275c303541cca945be (diff) | |
download | esper-testing-2eae4836279646050e7e342752cde6e8f7c5b6cb.tar.gz esper-testing-2eae4836279646050e7e342752cde6e8f7c5b6cb.tar.bz2 esper-testing-2eae4836279646050e7e342752cde6e8f7c5b6cb.tar.xz esper-testing-2eae4836279646050e7e342752cde6e8f7c5b6cb.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java b/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java new file mode 100644 index 0000000..603609e --- /dev/null +++ b/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousEventDao.java @@ -0,0 +1,27 @@ +package io.trygvis.esper.testing.gitorious; + +import java.sql.*; + +public class GitoriousEventDao { + private final PreparedStatement countEntryId; + private final PreparedStatement insertChange; + + public GitoriousEventDao(Connection c) throws SQLException { + countEntryId = c.prepareStatement("SELECT count(entry_id) FROM gitorious_event WHERE entry_id=?"); + insertChange = c.prepareStatement("INSERT INTO gitorious_event(entry_id, text) VALUES(?, ?)"); + } + + public int countEntryId(String entryId) throws SQLException { + countEntryId.setString(1, entryId); + try(ResultSet rs = countEntryId.executeQuery()) { + rs.next(); + return rs.getInt(1); + } + } + + public void insertChange(String entryId, String text) throws SQLException { + insertChange.setString(1, entryId); + insertChange.setString(2, text); + insertChange.executeUpdate(); + } +} |