0100class.mql 3.9 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. -- DB 仅存储数据库连接信息,不处理数据
  2. CREATE DB IF NOT EXISTS mdbxdb (
  3. -- 数据库驱动类型,单引号或双引号标记的字符串,
  4. -- 目前支持的类型有 sqlite|mysql ,新的类型需要更新 odbserver
  5. DRIVER : 'sqlite',
  6. -- 数据源定义,单引号或双引号标记的字符串,
  7. -- 不同数据库类型格式不一样,参考相关数据库驱动文档
  8. SOURCE : "file:data/paper_trade_record_620?cache=shared",
  9. -- 附加选项,JSON对象,
  10. -- 通过 odbserver 支持的,不同数据库类型支持的选项可能不同
  11. OPTION : {
  12. "makedir": "auto" -- sqlite 支持,自动创建数据库文件所在目录
  13. }
  14. -- mysql示例
  15. -- driver : "mysql",
  16. -- source : "user:password@tcp(127.0.0.1:3306)/dbname"
  17. )
  18. ;
  19. -- 创建 MDB 相关测试类
  20. -- MDB 统一处理不同数据库类型的数据存取
  21. -- 上面创建的 DB 与 BucketType 对应,兼容早期的内建 BucketType(tsdb|logs|bitlog|promdb|vector)
  22. create class if not exists /mdbx () with namespace='mdbx'
  23. ;
  24. -- 固定映射(指定固定条件或无条件映射数据),
  25. -- 当主类中没有数据时,查询时自动赋值默认对象属性:
  26. -- class: 类名/mdbx/dba1,
  27. -- id: 组合映射表主键为字符串,
  28. -- name: 与id相同,
  29. -- day: 当前日期,
  30. -- vtime: 当前时间
  31. -- 映射表查询结果按 id 匹配关联主对象
  32. -- 当主类中存在数据时,直接按主对象 id 与 组合映射表主键得到的字符串 进行匹配关联主对象
  33. -- rdb 输出为二维数组,兼容 promdb 等已有 bucket 类型
  34. -- rdb 数据 与 id 一一对应,实际 二维数组中的第一维 最多只有 一个元素
  35. -- 支持 bucket 链式表达式
  36. create class if not exists /mdbx/dba1 (
  37. rdb bucket {
  38. -- 固定映射
  39. "type" : "mdbxdb",
  40. -- 必须:指定表名
  41. "table" : "T__project_0_1000119_0_harness_0_draft__paper_0_trade_0_record",
  42. "fields": ["id","project_1000119_harness_draft_trades_on","system"]
  43. },
  44. ) with nickname='mdbx_dba1'
  45. ;
  46. -- 条件映射
  47. -- 主类中需要有数据,按指定条件映射数据,条件与主类数据有关联
  48. -- xrdb 输出为二维数组,兼容 promdb 等已有 bucket 类型,输出字段顺序与 bucket 定义的字段顺序一致
  49. -- xrdb 数据 与 id 为多对一关系,默认输出第一条记录,需要在 bucket 定义时明确数据唯一排序,否则数据输出可能不稳定
  50. -- 支持 bucket 链式表达式
  51. create class if not exists /mdbx/dba2 (
  52. xvarchar varchar,
  53. xint int,
  54. xbigint bigint,
  55. xdouble double,
  56. xdate date,
  57. xrdb bucket {
  58. -- 条件映射
  59. "type" : "mdbxdb",
  60. -- 指定结构化查询信息表、字段、条件
  61. -- TODO 后期可解析 sql 语句,方便应用开发
  62. "table" : "T__project_0_1000119_0_harness_0_draft__paper_0_trade_0_record",
  63. "fields": ["source_line_no", "trade_record_id", "system"],
  64. "conds" : {
  65. "and": [{ -- 多条件组合
  66. "like": ["trade_record_id","%000010001%"]},{ -- 常量条件
  67. "=": ["source_line_no", {"field":"xint"}]} -- 变量条件
  68. ]}, -- sql函数支持
  69. "orderby" : ["source_line_no"] -- 指定排序,保证 last row 输出稳定结果
  70. -- TODO "groupby","having"
  71. } "rdb test",
  72. xmap map<varchar, varchar>,
  73. xlist list<varchar>,
  74. xset set<varchar>,
  75. indexes(xvarchar, xint, xbigint, xdouble, xmap, xlist, xset),
  76. keys(xvarchar)
  77. ) with nickname='mdbx_dba2'
  78. ;