如何在psycopg2中移除fetchall返回三列数据的逗号并写入文本文件

你的代码存在几处明显错误，引发了索引越界及其他问题，具体修正如下：

错误点说明 #

• SQL语法错误：WHERE子句多条件需用AND连接，原代码用逗号会导致语法报错，同时占位符规范写法为小写%s
• execute调用错误：cursor.execute()第一个参数应为SQL语句，第二个才是参数元组，你写反了顺序
• 索引越界+方法误用：resultset[len(resultset)]超出列表索引范围（列表最大索引是len(resultset)-1），且fetchall()返回的是Python原生列表（元素为元组），不是pandas Series，不能调用str.replace()方法

修正后的完整代码 #

import psycopg2

# 建立数据库连接
con = psycopg2.connect(
    database="dbname",
    user="postgres",
    password="pwd",
    host="localhost",
    port='5432'
)
cursor_obj = con.cursor()

# 修正SQL语句
sql = """SELECT COL1, COL2, COL3 FROM TABLE WHERE COL1 = %s AND COL3 = 1 ORDER BY COL1, COL2, COL3 ASC;"""
# 正确调用execute，参数需传入元组
cursor_obj.execute(sql, (d1,))
resultset = cursor_obj.fetchall()

# 移除每个字段中的逗号，并整理成文本行格式
processed_data = []
for row in resultset:
    # 遍历每一行的三个字段，替换逗号
    cleaned_row = [str(col).replace(',', '') for col in row]
    # 用制表符拼接成一行，可按需替换为其他分隔符
    processed_data.append('\t'.join(cleaned_row))

# 写入文本文件
with open('output.txt', 'w', encoding='utf-8') as f:
    f.write('\n'.join(processed_data))

# 关闭游标和连接，释放资源
cursor_obj.close()
con.close()

补充说明 #

• 如果COL1/COL2/COL3是数值类型，需先转成字符串再替换逗号，避免类型错误
• 写入文件时可根据需求调整分隔符（比如空格、竖线），示例中用制表符\t便于后续处理
• 操作完成后务必关闭游标和数据库连接，避免资源泄漏

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