0

当我尝试将记录插入 Postgresql 时，出现以下错误。

pg8000.exceptions.DatabaseError: {'S': 'ERROR', 'V': 'ERROR', 'C': '42601', 'M': '","' 或附近的语法错误, 'P': '345'，'F'：'scan.l'，'L'：'1150'，'R'：'scanner_yyerror'}

下面是我收到错误的python代码片段：

def insert_data(metadata):
    if type(metadata) == dict: metadata = [metadata]
    print("Metadata = ", metadata)
    for detail in metadata:
        detail["dismissed"] = check_if_dismissed(detail["uuid"])
        cols = ",".join(detail.keys())
        print("Cols: ", cols)
        qmarks = ','.join(['?' for s in detail.keys()])
        print("Qmarks: ", qmarks)
        # values = [v for v in detail.values()]
        values = []
        for v in detail.values():
            if isinstance(v, list):
                values.append(json.dumps(v))
            else:
                values.append(v)
        print("Values: ", values)
        insert_statement = "INSERT INTO %s (%s) VALUES (%s);" % (TABLE_NAME, cols, qmarks)
        print("Insert Statement: ", insert_statement)
        conn = get_conn()
        conn.insert_record(insert_statement, str(values))

有人可以帮我解决这个错误吗？

4

1 回答 1

0

pg8000 对值使用“名称”样式的占位符

SELECT * FROM tbl WHERE name = :name

它们run作为关键字参数传递给连接的方法。目前尚不清楚它是什么conn.insert_record——我在 pg8000 的自述文件中没有看到它——但是要使用 pg8000 构建一个类似的语句，你可以这样做：

import pg8000.native

DDL = """CREATE TABLE IF NOT EXISTS table_name (
  name varchar,
  age integer
)
"""


conn = pg8000.native.Connection(...)
conn.run(DDL)

table = 'table_name'
data = {'name': 'Alice', 'age': 42}
cols = ', '.join(f'"{k}"' for k in data.keys())
vals = ', '.join(f':{k}' for k in data.keys())
stmt = f"""INSERT INTO "{table}" ({cols}) VALUES ({vals})"""
conn.run(stmt, **data)
conn.close()
于 2021-12-17T11:36:45.413 回答