MySQL单查询从已有表插入聚合数据至目标表问题求助

嘿，我来帮你搞定这个需求！你想要用单查询把company_products的聚合数据插入到company_value里，核心是用条件聚合（结合SUM和CASE语句），这样不用拆分多个子查询再关联，既简洁又能避免语法错误。

直接可用的SQL插入语句 #

INSERT INTO company_value (companyCode, trPeriod, total, export_val, import_val)
SELECT 
    cp.companyCode,
    cp.trPeriod,
    SUM(cp.amount) AS total,
    SUM(CASE WHEN cp.trType = 'export' THEN cp.amount ELSE 0 END) AS export_val,
    SUM(CASE WHEN cp.trType = 'import' THEN cp.amount ELSE 0 END) AS import_val
FROM company_products cp
GROUP BY cp.companyCode, cp.trPeriod;

语句解释： #

• SUM(cp.amount)：直接计算每个公司（companyCode）每个周期（trPeriod）的总金额，对应total字段；
• SUM(CASE...)：通过条件判断，只累加对应交易类型的金额——当trType是export时算入export_val，是import时算入import_val，否则加0；
• GROUP BY：确保按公司和周期分组，每个分组对应一条要插入到company_value的数据。

为什么这个方法比多子查询关联更好？
之前你尝试用多个子查询关联时，容易出现分组不一致、数据丢失（比如某个周期只有出口没有进口，JOIN可能过滤掉这条数据）或者语法错误的问题，而条件聚合在同一个查询里完成所有计算，逻辑更清晰，性能也更优。

Peewee ORM实现方案 #

如果你想用Peewee来做，对应的代码逻辑和SQL一致，用fn.SUM和Case来实现条件聚合：

from peewee import *

# 假设你已经定义了如下模型（根据你的表结构调整）
db = MySQLDatabase('your_database', user='user', password='pass')

class CompanyProducts(Model):
    companyCode = CharField()
    trPeriod = CharField()
    trType = CharField()
    amount = DecimalField()

    class Meta:
        database = db
        table_name = 'company_products'

class CompanyValue(Model):
    companyCode = CharField()
    trPeriod = CharField()
    total = DecimalField()
    export_val = DecimalField()
    import_val = DecimalField()

    class Meta:
        database = db
        table_name = 'company_value'

# 构建聚合查询
agg_query = (CompanyProducts
             .select(
                 CompanyProducts.companyCode,
                 CompanyProducts.trPeriod,
                 fn.SUM(CompanyProducts.amount).alias('total'),
                 fn.SUM(Case(
                     (CompanyProducts.trType == 'export', CompanyProducts.amount),
                     default=0
                 )).alias('export_val'),
                 fn.SUM(Case(
                     (CompanyProducts.trType == 'import', CompanyProducts.amount),
                     default=0
                 )).alias('import_val')
             )
             .group_by(CompanyProducts.companyCode, CompanyProducts.trPeriod))

# 执行插入
CompanyValue.insert_from(
    agg_query,
    fields=[CompanyValue.companyCode, CompanyValue.trPeriod, CompanyValue.total, CompanyValue.export_val, CompanyValue.import_val]
).execute()

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