基于列唯一值实现两表UNION联合排序并按C1值分发电邮需求

嗨，咱们把你的问题拆成两个明确的部分来一步步解决，搞定UNION后的行排序需求，再实现按C1分组发送给指定收件人的功能～

一、实现UNION后同一C1值的行连续排列 #

常规的UNION/UNION ALL操作不会保证同一C1值的行连续，因为数据库的排序是基于优化器选择的执行计划。要实现你要的效果，咱们可以给每张表加一个临时的排序标识字段，再通过ORDER BY来精准控制顺序。

假设你的表A和表B结构都是C1（唯一标识列）+C2（数值列），用下面的SQL就能得到目标结果：

-- 用UNION ALL（无去重，性能更好），如果需要去重就换成UNION
SELECT C1, C2, 1 AS sort_flag FROM 表A
UNION ALL
SELECT C1, C2, 2 AS sort_flag FROM 表B
ORDER BY C1, sort_flag;

逻辑说明： #

• sort_flag是临时字段，标记行来自表A（1）还是表B（2）
• ORDER BY C1, sort_flag先按C1分组，再按标识排序，确保表A的行排在对应表B行的前面
• 执行后得到的结果完全符合你的要求：

如果需要去重（比如两张表可能存在相同的C1,C2组合），可以把查询嵌套一层，避免sort_flag影响去重逻辑：

SELECT C1, C2 FROM (
    SELECT C1, C2, 1 AS sort_flag FROM 表A
    UNION
    SELECT C1, C2, 2 AS sort_flag FROM 表B
) AS combined_result
ORDER BY C1, sort_flag;

二、按C1分组将对应行发送给指定收件人 #

这部分需要结合脚本语言（比如Python、Shell）来实现，因为数据库本身的邮件功能灵活性有限。下面以Python为例，给出通用的实现思路：

步骤1：准备数据库连接与收件人映射 #

首先要连接数据库，同时定义C1值和收件人邮箱的对应关系：

import pymysql  # MySQL用这个，PostgreSQL用psycopg2，Oracle用cx_Oracle
import smtplib
from email.mime.text import MIMEText

# 数据库连接配置
db_conn = pymysql.connect(
    host="你的数据库地址",
    user="用户名",
    password="密码",
    database="数据库名"
)
cursor = db_conn.cursor()

# 定义C1值到收件人邮箱的映射
recipient_map = {
    'a': 'user_a@yourdomain.com',
    'b': 'user_b@yourdomain.com'
    # 可以继续添加更多C1对应的收件人
}

步骤2：分组查询数据并发送邮件 #

遍历每个C1值，查询对应的数据，生成HTML表格邮件，再发送给指定收件人：

# 邮件服务器配置（以企业邮箱为例，根据你的邮箱服务商调整）
smtp_host = "smtp.yourdomain.com"
smtp_port = 587
sender_email = "your_email@yourdomain.com"
sender_password = "你的邮箱授权码"

# 获取所有需要处理的C1唯一值
cursor.execute("SELECT DISTINCT C1 FROM (SELECT C1 FROM 表A UNION SELECT C1 FROM 表B) AS all_c1;")
all_c1_list = [row[0] for row in cursor.fetchall()]

for c1 in all_c1_list:
    # 查询当前C1对应的所有行（保持表A在前，表B在后的顺序）
    cursor.execute("""
        SELECT C1, C2 FROM (
            SELECT C1, C2 FROM 表A WHERE C1 = %s
            UNION ALL
            SELECT C1, C2 FROM 表B WHERE C1 = %s
        ) AS target_data ORDER BY C1;
    """, (c1, c1))
    data_rows = cursor.fetchall()
    
    # 生成HTML格式的表格（方便收件人查看）
    table_content = "<table border='1' cellpadding='5' cellspacing='0'>"
    table_content += "<tr><th>C1</th><th>C2</th></tr>"
    for row in data_rows:
        table_content += f"<tr><td>{row[0]}</td><td>{row[1]}</td></tr>"
    table_content += "</table>"
    
    # 构建邮件
    email_subject = f"【数据通知】C1={c1}的相关行数据"
    email_msg = MIMEText(table_content, 'html', 'utf-8')
    email_msg['Subject'] = email_subject
    email_msg['From'] = sender_email
    email_msg['To'] = recipient_map.get(c1, 'default_recipient@yourdomain.com')  # 找不到对应C1就发默认收件人
    
    # 发送邮件
    try:
        with smtplib.SMTP(smtp_host, smtp_port) as server:
            server.starttls()  # 开启加密传输
            server.login(sender_email, sender_password)
            server.send_message(email_msg)
        print(f"C1={c1}的邮件已成功发送")
    except Exception as e:
        print(f"C1={c1}的邮件发送失败：{str(e)}")

# 关闭数据库连接
cursor.close()
db_conn.close()

额外提示： #

• 如果你的数据库支持存储过程（比如MySQL、SQL Server），也可以用存储过程结合数据库的邮件功能实现，但脚本语言的灵活性更高，方便调整格式和处理异常。
• 建议添加日志记录，方便后续排查发送问题；如果收件人是企业内部系统的ID，可以把邮件发送换成调用内部API推送消息。

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