11trigger.mql 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. -- ============================================================
  2. -- 触发器操作测试
  3. -- ============================================================
  4. -- 1. 触发器相关操作:insert 后验证数据
  5. insert into /test/aaa/test_trigger (t_name, t_value, t_status) values ('trigger_test_1', 500, 'pending')
  6. ;
  7. select * from /test/aaa/test_trigger where t_name='trigger_test_1'
  8. /**
  9. output()
  10. count(1)
  11. match("t_value","500")
  12. **/
  13. ;
  14. -- 2. update 模拟触发器状态变更
  15. update /test/aaa/test_trigger set t_status='completed', t_value=600 where t_name='trigger_test_1'
  16. ;
  17. select t_name, t_value, t_status from /test/aaa/test_trigger where t_name='trigger_test_1'
  18. /**
  19. output()
  20. match("t_status","completed")
  21. match("t_value","600")
  22. **/
  23. ;
  24. -- 3. 批量触发器测试
  25. insert into /test/aaa/test_trigger (t_name, t_value, t_status) values ('trigger_batch_1', 10, 'init')
  26. ;
  27. insert into /test/aaa/test_trigger (t_name, t_value, t_status) values ('trigger_batch_2', 20, 'init')
  28. ;
  29. -- 批量更新状态(模拟触发器批量触发)
  30. update /test/aaa/test_trigger set t_status='processed' where t_status='init'
  31. ;
  32. select t_name, t_status from /test/aaa/test_trigger where t_status='processed'
  33. /**
  34. output()
  35. matchcount("t_name","trigger_batch",2)
  36. **/
  37. ;
  38. -- 4. delete 触发器相关数据
  39. delete from /test/aaa/test_trigger where t_name='trigger_batch_1'
  40. ;
  41. select * from /test/aaa/test_trigger where t_name='trigger_batch_1'
  42. /**
  43. output()
  44. count(0)
  45. **/
  46. ;
  47. -- 5. 触发器相关聚合
  48. select t_status, count(*) from /test/aaa/test_trigger group by t_status
  49. /**
  50. output()
  51. **/
  52. ;