Merge remote-tracking branch 'origin/master'

odbctest/mql/basic/01clear/1_delete_all_test_data.mql

@@ -515,6 +515,12 @@ onerror(continue,`not exist`,`not find`,`not found`)
 **/
 ;
 
+delete from /test/malert_status_local with version
+/**
+onerror(continue,`not exist`,`not find`,`not found`)
+**/
+;
+
 delete from /test/malert_status_seq with version
 /**
 onerror(continue,`not exist`,`not find`,`not found`)
@@ -533,19 +539,19 @@ onerror(continue,`not exist`,`not find`,`not found`)
 **/
 ;
 
-delete from /test/malert_status_seq3 with version
+delete from /test/alert_status_memdb with version
 /**
 onerror(continue,`not exist`,`not find`,`not found`)
 **/
 ;
 
-delete from /test/malert_status3 with version
+delete from /test/alert_status_cache with version
 /**
 onerror(continue,`not exist`,`not find`,`not found`)
 **/
 ;
 
-delete from /test/alert_status3 with version
+delete from /test/alert_status_local with version
 /**
 onerror(continue,`not exist`,`not find`,`not found`)
 **/
@@ -599,25 +605,7 @@ onerror(continue,`not exist`,`not find`,`not found`)
 **/
 ;
 
-delete from /test/delete2 with version
-/**
-onerror(continue,`not exist`,`not find`,`not found`)
-**/
-;
-
-delete from /test/delete3 with version
-/**
-onerror(continue,`not exist`,`not find`,`not found`)
-**/
-;
-
-delete from /test/delete4 with version
-/**
-onerror(continue,`not exist`,`not find`,`not found`)
-**/
-;
-
-delete from /test with version
+delete from /test/ with version
 /**
 onerror(continue,`not exist`,`not find`,`not found`)
 **/

odbctest/mql/basic/01clear/2_drop_all_test_class.mql

@@ -89,12 +89,13 @@ drop class if exists /test/interface ;
 
 drop class if exists /test/malert_status_memdb ;
 drop class if exists /test/malert_status_cache ;
+drop class if exists /test/malert_status_local ;
 drop class if exists /test/malert_status_seq ;
 drop class if exists /test/malert_status ;
 drop class if exists /test/alert_status ;
-drop class if exists /test/malert_status_seq3 ;
-drop class if exists /test/malert_status3 ;
-drop class if exists /test/alert_status3 ;
+drop class if exists /test/alert_status_cache ;
+drop class if exists /test/alert_status_local ;
+drop class if exists /test/alert_status_memdb ;
 
 drop class if exists /test/datetime ;
 
@@ -122,9 +123,5 @@ drop class if exists /test/abc ;
 
 drop class if exists /test/foo ;
 
-drop class if exists /test/delete2 ;
-drop class if exists /test/delete3 ;
-drop class if exists /test/delete4 ;
-
-drop class if exists /test ;
+drop class if exists /test/ ;
 

odbctest/mql/basic/30conflict/10clear.mql

@@ -10,19 +10,6 @@ delete from /test/malert_status with version ;
 onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
 **/
 ;
-
-
-delete from /test/malert_status_memdb with version ;
-/**
-onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
-**/
-;
-
-delete from /test/malert_status_cache with version ;
-/**
-onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
-**/
-;
         
 delete from /test/malert_status_seq with version ;
 /**

odbctest/mql/basic/30conflict/20valid.mql

@@ -1,6 +1,6 @@
 
 /**
-sleep(5s)
+sleep(3s)
 **/;
 
 select tally FROM /test/alert_status refresh

odbctest/mql/basic/30conflictcache/10clear.mql

@@ -0,0 +1,12 @@
+
+delete from /test/alert_status_cache with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;
+
+delete from /test/malert_status_cache with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;

odbctest/mql/basic/30conflictcache/13data_update.mql

