diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-23 00:21:57 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-12-23 00:21:57 +0100 |
commit | eaa0a2a0828037227312970668eba7bf951b4049 (patch) | |
tree | eced0d4f6c1b53abe0b2af527ecba3bd493684cd /src/main/java/io/trygvis/esper/testing/core/db/FileDao.java | |
parent | 78e7933c0af1d11d9476c5ee213c64ad87066f55 (diff) | |
download | esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.gz esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.bz2 esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.tar.xz esper-testing-eaa0a2a0828037227312970668eba7bf951b4049.zip |
o Storing the raw bytes with the parsed data from Jenkins.
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/core/db/FileDao.java')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/core/db/FileDao.java | 29 |
1 files changed, 29 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 new file mode 100644 index 0000000..0878f63 --- /dev/null +++ b/src/main/java/io/trygvis/esper/testing/core/db/FileDao.java @@ -0,0 +1,29 @@ +package io.trygvis.esper.testing.core.db; + +import java.io.*; +import java.net.*; +import java.sql.*; +import java.util.*; + +import static java.lang.System.*; + +public class FileDao { + private final Connection c; + + public FileDao(Connection c) { + this.c = c; + } + + public void store(URI url, String contentType, byte[] data) throws SQLException { + try (PreparedStatement s = c.prepareStatement("INSERT INTO file(uuid, created_date, url, content_type, data) VALUES(?, ?, ?, ?, ?)")) { + UUID uuid = UUID.randomUUID(); + int i = 1; + s.setString(i++, uuid.toString()); + s.setTimestamp(i++, new Timestamp(currentTimeMillis())); + s.setString(i++, url.toASCIIString()); + s.setString(i++, contentType); + s.setBinaryStream(i, new ByteArrayInputStream(data), data.length); + s.executeUpdate(); + } + } +} |