使用teradatasql Python模块批量查询无法返回全部结果的解决方法

你当前代码的问题在于**fast_executemany=True是专门为批量DML（插入、更新、删除）操作设计的优化参数**，将它用于SELECT语句时，只会执行最后一组参数的查询，因此无法获取全部结果。

以下是两种可行的解决方案：

方法一：使用IN子句构建参数化查询（适合参数数量较少的场景） #

通过将多组参数拼接成IN子句的形式，一次性执行查询：

with teradatasql.connect('{"host":"whomooz","user":"guest","password":"please"}') as con:
    with con.cursor() as cur:
        # 定义待查询的参数组
        params_list = [(1, "abc"), (2, "def"), (3, "ghi")]
        # 生成对应数量的占位符
        placeholders = ", ".join(["(?, ?)"] * len(params_list))
        # 构造完整查询语句
        query = f"SELECT * FROM table WHERE (userid, username) IN ({placeholders})"
        # 将参数组扁平化后传入
        flat_params = [val for param in params_list for val in param]
        cur.execute(query, flat_params)
        # 获取全部结果
        print(cur.fetchall())

方法二：循环执行单条查询并收集结果（适合参数数量较大的场景） #

如果参数组过多导致IN子句长度受限，可以循环执行每个参数组的查询，逐步收集结果：

with teradatasql.connect('{"host":"whomooz","user":"guest","password":"please"}') as con:
    with con.cursor() as cur:
        params_list = [(1, "abc"), (2, "def"), (3, "ghi")]
        all_results = []
        for params in params_list:
            cur.execute("SELECT * FROM table WHERE userid=? AND username=?", params)
            # 将当前查询结果追加到总结果列表
            all_results.extend(cur.fetchall())
        print(all_results)

注意事项 #

• 永远不要在SELECT操作中启用fast_executemany=True，该参数仅对批量DML操作有优化效果，对查询场景无效甚至会导致异常结果。
• 当参数组数量极大时，优先选择循环查询的方式，避免因IN子句过长触发数据库的语法限制。

内容的提问来源于stack exchange，提问作者rocks