diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-26 21:45:38 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-26 21:45:38 +0100 |
commit | 422b1caeaa9f7d069a9208ecb0d0249485b1a05e (patch) | |
tree | 90ef9e1d0b6f26178f1fae3e3df20226a1d91087 /src/main/java/io/trygvis/esper/testing/core/db | |
parent | 348ec4e14aeaf4e98fcab96f0ae7242d178db69b (diff) | |
download | esper-testing-422b1caeaa9f7d069a9208ecb0d0249485b1a05e.tar.gz esper-testing-422b1caeaa9f7d069a9208ecb0d0249485b1a05e.tar.bz2 esper-testing-422b1caeaa9f7d069a9208ecb0d0249485b1a05e.tar.xz esper-testing-422b1caeaa9f7d069a9208ecb0d0249485b1a05e.zip |
o Adding details page for persons.
o Better front page.
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/core/db')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/core/db/PersonDao.java | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/core/db/PersonDao.java b/src/main/java/io/trygvis/esper/testing/core/db/PersonDao.java index 6605999..62c4f2b 100644 --- a/src/main/java/io/trygvis/esper/testing/core/db/PersonDao.java +++ b/src/main/java/io/trygvis/esper/testing/core/db/PersonDao.java @@ -1,6 +1,5 @@ package io.trygvis.esper.testing.core.db; -import static io.trygvis.esper.testing.Util.toList; import io.trygvis.esper.testing.core.db.PersonBadgeDto.*; import io.trygvis.esper.testing.util.sql.*; import org.joda.time.*; @@ -8,6 +7,7 @@ import org.joda.time.*; import java.sql.*; import java.util.*; +import static io.trygvis.esper.testing.Util.*; import static io.trygvis.esper.testing.util.sql.SqlOption.*; import static java.lang.System.*; @@ -36,7 +36,7 @@ public class PersonDao { new DateTime(rs.getTimestamp(i++).getTime()), UUID.fromString(rs.getString(i++)), BadgeType.valueOf(rs.getString(i++)), - rs.getInt(i), + rs.getInt(i++), rs.getInt(i)); } }; @@ -63,16 +63,16 @@ public class PersonDao { // Person // ----------------------------------------------------------------------- - public SqlOption<PersonDto> selectPerson(String id) throws SQLException { - try (PreparedStatement s = c.prepareStatement("SELECT " + PERSON + " FROM person WHERE id=?")) { + public SqlOption<PersonDto> selectPerson(UUID uuid) throws SQLException { + try (PreparedStatement s = c.prepareStatement("SELECT " + PERSON + " FROM person WHERE uuid=?")) { int i = 1; - s.setString(i, id); + s.setString(i, uuid.toString()); return fromRs(s.executeQuery()).map(person); } } public List<PersonDto> selectPerson(PageRequest pageRequest) throws SQLException { - try (PreparedStatement s = c.prepareStatement("SELECT " + PERSON + " FROM person ORDER BY created_date LIMIT ? OFFSET ?")) { + try (PreparedStatement s = c.prepareStatement("SELECT " + PERSON + " FROM person ORDER BY created_date, name LIMIT ? OFFSET ?")) { int i = 1; s.setInt(i++, pageRequest.count.orSome(10)); s.setInt(i, pageRequest.startIndex.orSome(0)); @@ -80,6 +80,12 @@ public class PersonDao { } } + public int selectPersonCount() throws SQLException { + try (PreparedStatement s = c.prepareStatement("SELECT count(1) FROM person")) { + return fromRs(s.executeQuery()).map(ResultSetF.getInt).get(); + } + } + public SqlOption<PersonDto> selectPersonByJenkinsUuid(UUID jenkinsUser) throws SQLException { try (PreparedStatement s = c.prepareStatement("SELECT " + PERSON + " FROM person WHERE uuid=(SELECT person FROM person_jenkins_user WHERE jenkins_user=?)")) { int i = 1; |