From af92579129943acac73542f4e05e1c7faeda0994 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Mon, 19 Nov 2012 18:04:49 +0100
Subject: o Adding logic to stop fetching pages when Gitorious returns non-XML
 response. o Adding support for self-signed certificates with https. o Moving
 client code to GitoriousClient. o Adding Nexus client and an importer that
 fetches all artifacts. o A nexus client that actually fetches the entire set
 of artifacts.

---
 .../io/trygvis/esper/testing/nexus/NexusDao.java   | 52 ++++++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100755 src/main/java/io/trygvis/esper/testing/nexus/NexusDao.java

(limited to 'src/main/java/io/trygvis/esper/testing/nexus/NexusDao.java')

diff --git a/src/main/java/io/trygvis/esper/testing/nexus/NexusDao.java b/src/main/java/io/trygvis/esper/testing/nexus/NexusDao.java
new file mode 100755
index 0000000..39d4233
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/nexus/NexusDao.java
@@ -0,0 +1,52 @@
+package io.trygvis.esper.testing.nexus;
+
+import fj.data.*;
+import static fj.data.Option.*;
+import io.trygvis.esper.testing.*;
+import org.joda.time.*;
+
+import java.sql.*;
+
+public class NexusDao extends Dao {
+    protected NexusDao(Connection c) {
+        super(c);
+    }
+
+    public void insertRepository(String repositoryId, LocalDateTime discoveryDate) throws SQLException {
+        PreparedStatement s = prepareStatement("INSERT INTO nexus_repository(id) VALUES(?)");
+        s.setString(1, repositoryId);
+        s.executeUpdate();
+    }
+
+    public Option<NexusRepository> selectRepository(String repositoryId) throws SQLException {
+        PreparedStatement s = prepareStatement("SELECT id, discovery_date, last_update, last_successful_update FROM nexus_repository WHERE id=?");
+        s.setString(1, repositoryId);
+
+        try (ResultSet rs = s.executeQuery()) {
+            if (!rs.next()) {
+                return Option.none();
+            }
+
+            return some(new NexusRepository(
+                    rs.getString(1),
+                    fromNull(rs.getTimestamp(2)).map(timestampToLocalDateTime),
+                    fromNull(rs.getTimestamp(3)).map(timestampToLocalDateTime),
+                    fromNull(rs.getTimestamp(4)).map(timestampToLocalDateTime)
+            ));
+        }
+    }
+}
+
+class NexusRepository {
+    public final String repositoryId;
+    public final Option<LocalDateTime> discoveryDate;
+    public final Option<LocalDateTime> lastUpdate;
+    public final Option<LocalDateTime> lastSuccessfulUpdate;
+
+    NexusRepository(String repositoryId, Option<LocalDateTime> discoveryDate, Option<LocalDateTime> lastUpdate, Option<LocalDateTime> lastSuccessfulUpdate) {
+        this.repositoryId = repositoryId;
+        this.discoveryDate = discoveryDate;
+        this.lastUpdate = lastUpdate;
+        this.lastSuccessfulUpdate = lastSuccessfulUpdate;
+    }
+}
-- 
cgit v1.2.3