1 files changed, 8 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/util/sql/ResultSetF.java b/src/main/java/io/trygvis/esper/testing/util/sql/ResultSetF.java
index 5c51e6f..e911230 100755
--- a/src/main/java/io/trygvis/esper/testing/util/sql/ResultSetF.java
+++ b/src/main/java/io/trygvis/esper/testing/util/sql/ResultSetF.java
@@ -1,6 +1,7 @@
 package io.trygvis.esper.testing.util.sql;
 
 import io.trygvis.esper.testing.*;
+import org.joda.time.*;
 
 import java.sql.*;
 import java.util.*;
@@ -19,6 +20,13 @@ public class ResultSetF {
         }
     };
 
+    public static final SqlF<ResultSet, DateTime> getDateTime = new SqlF<ResultSet, DateTime>() {
+        public DateTime apply(ResultSet rs) throws SQLException {
+            Timestamp i = rs.getTimestamp(1);
+            return rs.wasNull() ? null : new DateTime(i.getTime());
+        }
+    };
+
     public static final SqlF<ResultSet, UUID> getUUID = new SqlF<ResultSet, UUID>() {
         public UUID apply(ResultSet rs) throws SQLException {
             return UUID.fromString(rs.getString(1));