• MongoDB归并连续号段-(待验证)


    实现按照不同条件归并连续号段的方式与具体的数据模型和查询需求有关,以下是一种常见的方式:

    假设有一个文档集合,包含如下字段:

    1. {
    2. "_id": ObjectId("613c3050d5d9b45a0de7c290"),
    3. "group": "A",
    4. "date": ISODate("2021-09-11T00:00:00Z"),
    5. "num": 1
    6. }

    其中,group表示分组条件,date表示日期条件,num表示连续号段中的起始编号。

    为了归并连续号段,可以使用聚合框架中的$group操作符和$push操作符结合使用,按照group和date条件进行分组,对于每个分组内的文档集合,使用$push操作符将num字段的值进行排序,然后使用脚本计算连续号段的起止编号和长度,最终输出归并后的结果。

    聚合框架中的操作如下所示:

    1. db.collection.aggregate([
    2. {
    3. $sort: {
    4. group: 1,
    5. date: 1,
    6. num: 1
    7. }
    8. },
    9. {
    10. $group: {
    11. _id: {
    12. group: "$group",
    13. date: "$date"
    14. },
    15. nums: {
    16. $push: "$num"
    17. }
    18. }
    19. },
    20. {
    21. $project: {
    22. _id: 0,
    23. group: "$_id.group",
    24. date: "$_id.date",
    25. segments: {
    26. $reduce: {
    27. input: "$nums",
    28. initialValue: [],
    29. in: {
    30. $cond: {
    31. if: {
    32. $gt: [
    33. {
    34. $size: "$$value"
    35. },
    36. 0
    37. ]
    38. },
    39. then: {
    40. $concatArrays: [
    41. "$$value",
    42. [
    43. {
    44. $cond: {
    45. if: {
    46. $eq: [
    47. {
    48. $subtract: [
    49. "$$this",
    50. {
    51. $arrayElemAt: [
    52. "$$value.num",
    53. -1
    54. ]
    55. }
    56. ]
    57. },
    58. 1
    59. ]
    60. },
    61. then: {
    62. num: {
    63. $arrayElemAt: [
    64. "$$value.num",
    65. -1
    66. ]
    67. },
    68. end: "$$this",
    69. len: {
    70. $add: [
    71. {
    72. $arrayElemAt: [
    73. "$$value.len",
    74. -1
    75. ]
    76. },
    77. 1
    78. ]
    79. }
    80. },
    81. else: {
    82. num: "$$this",
    83. end: "$$this",
    84. len: {
    85. $add: [
    86. {
    87. $arrayElemAt: [
    88. "$$value.len",
    89. -1
    90. ]
    91. },
    92. 1
    93. ]
    94. }
    95. }
    96. }
    97. }
    98. ]
    99. ]
    100. },
    101. else: [
    102. {
    103. num: "$$this",
    104. end: "$$this",
    105. len: 1
    106. }
    107. ]
    108. }
    109. }
    110. }
    111. }
    112. }
    113. }
    114. ])

    上述聚合操作的意义如下:

    1. 使用$sort操作符按照group、date和num字段升序排序。
    2. 使用$group操作符按照group和date字段分组,并将每个分组内的num字段值使用$push操作符放入一个数组中,得到如下文档集合:
    1. {
    2. "group": "A",
    3. "date": ISODate("2021-09-11T00:00:00Z"),
    4. "nums": [1, 2, 4, 6, 7, 8]
    5. },
    6. {
    7. "group": "A",
    8. "date": ISODate("2021-09-12T00:00:00Z"),
    9. "nums": [1, 2, 3, 5]
    10. }

    1. 使用$project操作符将分组后的文档集合重构,将nums数组内的值按照连续号段归并,得到如下文档集合:
    1. {
    2. "group": "A",
    3. "date": ISODate("2021-09-11T00:00:00Z"),
    4. "segments": [
    5. {"num": 1, "end": 2, "len": 2},
    6. {"num": 4, "end": 4, "len": 1},
    7. {"num": 6, "end": 8, "len": 3}
    8. ]
    9. },
    10. {
    11. "group": "A",
    12. "date": ISODate("2021-09-12T00:00:00Z"),
    13. "segments": [
    14. {"num": 1, "end": 3, "len": 3},
    15. {"num": 5, "end": 5, "len": 1}
    16. ]
    17. }

    其中,segments数组内的元素表示一个连续号段,包含num、end和len三个字段,分别表示连续号段的起始编号、结束编号和长度。

  • 相关阅读:
    计算机网络复习(一~三)
    STM32G030F6 (SOP-20)Cortex ® -M0+, 32KB Flash, 8KB RAM, 17 GPIOs
    VR全景算不算好的创业项目?有哪些特性?
    jmeter压力测试工具,雪崩效应,容错组件Sentinel
    NSSCTF第13页(1)
    Potplayer通过公网访问群晖WebDav,快速搭建远程办公环境
    Git分支及使用原则与流程
    牛客网《剑指offer》专栏刷题练习之掌握动态规划思想
    基于Qt4用QSortFilterProxyModel和QCustomPlot搞定数据筛选和曲线绘图
    详解Kubernetes Pod优雅退出
  • 原文地址:https://blog.csdn.net/u011490072/article/details/134521675