diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2013-04-20 15:43:01 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2013-04-20 15:43:01 +0200 |
commit | 637dddf11f5d60b35c9696914e1e2658b2ddc611 (patch) | |
tree | ef320c1950d78163dd0cc3247bee172f4e3e32ff /src/main/java/io/trygvis/queue/QueueDao.java | |
parent | c274d9177e4a495e7b793120dfd1ce12fa5632c7 (diff) | |
download | quartz-based-queue-637dddf11f5d60b35c9696914e1e2658b2ddc611.tar.gz quartz-based-queue-637dddf11f5d60b35c9696914e1e2658b2ddc611.tar.bz2 quartz-based-queue-637dddf11f5d60b35c9696914e1e2658b2ddc611.tar.xz quartz-based-queue-637dddf11f5d60b35c9696914e1e2658b2ddc611.zip |
wip
Diffstat (limited to 'src/main/java/io/trygvis/queue/QueueDao.java')
-rw-r--r-- | src/main/java/io/trygvis/queue/QueueDao.java | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/queue/QueueDao.java b/src/main/java/io/trygvis/queue/QueueDao.java new file mode 100644 index 0000000..a3a79ca --- /dev/null +++ b/src/main/java/io/trygvis/queue/QueueDao.java @@ -0,0 +1,34 @@ +package io.trygvis.queue; + +import org.springframework.beans.factory.annotation.*; +import org.springframework.jdbc.core.*; +import org.springframework.stereotype.*; + +import java.sql.*; + +import static org.springframework.dao.support.DataAccessUtils.*; + +@Component +public class QueueDao { + + @Autowired + private JdbcTemplate jdbcTemplate; + + public Queue findByName(String name) { + return singleResult(jdbcTemplate.query("SELECT name, interval FROM queue WHERE name=?", new QueueRowMapper(), name)); + } + + public void insert(Queue q) { + jdbcTemplate.update("INSERT INTO queue(name, interval) VALUES(?, ?)", q.name, q.interval); + } + + public void update(Queue q) { + jdbcTemplate.update("UPDATE queue SET interval=? WHERE name=?", q.interval, q.name); + } + + private class QueueRowMapper implements RowMapper<Queue> { + public Queue mapRow(ResultSet rs, int rowNum) throws SQLException { + return new Queue(rs.getString(1), rs.getLong(2)); + } + } +} |