11trigger.mql 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  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. **/
  11. ;
  12. -- 2. update 模拟触发器状态变更
  13. update /test/aaa/test_trigger set t_status='completed', t_value=600 where t_name='trigger_test_1'
  14. ;
  15. select t_name, t_value, t_status from /test/aaa/test_trigger where t_name='trigger_test_1'
  16. /**
  17. output()
  18. **/
  19. ;
  20. -- 3. 批量触发器测试
  21. insert into /test/aaa/test_trigger (t_name, t_value, t_status) values ('trigger_batch_1', 10, 'init')
  22. ;
  23. insert into /test/aaa/test_trigger (t_name, t_value, t_status) values ('trigger_batch_2', 20, 'init')
  24. ;
  25. -- 批量更新状态(模拟触发器批量触发)
  26. update /test/aaa/test_trigger set t_status='processed' where t_status='init'
  27. /**
  28. onerror(continue,"has't index")
  29. **/
  30. ;
  31. select t_name, t_status from /test/aaa/test_trigger where t_status='processed'
  32. /**
  33. onerror(continue,"has't index")
  34. output()
  35. **/
  36. ;
  37. -- 4. delete 触发器相关数据
  38. delete from /test/aaa/test_trigger where t_name='trigger_batch_1'
  39. ;
  40. select * from /test/aaa/test_trigger where t_name='trigger_batch_1'
  41. /**
  42. output()
  43. count(0)
  44. **/
  45. ;
  46. -- 5. 触发器相关聚合
  47. select t_status, count(*) from /test/aaa/test_trigger group by t_status
  48. /**
  49. output()
  50. **/
  51. ;