如何将Python DataFrame列转为逗号分隔字符串或直接从SQL生成

方式a：从DataFrame指定列转换为逗号分隔字符串 #

先通过嵌入式SQL获取目标DataFrame后，直接对指定列做字符串拼接处理即可，步骤如下：

import pandas as pd

# 假设已通过嵌入式SQL查询得到DataFrame df
target_column = "your_target_column"

# 1. 过滤空值并转换为字符串类型（可选，根据业务需求调整）
processed_values = df[target_column].dropna().astype(str)

# 2. 拼接为逗号分隔的字符串
comma_separated_str = ",".join(processed_values)

如果列值本身可能包含逗号，建议用双引号包裹每个元素避免歧义：

comma_separated_str = ",".join(f'"{val}"' for val in processed_values)

方式b：直接通过SQL查询生成逗号分隔字符串 #

利用数据库内置的字符串聚合函数，在查询阶段直接生成目标字符串，无需将全量数据加载到DataFrame，适合数据量较大的场景。不同数据库的聚合函数语法略有差异，以下是常见数据库的示例：

PostgreSQL（使用string_agg） #

import psycopg2

# 建立数据库连接
conn = psycopg2.connect(dbname="your_db", user="your_user", password="your_pass", host="your_host")
cur = conn.cursor()

# 执行聚合查询
cur.execute("""
    SELECT string_agg(your_target_column::text, ',') AS result_str
    FROM your_table
    WHERE your_target_column IS NOT NULL -- 过滤空值（可选）
    -- 追加你的查询条件
""")

# 获取结果
result = cur.fetchone()
comma_separated_str = result[0] if result[0] is not None else ""

# 关闭连接
cur.close()
conn.close()

MySQL/SQLite（使用GROUP_CONCAT） #

# MySQL示例（SQLite只需替换连接方式）
import mysql.connector

conn = mysql.connector.connect(user="your_user", password="your_pass", host="your_host", database="your_db")
cur = conn.cursor()

cur.execute("""
    SELECT GROUP_CONCAT(your_target_column SEPARATOR ',') AS result_str
    FROM your_table
    WHERE your_target_column IS NOT NULL
    -- 追加你的查询条件
""")

result = cur.fetchone()
comma_separated_str = result[0] if result[0] is not None else ""

cur.close()
conn.close()

注意事项 #

• 空值处理：两种方式都建议过滤空值，避免生成,,这类无效分隔符；
• 特殊字符处理：若列值包含逗号、引号等特殊字符，方式a可通过字符串格式化包裹，方式b可使用数据库的转义函数（如PostgreSQL的quote_literal）确保结果格式正确；
• 性能差异：方式b在数据量较大时性能更优，因为无需加载全量数据到内存。

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