|
|
|
@ -39,24 +39,6 @@ func DeleteIds(tableName string, ids []string) error {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
功能:通用的批量删除功能(物理)
|
|
|
|
|
作者:黄海
|
|
|
|
|
时间:2020-05-29
|
|
|
|
|
*/
|
|
|
|
|
func DeleteIdsPhysics(tableName string, ids []string) error {
|
|
|
|
|
//1、清除Redis缓存
|
|
|
|
|
var selector = GetBean(tableName)
|
|
|
|
|
DeleteCacheByIds(ids, selector)
|
|
|
|
|
//2、获取此表的主键
|
|
|
|
|
_, PkField := GetTablePk(tableName)
|
|
|
|
|
//3、批量删除
|
|
|
|
|
var myBuilder = builder.Dialect(builder.MYSQL).Delete().From(tableName).Where(builder.In(PkField, ids))
|
|
|
|
|
sql, _ := myBuilder.ToBoundSQL()
|
|
|
|
|
_, err := db.SQL(sql).Execute()
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
功能:优先从缓存读取,检查到缺失的,就从数据库读取,然后两个结果集拼接后返回,同时将缺失的缓存补全
|
|
|
|
|
作者:黄海
|
|
|
|
|