如何将 postgres 数组的值作为参数传递给 asyncpg connection.execute？

Question

我正在尝试构建一段使用 asyncpg 将内容添加到我的 postgres 数据库中的 table 的代码，定义如下：

CREATE TABLE my_table (
    id              SERIAL NOT NULL UNIQUE,
    nested_field    varchar(100) NOT NULL UNIQUE,
    subfields       varchar(100)[]
);

从我的 POV 来看，困难的部分是将内容保存到 postgres array variable。

我构建的代码如下：

try:
    await connection.execute(query, thing_string, subfields_string)
    return None
except (Exception, asyncpg.UniqueViolationError) as integrError:
    # some other action
except (Exception, asyncpg.ConnectionFailureError) as error:
    # some other action
finally:
    # some other action

其中 query 它运行定义为：

query = """
    INSERT INTO my_table(thing, subfields) 
    VALUES(,);
    """

和args*

(here are the docs 关于 asyncpg 函数 connection.execute 的 args* 参数)

将作为 $1 和 $2 放入字符串中

thing_string，定义为thing_string = "something"
和subfields_string，通过运行宁线得到

subfields_string = from_list_to_stringified_set(list_of_subfields)

哪里

list_of_subfields = ["one, two, three"]

函数定义如下：

def from_list_to_stringified_set(list_of_subfields):
    """
    Given a list of subfields
    [ "subfield1", "subfield2", "subfield3" ]
    it returns
    '{ "subfield1", "subfield2", "subfield3" }'
    """
    subfields_string = ""
    for subfield in list_of_subfields:
        subfields_string = subfields_string + '", "' + subfield
    subfields_string = '{' + subfields_string[3:] + '"}'
    return subfields_string

因此 subfields_string 的值结果 '{"one, two, three"}'（我的代码正确实现了这个结果）。

为了正常工作，数据库上的查询运行应该是：

# desired result
INSERT INTO my_table(title, subfields) 
VALUES('something','{"one", "two", "three"}');

但是，当我尝试运行脚本时，我得到

asyncpg.exceptions.DataError: invalid input for query argument : '{"one", "two", "three"}' (a sized iterable container expected (got type 'str'))

所以 connection.execute(...) 不接受我的第二个参数 subfields_string，其值为 '{"one, two, three"}'，因为显然它想要一个可迭代对象而不是字符串。

但是为什么呢？

我作为 args* 的一部分传递给 connection.execute(...) 的其他参数也是字符串，那么为什么第二个参数被拒绝而第一个被接受？

以及如何更改我的代码以获得 # desired result？

Answer 1

使用字符串列表作为参数。

    query = """
        INSERT INTO my_table(nested_field, subfields) 
        VALUES(,);
        """
    thing_string = 'something'
    subfields_string = ["one", "two", "three"]
    await connection.execute(query, thing_string, subfields_string)

列 subfields 是一个 varchar 数组。它对应的 Python 类型是列表，如 in the documentation

如何将 postgres 数组的值作为参数传递给 asyncpg connection.execute？

How to pass the value of a postgres array to asyncpg connection.execute as parameter?

python

arrays

string

postgresql

asyncpg