如何在 Bigquery 参数化查询中传递结构数组-Python教程-PHP中文网

如何在 Bigquery 参数化查询中传递结构数组

聖光之護

发布： 2024-10-15 16:54:01

转载

949人浏览过

如何在 bigquery 参数化查询中传递结构数组

在 google 的 bigquery 中，sql 查询可以参数化。如果您不熟悉这个概念，它基本上意味着您可以将 sql 查询编写为参数化模板，如下所示：

insert into mydataset.mytable(columna, columnb)
    values (@valuea, @valueb)

登录后复制

并分别传递值。这有很多好处：

查询比通过字符串连接构建的查询更具可读性
代码更加健壮和工业化
它可以很好地防止 sql 注入攻击（强制 xkcd）

从 python 脚本传递查询参数似乎很简单......乍一看。例如：

from google.cloud.bigquery import (
    client,
    scalarqueryparameter,
    arrayqueryparameter,
    structqueryparameter,
    queryjobconfig,
)

client=client()

client.query("
insert into mydataset.mytable(columna, columnb)
    values (@valuea, @valueb)
", job_config=queryjobconfig(
    query_parameters=[
        scalarqueryparameter("valuea","string","a"), 
        scalarqueryparameter("valueb","string","b")
])

登录后复制

上面的示例在 a 列和 b 列中插入简单（“标量”）值。但您也可以传递更复杂的参数：

数组（arrayqueryparameter）
结构体（structqueryparameter）

当您想要插入结构数组时，就会出现问题：有很多陷阱，几乎没有文档，网络上关于该主题的资源也很少。本文的目标就是填补这一空白。

如何使用参数化查询在 bigquery 中持久保存结构数组

让我们定义要存储在目标表中的以下对象

from dataclasses import dataclass

@dataclass
class country:
    name: str
    capital_city: str

@dataclass
class continent:
    name: str
    countries: list[country]

登录后复制

通过调用此参数化查询

query = update continents set countries=@countries where name="oceania"

登录后复制

遵循浅薄文档的第一次尝试将是

client.query(query, 
    job_config=queryjobconfig(query_parameters=[
        arrayqueryparameter("countries", "record", [
             {name="new zealand", capital_city="wellington"},
             {name="fiji", capital_city="suva"} ...]
]))

登录后复制

这会惨败

attributeerror：“dict”对象没有属性“to_api_repr”

问题 1：arrayqueryparameter 的值必须是 structqueryparameter 的实例

事实证明，构造函数的第三个参数 - value - 必须是 structqueryparameter 实例的集合，而不是直接想要的值。那么让我们来构建它们：

DeepBrain

AI视频生成工具，ChatGPT +生成式视频AI =你可以制作伟大的视频!

108

查看详情

client.query(query, 
job_config=queryjobconfig(query_parameters=[
    arrayqueryparameter("countries", "record", [
    structqueryparameter("countries",
        scalarqueryparameter("name", "string", ct.name), 
        scalarqueryparameter("capital_city", "string", ct.capital_city)
    )
    for ct in countries])
]))

登录后复制

这次有效...直到您尝试设置一个空数组

client.query(query, 
    job_config=queryjobconfig(
    query_parameters=[
        arrayqueryparameter("countries", "record", [])
]))

登录后复制

valueerror：缺少空数组的详细结构项类型信息，请提供 structqueryparametertype 实例。

陷阱 n°2：提供完整的结构类型作为第二个参数

错误消息非常清楚：“record”不足以让 bigquery 知道如何处理空数组。它需要完整详细的结构。就这样吧

client.query(query, job_config=QueryJobConfig(query_parameters=[
    ArrayQueryParameter("countries",
        StructQueryParameterType(
            ScalarQueryParameterType("STRING","name"),
            ScalarQueryParameterType("STRING","capital_city")
        ), [])
]))

登录后复制

（注意 ...parametertype 构造函数的参数顺序与 ...parameter 构造函数相反。这只是路上的另一个陷阱...）

现在它也适用于空数组，耶！

最后一个需要注意的问题：structqueryparametertype 的每个子字段都必须有一个名称，即使第二个参数（名称）在构造函数中是可选的。它实际上对于子字段是强制性的，否则你会得到一种新的错误