Changeset: 1c91b4d8981f for MonetDB URL: https://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=1c91b4d8981f Removed Files: sql/test/mapi/Tests/sql_int128.stable.out.int128.single Modified Files: sql/test/mapi/Tests/sql_int128.sql sql/test/mapi/Tests/sql_int128.stable.out.int128 Branch: Oct2020 Log Message:
Use sequential pipe and avoid another stable output diffs (truncated from 427 to 300 lines): diff --git a/sql/test/mapi/Tests/sql_int128.sql b/sql/test/mapi/Tests/sql_int128.sql --- a/sql/test/mapi/Tests/sql_int128.sql +++ b/sql/test/mapi/Tests/sql_int128.sql @@ -1,3 +1,4 @@ +set optimizer='sequential_pipe'; CREATE TABLE mytest(a HUGEINT, b HUGEINT, c HUGEINT, d HUGEINT, e HUGEINT); INSERT INTO mytest VALUES (1234567890987654321, 10000000000, NULL, NULL, NULL); explain UPDATE mytest SET a = 1234567890987654321; @@ -20,3 +21,4 @@ explain INSERT INTO sql_int128 VALUES (1 INSERT INTO sql_int128 VALUES (123456789098765432101234567890987654321); SELECT * FROM sql_int128; ROLLBACK; +set optimizer='default_pipe'; diff --git a/sql/test/mapi/Tests/sql_int128.stable.out.int128 b/sql/test/mapi/Tests/sql_int128.stable.out.int128 --- a/sql/test/mapi/Tests/sql_int128.stable.out.int128 +++ b/sql/test/mapi/Tests/sql_int128.stable.out.int128 @@ -12,9 +12,9 @@ stdout of test 'sql_int128` in directory % .explain # table_name % mal # name % clob # type -% 117 # length +% 120 # length function user.main():void; - X_1:void := querylog.define("explain update mytest set a = 1234567890987654321;":str, "default_pipe":str, 9:int); + X_1:void := querylog.define("explain update mytest set a = 1234567890987654321;":str, "sequential_pipe":str, 9:int); X_4:int := sql.mvc(); C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); X_10:bat[:hge] := algebra.project(C_5:bat[:oid], 1234567890987654321:hge); @@ -54,9 +54,9 @@ end user.main; % .explain # table_name % mal # name % clob # type -% 109 # length +% 112 # length function user.main():void; - X_1:void := querylog.define("explain update mytest set b = 10000000000;":str, "default_pipe":str, 9:int); + X_1:void := querylog.define("explain update mytest set b = 10000000000;":str, "sequential_pipe":str, 9:int); X_4:int := sql.mvc(); C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); X_10:bat[:hge] := algebra.project(C_5:bat[:oid], 10000000000:hge); @@ -96,10 +96,9 @@ end user.main; % .explain # table_name % mal # name % clob # type -% 104 # length +% 107 # length function user.main():void; - X_1:void := querylog.define("explain update mytest set c = a * b;":str, "default_pipe":str, 23:int); -barrier X_90:bit := language.dataflow(); + X_1:void := querylog.define("explain update mytest set c = a * b;":str, "sequential_pipe":str, 23:int); X_4:int := sql.mvc(); C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "a":str, 0:int); @@ -107,7 +106,6 @@ barrier X_90:bit := language.dataflow(); X_22:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "b":str, 0:int); X_30:bat[:hge] := algebra.projection(C_5:bat[:oid], X_22:bat[:hge]); X_31:bat[:hge] := batcalc.*(X_29:bat[:hge], X_30:bat[:hge], nil:BAT, nil:BAT); -exit X_90:bit; X_35:int := sql.update(X_4:int, "sys":str, "mytest":str, "c":str, C_5:bat[:oid], X_31:bat[:hge]); X_37:lng := aggr.count(C_5:bat[:oid]); sql.affectedRows(X_35:int, X_37:lng); @@ -144,10 +142,9 @@ end user.main; % .explain # table_name % mal # name % clob # type -% 104 # length +% 107 # length function user.main():void; - X_1:void := querylog.define("explain update mytest set d = c * b;":str, "default_pipe":str, 23:int); -barrier X_90:bit := language.dataflow(); + X_1:void := querylog.define("explain update mytest set d = c * b;":str, "sequential_pipe":str, 23:int); X_4:int := sql.mvc(); C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); X_22:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "c":str, 0:int); @@ -155,7 +152,6 @@ barrier X_90:bit := language.dataflow(); X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "b":str, 0:int); X_29:bat[:hge] := algebra.projection(C_5:bat[:oid], X_17:bat[:hge]); X_31:bat[:hge] := batcalc.*(X_30:bat[:hge], X_29:bat[:hge], nil:BAT, nil:BAT); -exit X_90:bit; X_35:int := sql.update(X_4:int, "sys":str, "mytest":str, "d":str, C_5:bat[:oid], X_31:bat[:hge]); X_37:lng := aggr.count(C_5:bat[:oid]); sql.affectedRows(X_35:int, X_37:lng); @@ -189,10 +185,9 @@ end user.main; % .explain # table_name % mal # name % clob # type -% 104 # length +% 107 # length function user.main():void; - X_1:void := querylog.define("explain update mytest set e = d + a;":str, "default_pipe":str, 23:int); -barrier X_90:bit := language.dataflow(); + X_1:void := querylog.define("explain update mytest set e = d + a;":str, "sequential_pipe":str, 23:int); X_4:int := sql.mvc(); C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); X_22:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "d":str, 0:int); @@ -200,7 +195,6 @@ barrier X_90:bit := language.dataflow(); X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "a":str, 0:int); X_29:bat[:hge] := algebra.projection(C_5:bat[:oid], X_17:bat[:hge]); X_31:bat[:hge] := batcalc.+(X_30:bat[:hge], X_29:bat[:hge], nil:BAT, nil:BAT); -exit X_90:bit; X_35:int := sql.update(X_4:int, "sys":str, "mytest":str, "e":str, C_5:bat[:oid], X_31:bat[:hge]); X_37:lng := aggr.count(C_5:bat[:oid]); sql.affectedRows(X_35:int, X_37:lng); @@ -260,9 +254,9 @@ end user.main; % .explain # table_name % mal # name % clob # type -% 147 # length +% 150 # length function user.main():void; - X_1:void := querylog.define("explain insert into sql_int128 values (123456789098765432101234567890987654321);":str, "default_pipe":str, 7:int); + X_1:void := querylog.define("explain insert into sql_int128 values (123456789098765432101234567890987654321);":str, "sequential_pipe":str, 7:int); X_4:int := sql.mvc(); X_8:int := sql.append(X_4:int, "sys":str, "sql_int128":str, "i":str, 123456789098765432101234567890987654321:hge); sql.affectedRows(X_8:int, 1:lng); diff --git a/sql/test/mapi/Tests/sql_int128.stable.out.int128.single b/sql/test/mapi/Tests/sql_int128.stable.out.int128.single deleted file mode 100644 --- a/sql/test/mapi/Tests/sql_int128.stable.out.int128.single +++ /dev/null @@ -1,307 +0,0 @@ -stdout of test 'sql_int128` in directory 'sql/test/mapi` itself: - - -# 07:30:43 > -# 07:30:43 > "mserver5" "--debug=10" "--set" "gdk_nr_threads=0" "--set" "mapi_open=true" "--set" "mapi_port=34256" "--set" "mapi_usock=/var/tmp/mtest-20272/.s.monetdb.34256" "--set" "monet_prompt=" "--forcemito" "--set" "mal_listing=2" "--dbpath=/ufs/manegold/_/Monet/HG/int128/prefix/_/var/MonetDB/mTests_sql_test_mapi" "--set" "mal_listing=0" -# 07:30:43 > - -#CREATE TABLE mytest(a HUGEINT, b HUGEINT, c HUGEINT, d HUGEINT, e HUGEINT); -#INSERT INTO mytest VALUES (1234567890987654321, 10000000000, NULL, NULL, NULL); -[ 1 ] -#explain UPDATE mytest SET a = 1234567890987654321; -% .explain # table_name -% mal # name -% clob # type -% 118 # length -function user.main():void; - X_1:void := querylog.define("explain update mytest set a = 1234567890987654321;":str, "default_pipe":str, 39:int); - X_4:int := sql.mvc(); - C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); - X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "a":str, 0:int); - X_47:bat[:hge] := algebra.projection(C_5:bat[:oid], X_17:bat[:hge]); - X_54:bat[:hge] := algebra.project(X_47:bat[:hge], 1234567890987654321:hge); - X_56:int := sql.update(X_4:int, "sys":str, "mytest":str, "a":str, C_5:bat[:oid], X_54:bat[:hge]); - X_59:lng := aggr.count(C_5:bat[:oid]); - sql.affectedRows(X_56:int, X_59:lng); -end user.main; -# optimizer.mitosis() -# optimizer.dataflow() -#inline actions= 0 time=0 usec -#remap actions= 0 time=1 usec -#costmodel actions= 1 time=1 usec -#coercion actions= 0 time=1 usec -#aliases actions= 1 time=2 usec -#evaluate actions= 1 time=8 usec -#emptybind actions= 0 time=0 usec -#pushselect actions= 0 time=2 usec -#aliases actions= 1 time=2 usec -#mergetable actions= 0 time=13 usec -#deadcode actions= 0 time=3 usec -#aliases actions= 0 time=0 usec -#constants actions= 0 time=1 usec -#commonTerms actions= 0 time=1 usec -#projectionpath actions= 0 time=1 usec -#deadcode actions= 0 time=2 usec -#reorder actions= 1 time=8 usec -#matpack actions= 0 time=0 usec -#dataflow actions= 0 time=3 usec -#multiplex actions= 0 time=0 usec -#profiler actions= 1 time=1 usec -#candidates actions= 1 time=1 usec -#deadcode actions= 0 time=2 usec -#wlc actions= 0 time=0 usec -#garbagecollector actions= 1 time=5 usec -#total actions=29 time=116 usec -#explain SET c = a * b; -% .explain # table_name -% mal # name -% clob # type -% 110 # length -function user.main():void; - X_1:void := querylog.define("explain update mytest set b = 10000000000;":str, "default_pipe":str, 39:int); - X_4:int := sql.mvc(); - C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); - X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "a":str, 0:int); - X_47:bat[:hge] := algebra.projection(C_5:bat[:oid], X_17:bat[:hge]); - X_54:bat[:hge] := algebra.project(X_47:bat[:hge], 10000000000:hge); - X_56:int := sql.update(X_4:int, "sys":str, "mytest":str, "b":str, C_5:bat[:oid], X_54:bat[:hge]); - X_59:lng := aggr.count(C_5:bat[:oid]); - sql.affectedRows(X_56:int, X_59:lng); -end user.main; -# optimizer.mitosis() -# optimizer.dataflow() -#inline actions= 0 time=1 usec -#remap actions= 0 time=2 usec -#costmodel actions= 1 time=1 usec -#coercion actions= 1 time=6 usec -#aliases actions= 1 time=6 usec -#evaluate actions= 0 time=5 usec -#emptybind actions= 6 time=10 usec -#pushselect actions= 0 time=9 usec -#aliases actions= 6 time=5 usec -#mergetable actions= 0 time=28 usec -#deadcode actions=22 time=10 usec -#aliases actions= 0 time=0 usec -#constants actions= 0 time=1 usec -#commonTerms actions= 0 time=1 usec -#projectionpath actions= 0 time=1 usec -#deadcode actions= 0 time=3 usec -#reorder actions= 1 time=10 usec -#matpack actions= 0 time=0 usec -#dataflow actions= 0 time=4 usec -#multiplex actions= 0 time=1 usec -#profiler actions= 1 time=1 usec -#candidates actions= 1 time=1 usec -#deadcode actions= 0 time=3 usec -#wlc actions= 0 time=0 usec -#garbagecollector actions= 1 time=8 usec -#total actions=29 time=141 usec -#explain SET d = c * b; -% .explain # table_name -% mal # name -% clob # type -% 104 # length -function user.main():void; - X_1:void := querylog.define("explain update mytest set c = a * b;":str, "default_pipe":str, 38:int); - X_4:int := sql.mvc(); - C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); - X_17:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "a":str, 0:int); - X_47:bat[:hge] := algebra.projection(C_5:bat[:oid], X_17:bat[:hge]); - X_22:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "b":str, 0:int); - X_48:bat[:hge] := algebra.projection(C_5:bat[:oid], X_22:bat[:hge]); - X_52:bat[:hge] := batcalc.*(X_47:bat[:hge], X_48:bat[:hge], nil:BAT, nil:BAT); - X_56:int := sql.update(X_4:int, "sys":str, "mytest":str, "c":str, C_5:bat[:oid], X_52:bat[:hge]); - X_58:lng := aggr.count(C_5:bat[:oid]); - sql.affectedRows(X_56:int, X_58:lng); -end user.main; -# optimizer.mitosis() -# optimizer.dataflow() -#inline actions= 0 time=1 usec -#remap actions= 0 time=1 usec -#costmodel actions= 1 time=0 usec -#coercion actions= 0 time=1 usec -#aliases actions= 0 time=0 usec -#evaluate actions= 0 time=2 usec -#emptybind actions= 0 time=0 usec -#pushselect actions= 0 time=2 usec -#aliases actions= 0 time=0 usec -#mergetable actions= 0 time=16 usec -#deadcode actions= 0 time=4 usec -#aliases actions= 0 time=0 usec -#constants actions= 0 time=1 usec -#commonTerms actions= 0 time=1 usec -#projectionpath actions= 0 time=1 usec -#deadcode actions= 0 time=2 usec -#reorder actions= 1 time=9 usec -#matpack actions= 0 time=0 usec -#dataflow actions= 0 time=3 usec -#multiplex actions= 0 time=1 usec -#profiler actions= 1 time=0 usec -#candidates actions= 1 time=1 usec -#deadcode actions= 0 time=3 usec -#wlc actions= 0 time=0 usec -#garbagecollector actions= 1 time=9 usec -#total actions=29 time=114 usec -#explain SET e = d + a; -% .explain # table_name -% mal # name -% clob # type -% 104 # length -function user.main():void; - X_1:void := querylog.define("explain update mytest set d = c * b;":str, "default_pipe":str, 38:int); - X_4:int := sql.mvc(); - C_5:bat[:oid] := sql.tid(X_4:int, "sys":str, "mytest":str); - X_28:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "c":str, 0:int); - X_49:bat[:hge] := algebra.projection(C_5:bat[:oid], X_28:bat[:hge]); - X_22:bat[:hge] := sql.bind(X_4:int, "sys":str, "mytest":str, "b":str, 0:int); - X_48:bat[:hge] := algebra.projection(C_5:bat[:oid], X_22:bat[:hge]); - X_52:bat[:hge] := batcalc.*(X_49:bat[:hge], X_48:bat[:hge], nil:BAT, nil:BAT); - X_56:int := sql.update(X_4:int, "sys":str, "mytest":str, "d":str, C_5:bat[:oid], X_52:bat[:hge]); - X_58:lng := aggr.count(C_5:bat[:oid]); - sql.affectedRows(X_56:int, X_58:lng); -end user.main; -# optimizer.mitosis() -# optimizer.dataflow() -#inline actions= 0 time=1 usec -#remap actions= 1 time=17 usec -#costmodel actions= 1 time=1 usec -#coercion actions= 0 time=2 usec -#aliases actions= 0 time=1 usec -#mergetable actions= 0 time=16 usec -#deadcode actions= 0 time=3 usec -#aliases actions= 0 time=0 usec -#constants actions= 0 time=1 usec -#commonTerms actions= 0 time=2 usec -#projectionpath actions= 0 time=1 usec -#deadcode actions= 0 time=2 usec -#reorder actions= 1 time=9 usec -#matpack actions= 0 time=1 usec -#dataflow actions= 0 time=3 usec -#multiplex actions= 0 time=1 usec _______________________________________________ checkin-list mailing list checkin-list@monetdb.org https://www.monetdb.org/mailman/listinfo/checkin-list