Skip to content

Latest commit

 

History

History
162 lines (128 loc) · 6.19 KB

Golang根据指定的两个字段，批量删除数据库中的相关记录.md

File metadata and controls

162 lines (128 loc) · 6.19 KB

表格数据

app_id 参数名称 参数值 参数值名称
100074 qwe12345 mao11 超超1
100074 ssss mao3 超超1
100074 qwe12 ma01 超超2
100074 www mao3 超超3
100074 www mao4 超超4
100036 qwe12345 1233 123
100036 ssss mao3 123
100036 qwe12 100036 100036
100036 www www1 dd

对应结构体

type appEvents struct {
    ID          int32  `gorm:"column:id;primaryKey;autoIncrement:true" json:"id"`  // 主键
    AppID       string `gorm:"column:app_id;not null" json:"app_id"`               // 应用id
    Params      string `gorm:"column:params;not null" json:"params"`               // 参数名称
    ParamsValue string `gorm:"column:params_value;not null" json:"params_value"`   // 参数值
    ParamsLabel string `gorm:"column:params_label;not null" json:"params_label"`   // 参数值名称
    Creator     int32  `gorm:"column:creator;not null" json:"creator"`             // 创建人id
    CreatedAt   int64  `gorm:"column:created_at;autoCreateTime" json:"created_at"` // 创建时间
    UpdatedAt   int64  `gorm:"column:updated_at;autoUpdateTime" json:"updated_at"` // 更新时间
}

错误示例

appEventsIDStr := make([]string, 0, len(appEvents))
appEventsParams := make([]string, 0, len(appEvents))
for _, event := range appEvents {
    appEventsIDStr = append(appEventsIDStr, event.AppID)
    appEventsParams = append(appEventsParams, event.Params)
}
_, err = dao.WithContext(ctx).Where(dao.AppID.In(appEventsIDStr...), dao.Params.In(appEventsParams...)).Delete()
if err != nil {
    return err
}

这段代码的意图是：直接将表格中的AppID和Params装入分别appEventsIDStr和appEventsParams中

然后批量删除那些其 AppID 值存在于 appEventsIDStr 且其 Params 值存在于 appEventsParams 的记录。

这会造成的问题如下:

正常删除了如下数据:

app_id 参数名称
100074 qwe12345

但同时也会误删其他app_id下名称为 qwe12345 的数据:

app_id 参数名称
100036 qwe12345

只要是 appEventsIDStr 包含的应用id 和 appEventsParams 中包含的参数名称都会被全部删除!

这显然是不符合业务需求的:删除指定app_id和参数名称下的数据

正确逻辑

  1. 创建映射：为 appEvents 创建一个映射，其中键由 AppID 和 Params 组合而成。
  2. 从数据库获取数据：查询数据库，获取那些其 AppID 和 Params 在指定的列表中的数据。
  3. 收集要删除的 IDs：根据先前创建的映射，筛选出数据库中需要删除的条目的 IDs。
  4. 删除数据库条目：基于筛选出来的 IDs，执行数据库中的删除操作。

代码实现

// 将 appEventsIDStr 和 appEventsParams 组合成 map的key ,value为空结构体的map
	appEventsMap := make(map[string]struct{}, len(appEventsIDStr))
	for _, event := range appEvents {
		appEventsMap[event.AppID+"_"+event.Params] = struct{}{}
	}

	// 批量删除旧数据
	dao := tx.CfgEventParamsValue
	find, err := dao.WithContext(ctx).Where(dao.AppID.In(appEventsIDStr...), dao.Params.In(appEventsParams...)).Find()
	if err != nil {
		return err
	}
	var ids []int32
	for _, value := range find {
		// 将数据库中的数据组合成map的key
		// value.AppID + "_" + value.Params 为map的key
		// value.ParamsValue 为map的value
		_, exists := appEventsMap[value.AppID+"_"+value.Params]
		if exists {
			ids = append(ids, value.ID)
		}
	}
	_, err = dao.WithContext(ctx).Where(dao.ID.In(ids...)).Delete()
	if err != nil {
		return err
	}

代码详解

  1. 构建appEventsMap映射:
appEventsMap := make(map[string]struct{}, len(appEventsIDStr))
for _, event := range appEvents {
    appEventsMap[event.AppID+"_"+event.Params] = struct{}{}
}

在这段代码中，首先初始化了一个名为 appEventsMap 的映射，其键是字符串，值是空结构体（struct{} 不占用任何额外的内存空间）。接下来，遍历每个 appEvents 条目并构造映射键，该键是 AppID 和 Params 的组合，并为每个键分配一个空结构体值。目的: 将 appEvents 列表转换为映射，以便后续可以快速检查某个组合（AppID 和 Params）是否存在于 appEvents 中。

  1. 查询出要删除的旧数据:
appEventsIDStr := make([]string, 0, len(appEvents))
appEventsParams := make([]string, 0, len(appEvents))
for _, event := range appEvents {
    appEventsIDStr = append(appEventsIDStr, event.AppID)
    appEventsParams = append(appEventsParams, event.Params)
}

dao := tx.CfgEventParamsValue
find, err := dao.WithContext(ctx).Where(dao.AppID.In(appEventsIDStr...), dao.Params.In(appEventsParams...)).Find()
if err != nil {
    return err
}

使用 dao 查询数据库中的数据。此查询的条件是 AppID 必须在 appEventsIDStr 中，Params 必须在 appEventsParams 中。

  1. 筛选要删除的数据ID:
var ids []int32
for _, value := range find {
    _, exists := appEventsMap[value.AppID+"_"+value.Params]
    if exists {
        ids = append(ids, value.ID)
    }
}

在这个循环中，您检查从数据库查询返回的每个条目是否存在于之前创建的 appEventsMap 中。如果存在，那么该条目的 ID 被添加到要删除的ID列表中。

  1. 执行删除操作:
_, err = dao.WithContext(ctx).Where(dao.ID.In(ids...)).Delete()
if err != nil {
    return err
}

最后，执行实际的删除操作。您通过在ids列表中指定的ID来删除所有条目。

综合分析: 该代码的主要目的是从数据库中删除特定的旧数据。这些数据由其AppID和Params确定，并在appEvents列表中给出。首先，代码将这个列表转换为一个映射，以便可以快速检查一个给定的AppID和Params组合是否存在。然后，代码查询与这些AppID和Params组合匹配的所有数据库条目，并删除这些条目。