Looker实现类似SQL GROUP_CONCAT功能：合并多行数据到一列

2024-09-12 17:10:33

在SQL Server Management Studio（SSMS）中，我们可以轻松地使用GROUP_CONCAT或STRING_AGG等函数将多行数据合并到一个单元格中。这在处理类似订单详情、用户标签等场景时非常方便。但是，当你从SSMS转向Looker时，会发现Looker并没有直接提供这样的函数。那么，如何在Looker中实现类似的功能呢？

其实，Looker强大的数据透视功能可以帮我们解决这个问题。虽然它没有直接提供字符串连接函数，但我们可以利用数据透视功能将行数据转换为列数据，再通过LookML的派生表功能将这些列合并成一个新的字段，最终达到类似SQL字符串连接的效果。

让我们通过一个实际案例来了解具体的实现步骤。

假设我们有一个名为orders的订单表，其中包含订单ID、商品名称和商品价格等信息：

订单ID	商品名称	商品价格
1001	苹果	10
1001	香蕉	5
1001	橙子	8
1002	牛奶	12
1002	面包	3

我们的目标是将每个订单的商品名称和价格合并到一个名为“订单详情”的单元格中，最终效果如下：

订单ID	订单详情
1001	苹果-10, 香蕉-5, 橙子-8
1002	牛奶-12, 面包-3

接下来，我们一步步地在LookML中实现这个功能。

第一步：创建数据透视表

我们需要在LookML的orders视图中使用pivot_where语句创建一个数据透视表。这个数据透视表会将商品名称作为列名，商品价格作为列值。

view: orders {
  sql_table_name: your_database.orders ;;

  dimension: order_id {
    primary_key: yes
    type: number
  }

  dimension: product_name {
    type: string
  }

  dimension: price {
    type: number
  }

  # ... 其他维度和度量 ...

  # 创建数据透视表
  pivot_where: {
    label: "Product Details" # 透视表的标签
    dimensions: [product_name] # 用作列名的维度
    measures: [price] # 用作列值的度量
  }
}

第二步：创建派生表

接下来，我们需要创建一个名为order_details的派生表。在这个派生表中，我们会使用SQL语句将数据透视表中的列合并成一个名为order_details的新字段。

view: order_details {
  derived_table: {
    sql: SELECT 
          order_id,
          # 使用CASE WHEN语句判断每个商品是否存在，并拼接字符串
          CASE WHEN "orders.price_苹果" IS NOT NULL THEN '苹果-' || "orders.price_苹果" ELSE '' END || 
          CASE WHEN "orders.price_香蕉" IS NOT NULL THEN ', 香蕉-' || "orders.price_香蕉" ELSE '' END ||
          CASE WHEN "orders.price_橙子" IS NOT NULL THEN ', 橙子-' || "orders.price_橙子" ELSE '' END ||
          CASE WHEN "orders.price_牛奶" IS NOT NULL THEN ', 牛奶-' || "orders.price_牛奶" ELSE '' END ||
          CASE WHEN "orders.price_面包" IS NOT NULL THEN ', 面包-' || "orders.price_面包" ELSE '' END AS order_details
        FROM orders
        GROUP BY 1 ;;
  }

  dimension: order_id {
    type: number
  }

  dimension: order_details {
    type: string
  }
}

在这个派生表中，我们使用了CASE WHEN语句来判断每个商品是否存在。如果存在，就将其名称和价格拼接成字符串，并使用逗号分隔。

第三步：创建Explore

最后，我们需要创建一个名为order_summary的Explore，使用order_details视图来查询合并后的订单详情。

explore: order_summary {
  from: order_details
  joins: [orders] {
    relationship: many_to_one
    on: order_details.order_id = orders.order_id
  }
}