PostgreSQL中如何将表行值替换为另一表的对应行值？

一、纯PostgreSQL语句实现 #

1. 查询时替换为用户名（不修改原表数据） #

如果只是想在查询结果中把user1_id替换成对应用户名，无需改动原表，通过JOIN关联两张表即可：

SELECT 
    ut.username AS user1_name,
    tt.*  -- 保留原表其他所有字段，不需要可指定具体字段
FROM 
    your_schema.target_table tt  -- 替换为你的实际schema和目标表名
JOIN 
    your_schema.user_table ut ON tt.user1_id = ut.id;  -- 替换为你的实际用户表名

若要保留原表字段名结构，仅替换user1_id的显示值：

SELECT 
    ut.username AS user1_id,  -- 用用户名替换原字段名输出
    tt.field1,  -- 替换为你需要保留的其他字段
    tt.field2
FROM 
    your_schema.target_table tt
JOIN 
    your_schema.user_table ut ON tt.user1_id = ut.id;

2. 永久更新原表字段为用户名 #

如果要把目标表的user1_id字段直接改成用户名，需先确认字段类型：若原字段是整数类型，需先修改为字符串类型，再执行更新：

步骤1：修改字段类型（整数转字符串）

ALTER TABLE your_schema.target_table 
ALTER COLUMN user1_id TYPE VARCHAR(50);  -- 长度根据实际用户名长度调整

步骤2：更新字段值为对应用户名

UPDATE your_schema.target_table tt
SET user1_id = ut.username
FROM your_schema.user_table ut
WHERE tt.user1_id::INT = ut.id;  -- 转换为整数匹配用户表的主键

二、Python中实现（以psycopg2为例） #

先确保安装依赖：pip install psycopg2-binary

1. 查询获取替换后的结果 #

import psycopg2

# 替换为你的数据库连接参数
conn_config = {
    "dbname": "your_db",
    "user": "your_user",
    "password": "your_pwd",
    "host": "your_host",
    "port": "5432"
}

conn = psycopg2.connect(**conn_config)
cur = conn.cursor()

# 执行关联查询
query = """
SELECT 
    ut.username AS user1_name,
    tt.*
FROM 
    your_schema.target_table tt
JOIN 
    your_schema.user_table ut ON tt.user1_id = ut.id;
"""
cur.execute(query)

# 读取并处理结果
for row in cur.fetchall():
    print(row)

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

2. 永久更新原表数据 #

import psycopg2

conn_config = {
    "dbname": "your_db",
    "user": "your_user",
    "password": "your_pwd",
    "host": "your_host",
    "port": "5432"
}

conn = psycopg2.connect(**conn_config)
cur = conn.cursor()

try:
    # 修改字段类型（若原字段是整数）
    alter_sql = """
    ALTER TABLE your_schema.target_table 
    ALTER COLUMN user1_id TYPE VARCHAR(50);
    """
    cur.execute(alter_sql)
    
    # 更新字段值
    update_sql = """
    UPDATE your_schema.target_table tt
    SET user1_id = ut.username
    FROM your_schema.user_table ut
    WHERE tt.user1_id::INT = ut.id;
    """
    cur.execute(update_sql)
    
    conn.commit()
    print("更新完成")
except Exception as e:
    conn.rollback()
    print(f"更新失败: {str(e)}")
finally:
    cur.close()
    conn.close()

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