如何用Python+MySQL动态选取另一表中存在的字段

你的原方案不可行，Python循环无法直接嵌入SQL字符串的拼接逻辑中，会触发语法错误。下面提供两种可行的实现方式：

方法一：Python动态生成SQL查询 #

先从task_field表获取目标字段列表，再动态拼接完整的SQL语句执行：

步骤1：获取字段列表 #

mycursor = mydb.cursor()
# 查询需要的字段名
mycursor.execute("""
    SELECT name
    FROM `wfi-workflow`.task_field
    WHERE taskid = 50 AND model = 'wca'
""")
# 将查询结果转换为字段名列表
field_names = [row[0] for row in mycursor.fetchall()]

步骤2：拼接并执行动态SQL #

# 把字段名处理为带表别名的格式，用反引号包裹避免特殊字符冲突
dynamic_fields = ", ".join([f"WCA.`{field}`" for field in field_names])

# 拼接完整查询语句
sql_query = f"""
    SELECT DISTINCT portfolio.id, portfolio.secid, {dynamic_fields}, portfolio.code
    FROM portfolio_identifier portfolio
    LEFT JOIN product_wca WCA ON portfolio.secid = WCA.secid
    WHERE portfolio.account_id = 319 LIMIT 1
"""

# 执行查询
newcursor = mydb.cursor()
newcursor.execute(sql_query)
# 获取结果
result = newcursor.fetchall()

注意：如果字段名包含特殊字符（如空格、关键字），必须用反引号`包裹；若字段来源不可信，需额外处理SQL注入风险（本场景字段来自内部表，风险较低）。

方法二：纯MySQL实现动态字段查询 #

无需Python，直接在MySQL中通过动态SQL完成需求：

-- 1. 拼接需要查询的字段列表
SET @dynamic_fields = (
    SELECT GROUP_CONCAT('WCA.`', name, '`')
    FROM `wfi-workflow`.task_field
    WHERE taskid = 50 AND model = 'wca'
);

-- 2. 拼接完整的SQL语句
SET @sql = CONCAT(
    'SELECT DISTINCT portfolio.id, portfolio.secid, ',
    @dynamic_fields,
    ', portfolio.code
    FROM portfolio_identifier portfolio
    LEFT JOIN product_wca WCA ON portfolio.secid = WCA.secid
    WHERE portfolio.account_id = 319 LIMIT 1'
);

-- 3. 预编译并执行动态SQL
PREPARE stmt FROM @sql;
EXECUTE stmt;
DEALLOCATE PREPARE stmt;

注意：GROUP_CONCAT默认有长度限制（默认1024字符），如果需要查询的字段过多，需先调整参数：SET GLOBAL group_concat_max_len = 102400;（需对应权限）。

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