gorm 原始查询 动态拼接条件

Question

我使用 Gorm 原始 SQL 查询，但 Web 开发人员将它传递给我多个参数。如果参数为空，则不执行查询。目前我用map拼接where语句，但是raw模式下好像不行。

where := make(map[string]interface{})
    if info.UserKey != "" {
        where["pay_merchant_order.merchant_fk"] = info.UserKey
    }
    if info.NickName != "" {
        where["sys_users.nick_name"] = info.NickName
    }
    if info.Type != 0 {
        where["pay_rate.id"] = info.Type
    }
    if info.IsSign != -1 && info.IsSign != 0 {
        where["pay_order.pay_status"] = info.IsSign
    }
    if info.PayOfficialOrder != "" {
        where["pay_order.pay_official_order"] = info.PayOfficialOrder
    }
    if info.Amount != 0 {
        where["pay_order.pay_amount"] = info.Amount
    }
    if info.MOrder != "" {
        where["pay_merchant_order.order"] = info.MOrder
    }
    if info.SOrder != "" {
        where["pay_merchant_order.sys_order_fk"] = info.SOrder
    }
    if info.Phone != "" {
        where["pay_channel_order.phone"] = info.Phone
    }
    if info.Rate != 0 {
        where["pay_order.pay_rate"] = info.Rate
    }
    db := global.GVA_DB.Debug()
    sql := "select pay_merchant_order.id,pay_merchant_order.order,pay_merchant_order.call_status,sys_users.username,pay_order.url,pay_merchant_order.merchant_fk,pay_order.token,pay_merchant_order.call_back,sys_users.nick_name,pay_order.pay_rate as rate,pay_order.pay_amount,pay_actualamount,pay_order.real_pay_amount,pay_order.pay_official_order,pay_order.pay_sys_order,pay_type.mode,pay_rate.name,pay_merchant_order.is_sign,pay_order.created_at,pay_order.pay_time,pay_order.overdue_time,pay_channel_order.phone from pay_merchant_order LEFT JOIN pay_order ON pay_order.pay_sys_order = pay_merchant_order.sys_order_fk LEFT JOIN sys_users ON sys_users.unique = pay_order.pay_merchant LEFT JOIN pay_channel ON pay_channel.id = pay_order.pay_channel_fk LEFT JOIN pay_rate ON pay_rate.id = pay_channel.rate_fk LEFT JOIN pay_payment_type ON pay_payment_type.id = pay_channel.channel_type_fk LEFT JOIN pay_type ON pay_type.id = pay_order.pay_type left join pay_channel_order on pay_channel_order.order_fk = pay_merchant_order.sys_order_fk"
    db.Raw(sql).Where(where).Group("pay_merchant_order.id").Order("pay_merchant_order.created_at desc").Scan(&payMerchantOrders)
    err = db.Count(&total).Error
    err = db.Limit(limit).Offset(offset).Error

请告诉我如何拼接查询条件。

Answer 1

尝试两种解决方案：

解决方案 1 - 没有原始查询

//your code for additions to the where clause

...

//the main part of the query
db.Table("pay_merchant_order").
Joins("LEFT JOIN pay_order ON pay_order.pay_sys_order = pay_merchant_order.sys_order_fk").
Joins("LEFT JOIN sys_users ON sys_users.unique = pay_order.pay_merchant").
Joins("LEFT JOIN pay_channel ON pay_channel.id = pay_order.pay_channel_fk").
Joins("LEFT JOIN pay_rate ON pay_rate.id = pay_channel.rate_fk").
Joins("LEFT JOIN pay_payment_type ON pay_payment_type.id = pay_channel.channel_type_fk").
Joins("LEFT JOIN pay_type ON pay_type.id = pay_order.pay_type").
Joins("LEFT JOIN pay_channel_order on pay_channel_order.order_fk = pay_merchant_order.sys_order_fk").
Where(where).
Select("pay_merchant_order.id,pay_merchant_order.order,pay_merchant_order.call_status,sys_users.username,pay_order.url,pay_merchant_order.merchant_fk,pay_order.token,pay_merchant_order.call_back,sys_users.nick_name,pay_order.pay_rate as rate,pay_order.pay_amount,pay_actualamount,pay_order.real_pay_amount,pay_order.pay_official_order,pay_order.pay_sys_order,pay_type.mode,pay_rate.name,pay_merchant_order.is_sign,pay_order.created_at,pay_order.pay_time,pay_order.overdue_time,pay_channel_order.phone").
Group("pay_merchant_order.id").
Order("pay_merchant_order.created_at desc")

然后，您可以使用Scan、Find 和Count 检索所需的信息。

解决方案 2 - 仅原始查询

此解决方案基于为原始查询准备 where 子句并仅运行原始查询。

type WhereClause map[string]interface{}

func (wc WhereClause) ConvertToSQLString() string {
    list := []string{}

    for k, v := range wc {
        list = append(list, fmt.Sprintf("%s=%v", k, v))
    }

    return strings.Join(list, " AND ")
}

where := WhereClause{}
    if info.UserKey != "" {
        where["pay_merchant_order.merchant_fk"] = info.UserKey
    }
    if info.NickName != "" {
        where["sys_users.nick_name"] = info.NickName
    }
    if info.Type != 0 {
        where["pay_rate.id"] = info.Type
    }
    if info.IsSign != -1 && info.IsSign != 0 {
        where["pay_order.pay_status"] = info.IsSign
    }
    if info.PayOfficialOrder != "" {
        where["pay_order.pay_official_order"] = info.PayOfficialOrder
    }
    if info.Amount != 0 {
        where["pay_order.pay_amount"] = info.Amount
    }
    if info.MOrder != "" {
        where["pay_merchant_order.order"] = info.MOrder
    }
    if info.SOrder != "" {
        where["pay_merchant_order.sys_order_fk"] = info.SOrder
    }
    if info.Phone != "" {
        where["pay_channel_order.phone"] = info.Phone
    }
    if info.Rate != 0 {
        where["pay_order.pay_rate"] = info.Rate
    }
db := global.GVA_DB.Debug()
sql := fmt.Sprintf(`SELECT pay_merchant_order.id,pay_merchant_order.order,pay_merchant_order.call_status,sys_users.username,pay_order.url,pay_merchant_order.merchant_fk,pay_order.token,pay_merchant_order.call_back,sys_users.nick_name,pay_order.pay_rate as rate,pay_order.pay_amount,pay_actualamount,pay_order.real_pay_amount,pay_order.pay_official_order,pay_order.pay_sys_order,pay_type.mode,pay_rate.name,pay_merchant_order.is_sign,pay_order.created_at,pay_order.pay_time,pay_order.overdue_time,pay_channel_order.phone 
FROM pay_merchant_order LEFT JOIN pay_order ON pay_order.pay_sys_order = pay_merchant_order.sys_order_fk LEFT JOIN sys_users ON sys_users.unique = pay_order.pay_merchant LEFT JOIN pay_channel ON pay_channel.id = pay_order.pay_channel_fk LEFT JOIN pay_rate ON pay_rate.id = pay_channel.rate_fk LEFT JOIN pay_payment_type ON pay_payment_type.id = pay_channel.channel_type_fk LEFT JOIN pay_type ON pay_type.id = pay_order.pay_type left join pay_channel_order on pay_channel_order.order_fk = pay_merchant_order.sys_order_fk
WHERE %s
GROUP BY pay_merchant_order.id
ORDER BY pay_merchant_order.created_at DESC`, where.ConvertToSQLString())
    
db.Raw(sql).Scan(&payMerchantOrders)