Changeset: ddada013a065 for MonetDB URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=ddada013a065 Added Files: sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.err sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.out sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.err sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.out sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.err sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.out Branch: iot Log Message:
Approve output diffs (truncated from 361 to 300 lines): diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.err b/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.err new file mode 100644 --- /dev/null +++ b/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.err @@ -0,0 +1,34 @@ +stderr of test 'ais07` in directory 'sql/backends/monet5/iot/Tests/ais` itself: + + +# 11:07:39 > +# 11:07:39 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=35624" "--set" "mapi_usock=/var/tmp/mtest-21087/.s.monetdb.35624" "--set" "monet_prompt=" "--forcemito" "--dbpath=/export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais" +# 11:07:39 > + +# builtin opt gdk_dbpath = /export/scratch1/mk/iot//Linux/var/monetdb5/dbfarm/demo +# builtin opt gdk_debug = 0 +# builtin opt gdk_vmtrim = no +# builtin opt monet_prompt = > +# builtin opt monet_daemon = no +# builtin opt mapi_port = 50000 +# builtin opt mapi_open = false +# builtin opt mapi_autosense = false +# builtin opt sql_optimizer = default_pipe +# builtin opt sql_debug = 0 +# cmdline opt gdk_nr_threads = 0 +# cmdline opt mapi_open = true +# cmdline opt mapi_port = 35624 +# cmdline opt mapi_usock = /var/tmp/mtest-21087/.s.monetdb.35624 +# cmdline opt monet_prompt = +# cmdline opt gdk_dbpath = /export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais +# cmdline opt gdk_debug = 536870922 + +# 11:07:39 > +# 11:07:39 > "mclient" "-lsql" "-ftest" "-Eutf-8" "-i" "-e" "--host=/var/tmp/mtest-21087" "--port=35624" +# 11:07:39 > + + +# 11:07:39 > +# 11:07:39 > "Done." +# 11:07:39 > + diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.out b/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.out new file mode 100644 --- /dev/null +++ b/sql/backends/monet5/iot/Tests/ais/Tests/ais07.stable.out @@ -0,0 +1,86 @@ +stdout of test 'ais07` in directory 'sql/backends/monet5/iot/Tests/ais` itself: + + +# 11:07:39 > +# 11:07:39 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=35624" "--set" "mapi_usock=/var/tmp/mtest-21087/.s.monetdb.35624" "--set" "monet_prompt=" "--forcemito" "--dbpath=/export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais" +# 11:07:39 > + +# MonetDB 5 server v11.24.0 +# This is an unreleased version +# Serving database 'mTests_sql_backends_monet5_iot_Tests_ais', using 8 threads +# Compiled for x86_64-unknown-linux-gnu/64bit with 64bit OIDs and 128bit integers dynamically linked +# Found 15.589 GiB available main-memory. +# Copyright (c) 1993-July 2008 CWI. +# Copyright (c) August 2008-2016 MonetDB B.V., all rights reserved +# Visit http://www.monetdb.org/ for further information +# Listening for connection requests on mapi:monetdb://vienna.da.cwi.nl:35624/ +# Listening for UNIX domain connection requests on mapi:monetdb:///var/tmp/mtest-21087/.s.monetdb.35624 +# MonetDB/GIS module loaded +# MonetDB/SQL module loaded +# MonetDB/iot loaded + +Ready. +#WARNING To speedup calc.wkb a bulk operator implementation is needed +# X_113:bat[:wkb] := mal.multiplex("calc":str,"wkb":str,X_112:bat[:str],0:int,0:int); + +# 11:07:39 > +# 11:07:39 > "mclient" "-lsql" "-ftest" "-Eutf-8" "-i" "-e" "--host=/var/tmp/mtest-21087" "--port=35624" +# 11:07:39 > + +#SET SCHEMA ais; +#SET optimizer = 'iot_pipe'; +#CREATE FUNCTION geographic_to_cartesian(lat FLOAT, lon FLOAT) RETURNS CLOB +#BEGIN +# DECLARE deg_to_rad FLOAT, lat_rad FLOAT, lon_rad FLOAT, aux1 FLOAT, aux2 FLOAT; +# SET deg_to_rad = pi() / 180; +# SET lat_rad = lat * deg_to_rad; +# SET lon_rad = lon * deg_to_rad; +# SET aux1 = sys.cos(lat_rad); +# SET aux2 = 6371 * aux1; +# RETURN 'POINT( ' || aux2 * sys.cos(lon_rad) || ' ' || aux2 * sys.sin(lon_rad) || ' ' || 6371 * sys.sin(lat_rad) || ' )'; +#END; +#CREATE TABLE static_locations (harbor CHAR(32), field POLYGON); /* All major harbors of Amsterdam: https://en.wikipedia.org/wiki/Port_of_Amsterdam#Geography */ +#INSERT INTO static_locations VALUES ('Amerikahaven', 'POLYGON( (3871.44456893 322.23523795 5049.52694825, 3873.75021533 323.064093023 5047.70540553, 3873.71867646 323.885373981 5047.67697859, 3873.5017397 324.872292495 5047.78003345, 3872.7938342 325.19853123 5048.30217331, 3872.60164177 324.785093693 5048.47622229, 3872.6741224 323.809744716 5048.48327629, 3871.54981295 323.35946261 5049.37438737, 3871.44456893 322.23523795 5049.52694825) )'); /* Amerikahaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Petroleumhaven', 'POLYGON( (3871.97792572 328.849674441 5048.69149725, 3872.33795265 328.725455306 5048.42345247, 3872.43401269 329.066629268 5048.32754195, 3872.11428671 329.287777613 5048.55835959, 3872.00301454 329.044638923 5048.65955289, 3871.97792572 328.849674441 5048.69149725) )'); /* Petroleumhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Oostelijkhaven', 'POLYGON( (3874.76945837 332.896017406 5046.28406712, 3874.99350047 332.95621223 5046.1080579, 3875.1279382 334.058396133 5045.93197046, 3875.5579763 334.604372405 5045.56550708, 3875.35055079 335.984299981 5045.63312763, 3874.41663614 335.616780364 5046.3747489, 3874.6428613 333.721315622 5046.32676121, 3874.76945837 332.896017406 5046.28406712) )'); /* Oostelijkhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Afrikahaven', 'POLYGON( (3871.30476187 320.817833925 5049.72438438, 3872.88902009 321.220747092 5048.4838189, 3872.96603 321.966084418 5048.37726116, 3872.74497591 322.035368331 5048.54242065, 3871.38317977 321.685638604 5049.60905668, 3871.30476187 320.817833925 5049.72438438) )'); /* Afrikahaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('DeRuijterkadehaven', 'POLYGON( (3874.84907684 331.832795545 5046.29295895, 3874.5621738 332.100597943 5046.49563105, 3874.74221319 332.592560967 5046.32499644, 3875.14500709 332.378589729 5046.02979055, 3874.84907684 331.832795545 5046.29295895) )'); /* DeRuijterkadehaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Coenhaven', 'POLYGON( (3872.18320026 329.539035698 5048.48910938, 3872.7184903 329.096658095 5048.10735667, 3872.88840793 329.5493504 5047.9474646, 3872.80986545 329.954639206 5047.98124819, 3872.54376258 330.007944404 5048.18190674, 3872.3152549 329.754769754 5048.37373404, 3872.18320026 329.539035698 5048.48910938) )'); /* Coenhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Houthaven', 'POLYGON( (3872.87117926 330.512107085 5047.89773826, 3872.96624169 330.37417078 5047.83383225, 3873.54601208 330.634050719 5047.37193169, 3873.94528714 331.083171623 5047.03604561, 3873.97858621 331.533215981 5046.98094313, 3873.54647189 331.388091275 5047.32212793, 3872.86905716 330.50899826 5047.89956994, 3872.87117926 330.512107085 5047.89773826) )'); /* Houthaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('JanvanRiebeeckhaven', 'POLYGON( (3871.94120918 327.917683906 5048.780275, 3872.13342591 327.779180854 5048.64185109, 3872.08217261 327.044586025 5048.72879914, 3872.14824523 327.029747516 5048.67908578, 3872.20328537 327.665296944 5048.59566315, 3872.60946857 327.378362182 5048.30271596, 3872.70184991 327.573104981 5048.21921499, 3872.17072336 327.995591149 5048.59919, 3872.36759179 328.102800999 5048.44122339, 3872.6245223 327.885014862 5048.25828641, 3872.67235818 328.003023524 5048.21392403, 3872.48169232 328.150453288 5048.35060417, 3872.89890584 328.498434046 5048.00790847, 3872.68943537 328.702668473 5048.15531585, 3872.54528354 328.410031669 5048.28494422, 3871.93965888 328.154140123 5048.76610058, 3871.94120918 327.917683906 5048.780275) )'); /* JanvanRiebeeckhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Westhaven', 'POLYGON( (3871.6739966 324.806577833 5049.18628603, 3872.14078933 325.202088988 5048.80285899, 3872.12532899 325.551292003 5048.7922113, 3871.97172049 325.836261828 5048.89163344, 3873.7575901 326.565103468 5047.47445425, 3873.75724972 325.799548089 5047.52418763, 3874.0235621 325.991429546 5047.30740377, 3874.1699978 326.506372453 5047.16171891, 3874.16875642 327.01475571 5047.12975822, 3873.91395529 327.291366901 5047.30740377, 3873.58537382 327.672691046 5047.53483983, 3872.81792241 327.54936104 5048.13170945, 3872.87160844 326.694979039 5048.14588688, 3871.7994125 326.178096178 5049.00169924, 3871.6739966 324.806577833 5049.18628603) )'); /* Westhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Mercuriushaven', 'POLYGON( (3872.72450963 330.277569199 5048.02561402, 3873.1986563 329.657593618 5047.70235253, 3872.92006997 329.040734675 5047.95635149, 3873.11386675 328.884805095 5047.81782161, 3873.41352071 329.00959555 5047.57975505, 3873.61782996 329.465350531 5047.39323713, 3873.33890872 330.429316655 5047.54427072, 3872.9540041 330.381842104 5047.84271947, 3872.72450963 330.277569199 5048.02561402) )'); /* Mercuriushaven */ +[ 1 ] +#CREATE TABLE vessels7 (implicit_timestamp timestamp, mmsi int, lat real, lon real, nav_status tinyint, sog real, rotais smallint); +#INSERT INTO iot.webserverstreams SELECT tabl.id, 2 , 8, 's' FROM sys.tables tabl INNER JOIN sys.schemas sch ON tabl.schema_id = sch.id WHERE tabl.name = 'vessels7' AND sch.name = 'ais'; +[ 1 ] +#CREATE STREAM TABLE ais07r (calc_time timestamp, harbor char(32), mmsi int); +#CREATE PROCEDURE ais07q() +#BEGIN +# INSERT INTO ais07r +# WITH data AS (SELECT mmsi, geographic_to_cartesian(lat, lon) AS calc_point FROM vessels7 WHERE (implicit_timestamp, mmsi) IN (SELECT max(implicit_timestamp), mmsi FROM vessels7 WHERE nav_status = 1 GROUP BY mmsi)), +# results AS (SELECT harbor, mmsi FROM data CROSS JOIN static_locations WHERE sys.st_contains(field, calc_point)), +# data_time AS (SELECT current_timestamp AS cur_time) +# SELECT cur_time, harbor, mmsi FROM results CROSS JOIN data_time; +#END; +#DELETE FROM iot.webserverstreams; +[ 1 ] +#DROP PROCEDURE ais07q; +#DROP FUNCTION geographic_to_cartesian; +#DROP TABLE static_locations; +#DROP TABLE vessels7; +#DROP TABLE ais07r; + +# 11:07:39 > +# 11:07:39 > "Done." +# 11:07:39 > + diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.err b/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.err new file mode 100644 --- /dev/null +++ b/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.err @@ -0,0 +1,34 @@ +stderr of test 'ais10` in directory 'sql/backends/monet5/iot/Tests/ais` itself: + + +# 11:07:40 > +# 11:07:40 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=35624" "--set" "mapi_usock=/var/tmp/mtest-21087/.s.monetdb.35624" "--set" "monet_prompt=" "--forcemito" "--dbpath=/export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais" +# 11:07:40 > + +# builtin opt gdk_dbpath = /export/scratch1/mk/iot//Linux/var/monetdb5/dbfarm/demo +# builtin opt gdk_debug = 0 +# builtin opt gdk_vmtrim = no +# builtin opt monet_prompt = > +# builtin opt monet_daemon = no +# builtin opt mapi_port = 50000 +# builtin opt mapi_open = false +# builtin opt mapi_autosense = false +# builtin opt sql_optimizer = default_pipe +# builtin opt sql_debug = 0 +# cmdline opt gdk_nr_threads = 0 +# cmdline opt mapi_open = true +# cmdline opt mapi_port = 35624 +# cmdline opt mapi_usock = /var/tmp/mtest-21087/.s.monetdb.35624 +# cmdline opt monet_prompt = +# cmdline opt gdk_dbpath = /export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais +# cmdline opt gdk_debug = 536870922 + +# 11:07:40 > +# 11:07:40 > "mclient" "-lsql" "-ftest" "-Eutf-8" "-i" "-e" "--host=/var/tmp/mtest-21087" "--port=35624" +# 11:07:40 > + + +# 11:07:40 > +# 11:07:40 > "Done." +# 11:07:40 > + diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.out b/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.out new file mode 100644 --- /dev/null +++ b/sql/backends/monet5/iot/Tests/ais/Tests/ais10.stable.out @@ -0,0 +1,85 @@ +stdout of test 'ais10` in directory 'sql/backends/monet5/iot/Tests/ais` itself: + + +# 11:07:40 > +# 11:07:40 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=35624" "--set" "mapi_usock=/var/tmp/mtest-21087/.s.monetdb.35624" "--set" "monet_prompt=" "--forcemito" "--dbpath=/export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais" +# 11:07:40 > + +# MonetDB 5 server v11.24.0 +# This is an unreleased version +# Serving database 'mTests_sql_backends_monet5_iot_Tests_ais', using 8 threads +# Compiled for x86_64-unknown-linux-gnu/64bit with 64bit OIDs and 128bit integers dynamically linked +# Found 15.589 GiB available main-memory. +# Copyright (c) 1993-July 2008 CWI. +# Copyright (c) August 2008-2016 MonetDB B.V., all rights reserved +# Visit http://www.monetdb.org/ for further information +# Listening for connection requests on mapi:monetdb://vienna.da.cwi.nl:35624/ +# Listening for UNIX domain connection requests on mapi:monetdb:///var/tmp/mtest-21087/.s.monetdb.35624 +# MonetDB/GIS module loaded +# MonetDB/SQL module loaded +# MonetDB/iot loaded + +Ready. +#WARNING To speedup calc.wkb a bulk operator implementation is needed +# X_103:bat[:wkb] := mal.multiplex("calc":str,"wkb":str,X_181:bat[:str],0:int,0:int); + +# 11:07:40 > +# 11:07:40 > "mclient" "-lsql" "-ftest" "-Eutf-8" "-i" "-e" "--host=/var/tmp/mtest-21087" "--port=35624" +# 11:07:40 > + +#SET SCHEMA ais; +#SET optimizer = 'iot_pipe'; +#CREATE FUNCTION geographic_to_cartesian(lat FLOAT, lon FLOAT) RETURNS CLOB +#BEGIN +# DECLARE deg_to_rad FLOAT, lat_rad FLOAT, lon_rad FLOAT, aux1 FLOAT, aux2 FLOAT; +# SET deg_to_rad = pi() / 180; +# SET lat_rad = lat * deg_to_rad; +# SET lon_rad = lon * deg_to_rad; +# SET aux1 = sys.cos(lat_rad); +# SET aux2 = 6371 * aux1; +# RETURN 'POINT( ' || aux2 * sys.cos(lon_rad) || ' ' || aux2 * sys.sin(lon_rad) || ' ' || 6371 * sys.sin(lat_rad) || ' )'; +#END; +#CREATE TABLE static_locations (harbor CHAR(32), field POLYGON); /* All major harbors of Amsterdam: https://en.wikipedia.org/wiki/Port_of_Amsterdam#Geography */ +#INSERT INTO static_locations VALUES ('Amerikahaven', 'POLYGON( (3871.44456893 322.23523795 5049.52694825, 3873.75021533 323.064093023 5047.70540553, 3873.71867646 323.885373981 5047.67697859, 3873.5017397 324.872292495 5047.78003345, 3872.7938342 325.19853123 5048.30217331, 3872.60164177 324.785093693 5048.47622229, 3872.6741224 323.809744716 5048.48327629, 3871.54981295 323.35946261 5049.37438737, 3871.44456893 322.23523795 5049.52694825) )'); /* Amerikahaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Petroleumhaven', 'POLYGON( (3871.97792572 328.849674441 5048.69149725, 3872.33795265 328.725455306 5048.42345247, 3872.43401269 329.066629268 5048.32754195, 3872.11428671 329.287777613 5048.55835959, 3872.00301454 329.044638923 5048.65955289, 3871.97792572 328.849674441 5048.69149725) )'); /* Petroleumhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Oostelijkhaven', 'POLYGON( (3874.76945837 332.896017406 5046.28406712, 3874.99350047 332.95621223 5046.1080579, 3875.1279382 334.058396133 5045.93197046, 3875.5579763 334.604372405 5045.56550708, 3875.35055079 335.984299981 5045.63312763, 3874.41663614 335.616780364 5046.3747489, 3874.6428613 333.721315622 5046.32676121, 3874.76945837 332.896017406 5046.28406712) )'); /* Oostelijkhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Afrikahaven', 'POLYGON( (3871.30476187 320.817833925 5049.72438438, 3872.88902009 321.220747092 5048.4838189, 3872.96603 321.966084418 5048.37726116, 3872.74497591 322.035368331 5048.54242065, 3871.38317977 321.685638604 5049.60905668, 3871.30476187 320.817833925 5049.72438438) )'); /* Afrikahaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('DeRuijterkadehaven', 'POLYGON( (3874.84907684 331.832795545 5046.29295895, 3874.5621738 332.100597943 5046.49563105, 3874.74221319 332.592560967 5046.32499644, 3875.14500709 332.378589729 5046.02979055, 3874.84907684 331.832795545 5046.29295895) )'); /* DeRuijterkadehaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Coenhaven', 'POLYGON( (3872.18320026 329.539035698 5048.48910938, 3872.7184903 329.096658095 5048.10735667, 3872.88840793 329.5493504 5047.9474646, 3872.80986545 329.954639206 5047.98124819, 3872.54376258 330.007944404 5048.18190674, 3872.3152549 329.754769754 5048.37373404, 3872.18320026 329.539035698 5048.48910938) )'); /* Coenhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Houthaven', 'POLYGON( (3872.87117926 330.512107085 5047.89773826, 3872.96624169 330.37417078 5047.83383225, 3873.54601208 330.634050719 5047.37193169, 3873.94528714 331.083171623 5047.03604561, 3873.97858621 331.533215981 5046.98094313, 3873.54647189 331.388091275 5047.32212793, 3872.86905716 330.50899826 5047.89956994, 3872.87117926 330.512107085 5047.89773826) )'); /* Houthaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('JanvanRiebeeckhaven', 'POLYGON( (3871.94120918 327.917683906 5048.780275, 3872.13342591 327.779180854 5048.64185109, 3872.08217261 327.044586025 5048.72879914, 3872.14824523 327.029747516 5048.67908578, 3872.20328537 327.665296944 5048.59566315, 3872.60946857 327.378362182 5048.30271596, 3872.70184991 327.573104981 5048.21921499, 3872.17072336 327.995591149 5048.59919, 3872.36759179 328.102800999 5048.44122339, 3872.6245223 327.885014862 5048.25828641, 3872.67235818 328.003023524 5048.21392403, 3872.48169232 328.150453288 5048.35060417, 3872.89890584 328.498434046 5048.00790847, 3872.68943537 328.702668473 5048.15531585, 3872.54528354 328.410031669 5048.28494422, 3871.93965888 328.154140123 5048.76610058, 3871.94120918 327.917683906 5048.780275) )'); /* JanvanRiebeeckhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Westhaven', 'POLYGON( (3871.6739966 324.806577833 5049.18628603, 3872.14078933 325.202088988 5048.80285899, 3872.12532899 325.551292003 5048.7922113, 3871.97172049 325.836261828 5048.89163344, 3873.7575901 326.565103468 5047.47445425, 3873.75724972 325.799548089 5047.52418763, 3874.0235621 325.991429546 5047.30740377, 3874.1699978 326.506372453 5047.16171891, 3874.16875642 327.01475571 5047.12975822, 3873.91395529 327.291366901 5047.30740377, 3873.58537382 327.672691046 5047.53483983, 3872.81792241 327.54936104 5048.13170945, 3872.87160844 326.694979039 5048.14588688, 3871.7994125 326.178096178 5049.00169924, 3871.6739966 324.806577833 5049.18628603) )'); /* Westhaven */ +[ 1 ] +#INSERT INTO static_locations VALUES ('Mercuriushaven', 'POLYGON( (3872.72450963 330.277569199 5048.02561402, 3873.1986563 329.657593618 5047.70235253, 3872.92006997 329.040734675 5047.95635149, 3873.11386675 328.884805095 5047.81782161, 3873.41352071 329.00959555 5047.57975505, 3873.61782996 329.465350531 5047.39323713, 3873.33890872 330.429316655 5047.54427072, 3872.9540041 330.381842104 5047.84271947, 3872.72450963 330.277569199 5048.02561402) )'); /* Mercuriushaven */ +[ 1 ] +#CREATE TABLE vessels10 (implicit_timestamp timestamp, mmsi int, lat real, lon real, nav_status tinyint, sog real, rotais smallint); +#INSERT INTO iot.webserverstreams SELECT tabl.id, 2 , 8, 's' FROM sys.tables tabl INNER JOIN sys.schemas sch ON tabl.schema_id = sch.id WHERE tabl.name = 'vessels10' AND sch.name = 'ais'; +[ 1 ] +#CREATE STREAM TABLE ais10r (calc_time timestamp, harbor char(32), mmsi int, time_left float); /* in hours */ +#CREATE PROCEDURE ais10q() +#BEGIN +# INSERT INTO ais10r +# WITH data AS (SELECT harbor, mmsi, sog, sys.st_distance(field, geographic_to_cartesian(lat, lon)) AS distance FROM vessels10 CROSS JOIN static_locations WHERE (implicit_timestamp, mmsi) IN (SELECT max(implicit_timestamp), mmsi FROM vessels10 GROUP BY mmsi)), +# data_time AS (SELECT current_timestamp AS cur_time) +# SELECT cur_time, harbor, mmsi, distance / sog * 1.852 FROM data CROSS JOIN data_time WHERE distance > 0; +#END; +#DELETE FROM iot.webserverstreams; +[ 1 ] +#DROP PROCEDURE ais10q; +#DROP FUNCTION geographic_to_cartesian; +#DROP TABLE static_locations; +#DROP TABLE vessels10; +#DROP TABLE ais10r; + +# 11:07:40 > +# 11:07:40 > "Done." +# 11:07:40 > + diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.err b/sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.err new file mode 100644 --- /dev/null +++ b/sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.err @@ -0,0 +1,34 @@ +stderr of test 'ais11` in directory 'sql/backends/monet5/iot/Tests/ais` itself: + + +# 11:07:40 > +# 11:07:40 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=35624" "--set" "mapi_usock=/var/tmp/mtest-21087/.s.monetdb.35624" "--set" "monet_prompt=" "--forcemito" "--dbpath=/export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais" +# 11:07:40 > + +# builtin opt gdk_dbpath = /export/scratch1/mk/iot//Linux/var/monetdb5/dbfarm/demo +# builtin opt gdk_debug = 0 +# builtin opt gdk_vmtrim = no +# builtin opt monet_prompt = > +# builtin opt monet_daemon = no +# builtin opt mapi_port = 50000 +# builtin opt mapi_open = false +# builtin opt mapi_autosense = false +# builtin opt sql_optimizer = default_pipe +# builtin opt sql_debug = 0 +# cmdline opt gdk_nr_threads = 0 +# cmdline opt mapi_open = true +# cmdline opt mapi_port = 35624 +# cmdline opt mapi_usock = /var/tmp/mtest-21087/.s.monetdb.35624 +# cmdline opt monet_prompt = +# cmdline opt gdk_dbpath = /export/scratch1/mk/default//Linux/var/MonetDB/mTests_sql_backends_monet5_iot_Tests_ais +# cmdline opt gdk_debug = 536870922 + +# 11:07:41 > +# 11:07:41 > "mclient" "-lsql" "-ftest" "-Eutf-8" "-i" "-e" "--host=/var/tmp/mtest-21087" "--port=35624" +# 11:07:41 > + + +# 11:07:41 > +# 11:07:41 > "Done." +# 11:07:41 > + diff --git a/sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.out b/sql/backends/monet5/iot/Tests/ais/Tests/ais11.stable.out new file mode 100644 _______________________________________________ checkin-list mailing list checkin-list@monetdb.org https://www.monetdb.org/mailman/listinfo/checkin-list
