From a63ec924e5440b17434ecc91e84d1419ae39ef2a Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Fri, 21 Dec 2012 22:24:41 +0100
Subject: o Adding a sequence number to jenkins_build. o Making the table
 poller poll based on a sequence number instead.

---
 .../io/trygvis/esper/testing/sql/ResultSetF.java   | 18 +++++++++++++++
 .../io/trygvis/esper/testing/sql/SqlOption.java    | 26 ++++++++++++++++++++++
 2 files changed, 44 insertions(+)
 create mode 100644 src/main/java/io/trygvis/esper/testing/sql/ResultSetF.java

(limited to 'src/main/java/io/trygvis/esper/testing/sql')

diff --git a/src/main/java/io/trygvis/esper/testing/sql/ResultSetF.java b/src/main/java/io/trygvis/esper/testing/sql/ResultSetF.java
new file mode 100644
index 0000000..e5a9e4e
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/sql/ResultSetF.java
@@ -0,0 +1,18 @@
+package io.trygvis.esper.testing.sql;
+
+import java.sql.*;
+
+public class ResultSetF {
+    public static final SqlF<ResultSet, Integer> getInt = new SqlF<ResultSet, Integer>() {
+        public Integer apply(ResultSet rs) throws SQLException {
+            return rs.getInt(1);
+        }
+    };
+
+    public static final SqlF<ResultSet, Integer> getInteger = new SqlF<ResultSet, Integer>() {
+        public Integer apply(ResultSet rs) throws SQLException {
+            int i = rs.getInt(1);
+            return rs.wasNull() ? null : i;
+        }
+    };
+}
diff --git a/src/main/java/io/trygvis/esper/testing/sql/SqlOption.java b/src/main/java/io/trygvis/esper/testing/sql/SqlOption.java
index 058435e..288735a 100644
--- a/src/main/java/io/trygvis/esper/testing/sql/SqlOption.java
+++ b/src/main/java/io/trygvis/esper/testing/sql/SqlOption.java
@@ -43,6 +43,16 @@ public abstract class SqlOption<A> {
         return !isSome();
     }
 
+    public abstract A getOrElse(A a);
+
+    public static <A> SqlOption<A> fromNull(A a) {
+        if (a != null) {
+            return some(a);
+        } else {
+            return none();
+        }
+    }
+
     // -----------------------------------------------------------------------
     //
     // -----------------------------------------------------------------------
@@ -59,6 +69,14 @@ public abstract class SqlOption<A> {
         public boolean isSome() {
             return false;
         }
+
+        public A getOrElse(A a) {
+            return a;
+        }
+
+        public String toString() {
+            return "None";
+        }
     }
 
     private static class Some<A> extends SqlOption<A> {
@@ -79,5 +97,13 @@ public abstract class SqlOption<A> {
         public boolean isSome() {
             return true;
         }
+
+        public A getOrElse(A a) {
+            return this.a;
+        }
+
+        public String toString() {
+            return "Some(" + a + ")";
+        }
     }
 }
-- 
cgit v1.2.3