0100class.mql 3.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485
  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. },
  43. ) with nickname='mdbx_dba1'
  44. ;
  45. -- 条件映射
  46. -- 主类中需要有数据,按指定条件映射数据,条件与主类数据有关联
  47. -- xrdb 输出为二维数组,兼容 promdb 等已有 bucket 类型,输出字段顺序与 bucket 定义的字段顺序一致
  48. -- xrdb 数据 与 id 为多对一关系,默认输出第一条记录,需要在 bucket 定义时明确数据唯一排序,否则数据输出可能不稳定
  49. -- 支持 bucket 链式表达式
  50. create class if not exists /mdbx/dba2 (
  51. xvarchar varchar,
  52. xint int,
  53. xbigint bigint,
  54. xdouble double,
  55. xdate date,
  56. xrdb bucket {
  57. -- 条件映射
  58. "type" : "mdbxdb",
  59. -- 指定结构化查询信息表、字段、条件
  60. -- TODO 后期可解析 sql 语句,方便应用开发
  61. "table" : "T__project_0_1000119_0_harness_0_draft__paper_0_trade_0_record",
  62. "fields": ["字符串", "大整数", "整数", "浮点", {"name":"双浮点","asname":"vdouble"}],
  63. "conds" : {
  64. "and": [{ -- 多条件组合
  65. "like": ["trade_record_id","%000010001%"]},{ -- 常量条件
  66. "=": ["source_line_no", {"field":"xint"}]} -- 变量条件
  67. ]}, -- sql函数支持
  68. "orderby" : ["字符串", {"name":"vtime","reverse":true}] -- 指定排序,保证 last row 输出稳定结果
  69. -- TODO "groupby","having"
  70. } "rdb test",
  71. xmap map<varchar, varchar>,
  72. xlist list<varchar>,
  73. xset set<varchar>,
  74. indexes(xvarchar, xint, xbigint, xdouble, xmap, xlist, xset),
  75. keys(xvarchar)
  76. ) with nickname='mdbx_dba2'
  77. ;