couchbase - UNNEST 数组上的 N1ql SUM

Question

UNNEST 数组上的 N1ql SUM
我有一个包含以下文档的存储桶(Couchbase Community 6.5 版):
钓鱼文档

{
    "boatIds": ["boatId_1","boatId_2","boatId_3"],
    "areaIds": ["areaId_1","areaId_2","areaId_3"],
    "total": 10,
    "date": "2021-05-13T00:00:00Z",
    "type": "fishing"
},
{
    "boatIds": ["boatId_1","boatId_3"],
    "areaIds": ["areaId_2","areaId_3"],
    "total": 25,
    "date": "2021-05-15T00:00:00Z",
    "type": "fishing"
}

河流文档

{
    "_id": "areaId_1",
    "size": 5,
    "type": "river"
},
{
    "_id": "areaId_1",
    "size": 10,
    "type": "river"
},
{
    "_id": "areaId_1",
    "size": 15,
    "type": "river"
}

BoatDoc

{
    "_id": "areaId_1",
    "name": "Small Boat",
    "type": "boat"
},
{
    "_id": "areaId_1",
    "name": "Medium Boat",
    "type": "boat"
},
{
    "_id": "areaId_1",
    "name": "Large Boat",
    "type": "boat"
}

我需要一个查询，在哪里可以获得每条河流和每条船的所有钓鱼文件。我在以下查询中使用 UNNEST 运算符得到了这个工作:

SELECT river.size,
        boat.name,
        fishing.total
FROM bucket_name fishing
UNNEST fishing.riverIds AS river
UNNEST fishing.boatIds AS boat
WHERE fishing.type = "fishing"

但是这个查询的问题是上面查询中的总值是整个钓鱼对象的总值。
我需要得到相对于未嵌套河流的大小的总数。所以我需要加入并求和钓鱼对象的所有河流的总数，并获得相对于总数的特定河流的大小。
这是我想到的选择语句，但我不知道如何实际编写正确的查询:

SELECT river.size,
        boat.name,
        river.size/SUM( fishing.riverIds[0].size, fishing.riverIds[1].size, fishing.riverIds[2].size ) * fishing.total
FROM bucket_name fishing
UNNEST fishing.riverIds AS river
UNNEST fishing.boatIds AS boat
WHERE fishing.type = "fishing"

Answer 1

INSERT INTO default VALUES ("f01", { "boatIds": ["boatId_1","boatId_2","boatId_3"], "areaIds": ["areaId_1","areaId_2","areaId_3"], "total": 10, "date": "2021-05-13T00:00:00Z", "type": "fishing" });
INSERT INTO default VALUES ("f02", { "boatIds": ["boatId_1","boatId_3"], "areaIds": ["areaId_2","areaId_3"], "total": 25, "date": "2021-05-15T00:00:00Z", "type": "fishing" });
INSERT INTO default VALUES ("areaId_1", { "_id": "areaId_1", "size": 5, "type": "river" });
INSERT INTO default VALUES ("areaId_2", { "_id": "areaId_2", "size": 10, "type": "river" });
INSERT INTO default VALUES ("areaId_3", { "_id": "areaId_3", "size": 15, "type": "river" });
INSERT INTO default VALUES ("boatId_1", { "_id": "boatId_1", "name": "Small Boat", "type": "boat" });
INSERT INTO default VALUES ("boatId_2", { "_id": "boatId_2", "name": "Medium Boat", "type": "boat" });
INSERT INTO default VALUES ("boatId_3", { "_id": "boatId_3", "name": "Large Boat", "type": "boat" });

SELECT ARRAY {"size": f.river.[v], "name": f.boat.[f.boatIds[pos]], "total": f.total*f.river.[v]/ARRAY_SUM(OBJECT_VALUES(f.river))}
       FOR pos:v IN f.areaIds END AS distribution
FROM (SELECT d.*,
          OBJECT v._id:v.size FOR v IN (SELECT r._id, r.size FROM default AS r USE KEYS d.areaIds) END AS river,
          OBJECT v._id:v.name FOR v IN (SELECT b._id, b.name FROM default AS b USE KEYS d.boatIds) END AS boat
      FROM default AS d
      WHERE d.type = "fishing") AS f;
{
    "requestID": "fbe127b4-2ebb-4b01-a8a1-0bfe5310ed42",
    "signature": {
        "distribution": "array"
    },
    "results": [
    {
        "distribution": [
            {
                "name": "Small Boat",
                "size": 5,
                "total": 1.6666666666666667
            },
            {
                "name": "Medium Boat",
                "size": 10,
                "total": 3.3333333333333335
            },
            {
                "name": "Large Boat",
                "size": 15,
                "total": 5
            }
        ]
    },
    {
        "distribution": [
            {
                "name": "Small Boat",
                "size": 10,
                "total": 10
            },
            {
                "name": "Large Boat",
                "size": 15,
                "total": 15
            }
        ]
    }
    ],
    "status": "success",
    "metrics": {
        "elapsedTime": "6.946602ms",
        "executionTime": "6.881065ms",
        "resultCount": 2,
        "resultSize": 730,
        "serviceLoad": 2
    }
}

或者

SELECT river AS SectionSize,
       f.total*(river/ARRAY_SUM(f.sections)) AS total,
       f.boats[UNNEST_POS(river)] AS name
FROM (SELECT d.total,
             (SELECT RAW r.size FROM default AS r USE KEYS d.areaIds) AS sections,
             (SELECT RAW b.name FROM default AS b USE KEYS d.boatIds) AS boats
      FROM default AS d
      WHERE d.type = "fishing") AS f
UNNEST f.sections AS river;

{
"results": [
    {
        "SectionSize": 5,
        "name": "Small Boat",
        "total": 1.6666666666666665
    },
    {
        "SectionSize": 10,
        "name": "Medium Boat",
        "total": 3.333333333333333
    },
    {
        "SectionSize": 15,
        "name": "Large Boat",
        "total": 5
    },
    {
        "SectionSize": 10,
        "name": "Small Boat",
        "total": 10
    },
    {
        "SectionSize": 15,
        "name": "Large Boat",
        "total": 15
    }
    ]
}