@@ -0,0 +1,24 @@
+
+update /test/alert_status_cache set connect = nil
+;
+
+select connect FROM /test/alert_status_cache refresh
+/**
+output()
+matchcount("connect._all.len",0,4)
+**/
+;
+
+update /test/alert_status_cache set connect = connect + "Project:prj{%d,mqli}"
+/**
+loop(10)
+parallel(10)
+**/
+;
+
+select connect FROM /test/alert_status_cache refresh
+/**
+output()
+matchcount("connect._all.len",10,4)
+**/
+;

odbctest/mql/basic/30conflictcache/14update_tags.mql

@@ -0,0 +1,36 @@
+
+update /test/alert_status_cache set tags = "mytag6" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_cache set tags = "mytag7" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.7'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_cache set tags = "mytag8" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.8'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_cache set tags = "mytag9" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.9'
+/**
+fork(a)
+**/
+;
+
+/**
+wait(a)
+sleep(2s)
+**/;
+
+select tags FROM /test/alert_status_cache refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;

odbctest/mql/basic/30conflictcachedb/15concur.mql

@@ -1,12 +1,8 @@
 
-
-
-
-
-insert into /test/malert_status3 (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+insert into /test/malert_status_cache (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
 /**
-loop(10000)
-parallel(1000)
+loop(2000)
+parallel(100)
 beforerun(
     set(ct,now),
     add(ct,1,second),

odbctest/mql/basic/30conflictcache/20valid.mql

@@ -0,0 +1,26 @@
+
+/**
+sleep(3s)
+**/;
+
+select tally FROM /test/alert_status_cache refresh
+/**
+output()
+matchcount("tally", 40, 4)
+**/
+;
+
+select tags FROM /test/alert_status_cache refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;
+
+select id, identifier, lastoccurrence from /test/alert_status_cache
+where severity < 1 and manager=? and lastoccurrence > 1622249714000
+/**
+output()
+params(nil)
+**/
+;

odbctest/mql/basic/30conflictcache/25update.mql

@@ -0,0 +1,41 @@
+
+
+
+update /test/alert_status_cache set test='aaa'
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_cache
+/**
+output()
+matchcount(id, "31245179064114961", test, "aaa", 1)
+**/
+;
+
+update /test/alert_status_cache set test='xxx' where id="31245179064114961"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_cache
+/**
+output()
+matchcount(id, "31245179064114961", test, "xxx", 1)
+**/
+;
+
+update /test/alert_status_cache set test='xxx' where id="31245179064114961"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_cache
+/**
+output()
+matchcount(id, "31245179064114961", test, "xxx", 1)
+**/
+;

odbctest/mql/basic/30conflictcache/26mupdate.mql

@@ -0,0 +1,81 @@
+
+
+
+insert into /test/malert_status_cache (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+/**
+params("xxx", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", 1, "huawei mttrapd #1", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:222.129.134.178电源整体功能恢复!", "xxx")
+**/
+;
+
+select * from /test/malert_status_cache limit -1
+/**
+output()
+count(2001)
+**/
+;
+
+
+update /test/malert_status_cache set summary='xxx' where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_cache where identifier='xxx'
+/**
+output()
+matchcount(identifier, "xxx", summary, "xxx", 1)
+**/
+;
+
+update /test/malert_status_cache set summary='aaa' where id='z0000000000012CewoVSJrp'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_cache where id='z0000000000012CewoVSJrp'
+/**
+output()
+matchcount(id, "z0000000000012CewoVSJrp", summary, "aaa", 1)
+**/
+;
+
+update /test/malert_status_cache set summary='xxx' where id='z0000000000012CewoVSJrp'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_cache where id='z0000000000012CewoVSJrp'
+/**
+output()
+matchcount(id, "z0000000000012CewoVSJrp", summary, "xxx", 1)
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_cache where identifier='xxx'
+/**
+output()
+**/
+;
+
+delete from /test/malert_status_cache where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_cache where identifier='xxx'
+/**
+output()
+count(0)
+**/
+;
+
+select count(*) from /test/malert_status_cache
+/**
+output()
+matchcount("count", 2000, 1)
+**/
+;

odbctest/mql/basic/30conflictcachedb/13data_update.mql

@@ -1,15 +0,0 @@
-
-/**
-sleep(10s)
-**/;
-
-update /test/alert_status3 set connect = connect + "Project:prj{%d,mqli}"
-/**
-loop(10)
-parallel(10)
-**/
-;
-
-/**
-sleep(5s)
-**/;

odbctest/mql/basic/30conflictcachedb/14update_tags.mql

@@ -1,29 +0,0 @@
-
-update /test/alert_status3 set tags = "mytag6" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6'
-/**
-fork(a)
-**/
-;
-
-update /test/alert_status3 set tags = "mytag7" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.7'
-/**
-fork(a)
-**/
-;
-
-update /test/alert_status3 set tags = "mytag8" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.8'
-/**
-fork(a)
-**/
-;
-
-update /test/alert_status3 set tags = "mytag9" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.9'
-/**
-fork(a)
-**/
-;
-
-/**
-wait(a)
-sleep(1s)
-**/;

odbctest/mql/basic/30conflictcachedb/20valid.mql

@@ -1,25 +0,0 @@
-
-/**
-sleep(5s)
-**/;
-
-select tally FROM /test/alert_status3 refresh
-/**
-output()
-matchcount("tally", 20, 4)
-**/
-;
-
-select tags FROM /test/alert_status3 refresh
-/**
-output()
-matchcount("tags.len",1,4)
-**/
-;
-
-select connect FROM /test/alert_status3 refresh
-/**
-output()
-matchcount("connect._all.len",10,4)
-**/
-;

odbctest/mql/basic/30conflictlocal/10clear.mql

@@ -0,0 +1,12 @@
+
+delete from /test/alert_status_local with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;
+
+delete from /test/malert_status_local with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;

odbctest/mql/basic/30conflictlocal/13data_update.mql

@@ -0,0 +1,24 @@
+
+update /test/alert_status_local set connect = nil
+;
+
+select connect FROM /test/alert_status_local refresh
+/**
+output()
+matchcount("connect._all.len",0,4)
+**/
+;
+
+update /test/alert_status_local set connect = connect + "Project:prj{%d,mqli}"
+/**
+loop(10)
+parallel(10)
+**/
+;
+
+select connect FROM /test/alert_status_local refresh
+/**
+output()
+matchcount("connect._all.len",10,4)
+**/
+;

odbctest/mql/basic/30conflictlocal/14update_tags.mql

@@ -0,0 +1,36 @@
+
+update /test/alert_status_local set tags = "mytag6" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_local set tags = "mytag7" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.7'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_local set tags = "mytag8" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.8'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_local set tags = "mytag9" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.9'
+/**
+fork(a)
+**/
+;
+
+/**
+wait(a)
+sleep(2s)
+**/;
+
+select tags FROM /test/alert_status_local refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;

odbctest/mql/basic/30conflictlocal/15concur.mql

@@ -0,0 +1,23 @@
+
+insert into /test/malert_status_local (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+/**
+loop(2000)
+parallel(100)
+beforerun(
+    set(ct,now),
+    add(ct,1,second),
+	set(t10,mqli),
+	mod(t10,10),
+    set(mtype, t10),
+	set(tag,"mytag"),
+	case(t10==1,set(tag,"mytag1")),
+	case(t10==2,set(tag,"mytag2")),
+	case(t10==3,set(tag,"mytag3")),
+	case(t10==4,set(tag,"mytag4")),
+	case(t10==5,set(tag,"mytag5")),
+    set(t100,mqli),
+	mod(t100,100)
+)
+params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6{%d,mqli}", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", {%d,mtype}, "huawei mttrapd #{%d,t100}", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:222.129.134.178电源整体功能恢复!", "{%s,tag}")
+**/
+;

odbctest/mql/basic/30conflictlocal/20valid.mql

@@ -0,0 +1,26 @@
+
+/**
+sleep(3s)
+**/;
+
+select tally FROM /test/alert_status_local refresh
+/**
+output()
+matchcount("tally", 40, 4)
+**/
+;
+
+select tags FROM /test/alert_status_local refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;
+
+select id, identifier, lastoccurrence from /test/alert_status_local
+where severity < 1 and manager=? and lastoccurrence > 1622249714000
+/**
+output()
+params(nil)
+**/
+;

odbctest/mql/basic/30conflictlocal/25update.mql

@@ -0,0 +1,41 @@
+
+
+
+update /test/alert_status_local set test='aaa'
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_local
+/**
+output()
+matchcount(id, "3882396565548614434", test, "aaa", 1)
+**/
+;
+
+update /test/alert_status_local set test='xxx' where id="3882396565548614434"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_local
+/**
+output()
+matchcount(id, "3882396565548614434", test, "xxx", 1)
+**/
+;
+
+update /test/alert_status_local set test='xxx' where id="3882396565548614434"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_local
+/**
+output()
+matchcount(id, "3882396565548614434", test, "xxx", 1)
+**/
+;

odbctest/mql/basic/30conflictlocal/26mupdate.mql

@@ -0,0 +1,81 @@
+
+
+
+insert into /test/malert_status_local (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+/**
+params("xxx", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", 1, "huawei mttrapd #1", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:222.129.134.178电源整体功能恢复!", "xxx")
+**/
+;
+
+select * from /test/malert_status_local limit -1
+/**
+output()
+count(2001)
+**/
+;
+
+
+update /test/malert_status_local set summary='xxx' where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_local where identifier='xxx'
+/**
+output()
+matchcount(identifier, "xxx", summary, "xxx", 1)
+**/
+;
+
+update /test/malert_status_local set summary='aaa' where id='4209425540011051504'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_local where id='4209425540011051504'
+/**
+output()
+matchcount(id, "4209425540011051504", summary, "aaa", 1)
+**/
+;
+
+update /test/malert_status_local set summary='xxx' where id='4209425540011051504'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_local where id='4209425540011051504'
+/**
+output()
+matchcount(id, "4209425540011051504", summary, "xxx", 1)
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_local where identifier='xxx'
+/**
+output()
+**/
+;
+
+delete from /test/malert_status_local where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_local where identifier='xxx'
+/**
+output()
+count(0)
+**/
+;
+
+select count(*) from /test/malert_status_local
+/**
+output()
+matchcount("count", 2000, 1)
+**/
+;

odbctest/mql/basic/30conflictmemdb/10clear.mql

@@ -0,0 +1,12 @@
+
+delete from /test/alert_status_memdb with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;
+
+delete from /test/malert_status_memdb with version ;
+/**
+onerror(continue,`not exist`,`not find`,`not found`,` Not Found`)
+**/
+;

odbctest/mql/basic/30conflictmemdb/13data_update.mql

@@ -0,0 +1,24 @@
+
+update /test/alert_status_memdb set connect = nil
+;
+
+select connect FROM /test/alert_status_memdb refresh
+/**
+output()
+matchcount("connect._all.len",0,4)
+**/
+;
+
+update /test/alert_status_memdb set connect = connect + "Project:prj{%d,mqli}"
+/**
+loop(10)
+parallel(10)
+**/
+;
+
+select connect FROM /test/alert_status_memdb refresh
+/**
+output()
+matchcount("connect._all.len",10,4)
+**/
+;

odbctest/mql/basic/30conflictmemdb/14update_tags.mql

@@ -0,0 +1,36 @@
+
+update /test/alert_status_memdb set tags = "mytag6" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_memdb set tags = "mytag7" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.7'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_memdb set tags = "mytag8" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.8'
+/**
+fork(a)
+**/
+;
+
+update /test/alert_status_memdb set tags = "mytag9" where identifier = '222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.9'
+/**
+fork(a)
+**/
+;
+
+/**
+wait(a)
+sleep(2s)
+**/;
+
+select tags FROM /test/alert_status_memdb refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;

odbctest/mql/basic/30conflictmemdb/15concur.mql

@@ -0,0 +1,23 @@
+
+insert into /test/malert_status_memdb (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+/**
+loop(2000)
+parallel(100)
+beforerun(
+    set(ct,now),
+    add(ct,1,second),
+	set(t10,mqli),
+	mod(t10,10),
+    set(mtype, t10),
+	set(tag,"mytag"),
+	case(t10==1,set(tag,"mytag1")),
+	case(t10==2,set(tag,"mytag2")),
+	case(t10==3,set(tag,"mytag3")),
+	case(t10==4,set(tag,"mytag4")),
+	case(t10==5,set(tag,"mytag5")),
+    set(t100,mqli),
+	mod(t100,100)
+)
+params("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6{%d,mqli}", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", {%d,mtype}, "huawei mttrapd #{%d,t100}", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:222.129.134.178电源整体功能恢复!", "{%s,tag}")
+**/
+;

odbctest/mql/basic/30conflictmemdb/20valid.mql

@@ -0,0 +1,26 @@
+
+/**
+sleep(3s)
+**/;
+
+select tally FROM /test/alert_status_memdb refresh
+/**
+output()
+matchcount("tally", 40, 4)
+**/
+;
+
+select tags FROM /test/alert_status_memdb refresh
+/**
+output()
+matchcount("tags.len",1,4)
+**/
+;
+
+select id, identifier, lastoccurrence from /test/alert_status_memdb
+where severity < 1 and manager=? and lastoccurrence > 1622249714000
+/**
+output()
+params(nil)
+**/
+;

odbctest/mql/basic/30conflictmemdb/25update.mql

@@ -0,0 +1,41 @@
+
+
+
+update /test/alert_status_memdb set test='aaa'
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_memdb
+/**
+output()
+matchcount(id, "9986946430000814177", test, "aaa", 1)
+**/
+;
+
+update /test/alert_status_memdb set test='xxx' where id="9986946430000814177"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_memdb
+/**
+output()
+matchcount(id, "9986946430000814177", test, "xxx", 1)
+**/
+;
+
+update /test/alert_status_memdb set test='xxx' where id="9986946430000814177"
+/**
+output()
+**/
+;
+
+select id,test from /test/alert_status_memdb
+/**
+output()
+matchcount(id, "9986946430000814177", test, "xxx", 1)
+**/
+;

odbctest/mql/basic/30conflictmemdb/26mupdate.mql

@@ -0,0 +1,81 @@
+
+
+
+insert into /test/malert_status_memdb (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, originalseverity, summary, tags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1
+/**
+params("xxx", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", 1, "huawei mttrapd #1", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", 5, "设备:222.129.134.178电源整体功能恢复!", "xxx")
+**/
+;
+
+select * from /test/malert_status_memdb limit -1
+/**
+output()
+count(2001)
+**/
+;
+
+
+update /test/malert_status_memdb set summary='xxx' where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_memdb where identifier='xxx'
+/**
+output()
+matchcount(identifier, "xxx", summary, "xxx", 1)
+**/
+;
+
+update /test/malert_status_memdb set summary='aaa' where id='18154638131105394144'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_memdb where id='18154638131105394144'
+/**
+output()
+matchcount(id, "18154638131105394144", summary, "aaa", 1)
+**/
+;
+
+update /test/malert_status_memdb set summary='xxx' where id='18154638131105394144'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_memdb where id='18154638131105394144'
+/**
+output()
+matchcount(id, "18154638131105394144", summary, "xxx", 1)
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_memdb where identifier='xxx'
+/**
+output()
+**/
+;
+
+delete from /test/malert_status_memdb where identifier='xxx'
+/**
+output()
+**/
+;
+
+select class,id,identifier,summary from /test/malert_status_memdb where identifier='xxx'
+/**
+output()
+count(0)
+**/
+;
+
+select count(*) from /test/malert_status_memdb
+/**
+output()
+matchcount("count", 2000, 1)
+**/
+;