1 files changed, 14 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/core/db/FileDao.java b/src/main/java/io/trygvis/esper/testing/core/db/FileDao.java
index c418970..affe1c8 100644..100755
--- a/src/main/java/io/trygvis/esper/testing/core/db/FileDao.java
+++ b/src/main/java/io/trygvis/esper/testing/core/db/FileDao.java
@@ -1,10 +1,13 @@
 package io.trygvis.esper.testing.core.db;
 
+import io.trygvis.esper.testing.util.sql.*;
+
 import java.io.*;
 import java.net.*;
 import java.sql.*;
 import java.util.*;
 
+import static io.trygvis.esper.testing.util.sql.SqlOption.*;
 import static java.lang.System.*;
 
 public class FileDao {
@@ -27,4 +30,15 @@ public class FileDao {
             return uuid;
         }
     }
+
+    public SqlOption<InputStream> load(UUID uuid) throws SQLException {
+        try (PreparedStatement s = c.prepareStatement("SELECT data FROM file WHERE uuid=?")) {
+            s.setString(1, uuid.toString());
+            ResultSet rs = s.executeQuery();
+            if(!rs.next()) {
+                return none();
+            }
+            return some(rs.getBinaryStream(1));
+        }
+    }
 }