Changeset: 638dbe5cf044 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=638dbe5cf044
Added Files:
sql/backends/monet5/datacell/Tests/dcload.sql
Branch: default
Log Message:
Temperature sensor experiment
These instructions are now parsed correctly and
the datacell is receiving the sensor information from
the replay.
The runtime execution still shows errors.
diffs (66 lines):
diff --git a/sql/backends/monet5/datacell/Tests/dcload.sql
b/sql/backends/monet5/datacell/Tests/dcload.sql
new file mode 100644
--- /dev/null
+++ b/sql/backends/monet5/datacell/Tests/dcload.sql
@@ -0,0 +1,61 @@
+CREATE TABLE "datacell"."sensors" (
+ "ip" INET,
+ "emit_time" TIMESTAMP,
+ "recv_time" TIMESTAMP,
+ "location" VARCHAR(20),
+ "type" VARCHAR(50),
+ "value" DOUBLE
+);
+create table datacell.warm(like datacell.sensors);
+create table datacell.hot(like datacell.sensors);
+
+CREATE TABLE "datacell"."alarm_warm" (
+ "ip" INET,
+ "emit_time" TIMESTAMP,
+ "location" VARCHAR(20),
+ "temperature" DOUBLE
+);
+
+CREATE TABLE "datacell"."alarm_hot" (
+ "ip" INET,
+ "emit_time" TIMESTAMP,
+ "location" VARCHAR(20),
+ "temperature" DOUBLE
+);
+
+CALL datacell.receptor('datacell.sensors', 'localhost', 50500);
+
+CALL datacell.emitter('datacell.alarm_warm', 'localhost', 50601);
+CALL datacell.emitter('datacell.alarm_hot', 'localhost', 50602);
+
+CALL datacell.basket('datacell.warm');
+CALL datacell.basket('datacell.hot');
+
+CREATE PROCEDURE datacell.warm()
+BEGIN
+ INSERT INTO datacell.alarm_warm
+ SELECT ip, emit_time, location, value
+ FROM datacell.warm
+ WHERE "type" LIKE 'temperature' AND value BETWEEN 21 AND 27;
+END;
+CALL datacell.query('datacell.warm');
+
+CREATE PROCEDURE datacell.hot()
+BEGIN
+ INSERT INTO datacell.alarm_hot
+ SELECT ip, emit_time, location, value
+ FROM datacell.hot
+ WHERE type LIKE 'temperature' AND value > 27;
+END;
+CALL datacell.query('datacell.hot');
+
+CREATE PROCEDURE datacell.splitter()
+BEGIN
+ INSERT INTO datacell.warm SELECT * FROM datacell.sensors;
+ INSERT INTO datacell.hot SELECT * FROM datacell.sensors;
+END;
+CALL datacell.query('datacell.splitter');
+
+CALL datacell.resume();
+SELECT * FROM datacell.receptors(); SELECT * FROM datacell.emitters(); SELECT
* FROM datacell.queries(); SELECT * FROM datacell.baskets();
+
_______________________________________________
Checkin-list mailing list
[email protected]
http://mail.monetdb.org/mailman/listinfo/checkin-list
