From bddca73748f7eace28cdd76282fcfd33971e9995 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Thu, 8 Nov 2012 00:55:32 +0100 Subject: wip --- src/main/java/io/trygvis/esper/testing/DbMain.java | 33 ++++++++++++++++++++++ 1 file changed, 33 insertions(+) create mode 100644 src/main/java/io/trygvis/esper/testing/DbMain.java (limited to 'src/main/java/io/trygvis/esper/testing/DbMain.java') diff --git a/src/main/java/io/trygvis/esper/testing/DbMain.java b/src/main/java/io/trygvis/esper/testing/DbMain.java new file mode 100644 index 0000000..635e3cc --- /dev/null +++ b/src/main/java/io/trygvis/esper/testing/DbMain.java @@ -0,0 +1,33 @@ +package io.trygvis.esper.testing; + +import org.h2.tools.*; + +import java.sql.*; + +public class DbMain { + private static final String JDBC_URL = "jdbc:h2:mem:esper;DB_CLOSE_DELAY=-1"; + + public static void main(String[] args) throws Exception { + Server server = Server.createTcpServer(args).start(); + + System.out.println("server.getURL() = " + server.getURL()); + + Connection connection = DriverManager.getConnection(JDBC_URL, "", ""); + connection.setAutoCommit(false); + Statement s = connection.createStatement(); + s.execute("create table subscription(" + + "itemName varchar(100) not null," + + "subscriber varchar(100) not null" + + ");"); + + s.execute("insert into subscription values('shirt', 'sub a');"); + s.execute("insert into subscription values('shirt', 'sub b');"); + s.execute("insert into subscription values('pants', 'sub b');"); + s.execute("insert into subscription values('pants', 'sub c');"); + connection.commit(); + + while(true) { + Thread.sleep(1000); + } + } +} -- cgit v1.2.3