如何实现多表查询：优先取先声明表字段，联表自动获取异名字段

核心问题说明 #

直接用SELECT *联表会导致同名字段（比如type、B_id）重复，数据库无法自动区分取哪张表的字段，也不会自动过滤主表已有的字段。必须通过查询数据库的元数据，动态生成包含主表全字段+副表独有字段的SQL语句。

MySQL 实现方案 #

可以通过存储过程自动生成并执行目标SQL：

DELIMITER //
CREATE PROCEDURE GetCombinedTableData()
BEGIN
    DECLARE b_unique_columns TEXT DEFAULT '';
    -- 提取TableB中TableA没有的字段，拼接成`TableB.字段名`格式
    SELECT GROUP_CONCAT('TableB.', COLUMN_NAME) INTO b_unique_columns
    FROM INFORMATION_SCHEMA.COLUMNS 
    WHERE TABLE_SCHEMA = DATABASE() -- 当前数据库
      AND TABLE_NAME = 'TableB'
      AND COLUMN_NAME NOT IN (
          SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS 
          WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = 'TableA'
      );
    
    -- 拼接最终SQL并执行
    SET @sql = CONCAT('SELECT TableA.*, ', b_unique_columns, ' FROM TableA JOIN TableB ON TableA.B_id = TableB.B_id');
    PREPARE stmt FROM @sql;
    EXECUTE stmt;
    DEALLOCATE PREPARE stmt;
END //
DELIMITER ;

调用存储过程即可得到结果：

CALL GetCombinedTableData();

PostgreSQL 实现方案 #

用PL/pgSQL函数动态生成查询：

CREATE OR REPLACE FUNCTION get_combined_table_data()
RETURNS SETOF RECORD AS $$
DECLARE
    b_unique_columns TEXT;
BEGIN
    -- 提取TableB的独有字段并拼接
    SELECT string_agg('TableB.' || column_name, ', ') INTO b_unique_columns
    FROM information_schema.columns
    WHERE table_schema = 'public' -- 替换为你的schema
      AND table_name = 'tableb'
      AND column_name NOT IN (
          SELECT column_name FROM information_schema.columns 
          WHERE table_schema = 'public' AND table_name = 'tablea'
      );
    
    -- 执行动态SQL并返回结果
    RETURN QUERY EXECUTE format('SELECT TableA.*, %s FROM TableA JOIN TableB ON TableA.B_id = TableB.B_id', b_unique_columns);
END;
$$ LANGUAGE plpgsql;

调用时需要指定返回字段的结构（和预期结果一致）：

SELECT * FROM get_combined_table_data() AS (A_id INT, B_id INT, type VARCHAR, value VARCHAR);

应用层动态生成SQL（以Python为例） #

如果不想写数据库端的存储过程/函数，也可以在应用层先查元数据，拼接SQL后执行：

import psycopg2  # MySQL用pymysql，逻辑类似

# 连接数据库
conn = psycopg2.connect("dbname=你的数据库名 user=用户名 password=密码")
cur = conn.cursor()

# 获取TableA的所有字段
cur.execute("SELECT column_name FROM information_schema.columns WHERE table_schema='public' AND table_name='tablea'")
a_columns = [row[0] for row in cur.fetchall()]

# 获取TableB中TableA没有的字段
cur.execute(
    "SELECT column_name FROM information_schema.columns WHERE table_schema='public' AND table_name='tableb' AND column_name NOT IN %s",
    (tuple(a_columns),)
)
b_unique_columns = [f"tableb.{col}" for col in [row[0] for row in cur.fetchall()]]

# 拼接并执行SQL
sql = f"SELECT tablea.*, {', '.join(b_unique_columns)} FROM tablea JOIN tableb ON tablea.b_id = tableb.b_id"
cur.execute(sql)

# 打印结果
print(cur.fetchall())  # 输出: [(1, 1, 'A', 'x')]

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

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