aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/core/db
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2012-12-26 21:45:38 +0100
committerTrygve Laugstøl <trygvis@inamo.no>2012-12-26 21:45:38 +0100
commit422b1caeaa9f7d069a9208ecb0d0249485b1a05e (patch)
tree90ef9e1d0b6f26178f1fae3e3df20226a1d91087 /src/main/java/io/trygvis/esper/testing/core/db
parent348ec4e14aeaf4e98fcab96f0ae7242d178db69b (diff)
downloadesper-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.java18
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;