1 files changed, 70 insertions, 0 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/esper/Test2.java b/src/main/java/io/trygvis/esper/testing/esper/Test2.java
new file mode 100755
index 0000000..ecd276a
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/esper/Test2.java
@@ -0,0 +1,70 @@
+package io.trygvis.esper.testing.esper;
+
+import com.espertech.esper.client.*;
+import io.trygvis.esper.testing.*;
+import org.slf4j.*;
+
+import javax.sql.*;
+import java.sql.*;
+import java.util.*;
+
+public class Test2 {
+    private static Config config;
+
+    @SuppressWarnings("UnusedDeclaration")
+    public static DataSource createDataSource(Properties p) throws SQLException {
+        return config.createBoneCp();
+    }
+
+    public static void main(String[] args) throws Exception {
+        config = Config.loadFromDisk();
+
+        Configuration c = new Configuration();
+
+        ConfigurationDBRef configurationDBRef = new ConfigurationDBRef();
+        configurationDBRef.setDataSourceFactory(new Properties(), Test2.class.getName());
+        configurationDBRef.setConnectionAutoCommit(true);
+        c.addDatabaseReference("db1", configurationDBRef);
+
+        c.addVariable("VarLastTimestamp", Long.class, Long.valueOf(0));
+
+//        c.addEventTypeAutoName(getClass().getPackage().getName());
+
+        EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(c);
+
+//        String expression = "select avg(price) from OrderEvent.win:time(30 sec)";
+
+        EPAdministrator administrator = epService.getEPAdministrator();
+
+        EPStatement statement = administrator.createEPL("insert into JenkinsBuild " +
+                "select uuid, job, result from pattern [every timer:interval(1 sec)], " +
+                "sql:db1 ['SELECT uuid, job, result FROM jenkins_build WHERE extract(epoch from created_date) > ${VarLastTimestamp}']");
+
+        Logger logger = LoggerFactory.getLogger("app");
+
+        statement.addListener(new GenericListener(logger));
+
+        administrator.createEPL("on JenkinsBuild set VarLastTimestamp = current_timestamp()");
+
+        administrator.createEPL("every build=JenkinsBuild(result='FAILURE') -> ((JenkinsBuild(job=build.job, result='FAILURE') and not Sample(sensor=sample.sensor, temp <= 50)) -> (Sample(sensor=sample.sensor, temp > 50) and not Sample(sensor=sample.sensor, temp <= 50))) where timer:within(90 seconds))\n");
+
+        while(true) {
+            Thread.sleep(10000);
+        }
+    }
+}
+
+/*
+every build=JenkinsBuild(result='FAILURE') ->
+ (
+  (
+   Sample(sensor=sample.sensor, temp > 50) and not
+   Sample(sensor=sample.sensor, temp <= 50)
+  ) ->
+  (
+   Sample(sensor=sample.sensor, temp > 50) and not
+   Sample(sensor=sample.sensor, temp <= 50)
+  )
+ )
+where timer:within(90 seconds))
+*/