From 37551df55a9ee38a9e4c8cad14f6bc3e9602301f Mon Sep 17 00:00:00 2001 From: huanghai <10402852@qq.com> Date: Thu, 20 Aug 2020 14:38:18 +0800 Subject: [PATCH] 'commit' --- .../GovArea/GovAreaService/GovAreaService.go | 2 +- dsBaseRpc/Utils/SqlKit/SqlKit.go | 18 ------------------ 2 files changed, 1 insertion(+), 19 deletions(-) diff --git a/dsBaseRpc/RpcService/GovArea/GovAreaService/GovAreaService.go b/dsBaseRpc/RpcService/GovArea/GovAreaService/GovAreaService.go index 7e77f696..eac0c6e4 100644 --- a/dsBaseRpc/RpcService/GovArea/GovAreaService/GovAreaService.go +++ b/dsBaseRpc/RpcService/GovArea/GovAreaService/GovAreaService.go @@ -105,7 +105,7 @@ func (s *Rpc) DeleteGovArea(ctx context.Context, in *GovAreaProto.DeleteIdsArg) //rpc响应 var reply GovAreaProto.Reply //调用通用删除命令进行删除 - err := SqlKit.DeleteIdsPhysics("t_gov_area", in.Ids) + err := SqlKit.DeleteIds("t_gov_area", in.Ids) //错误处理 if err != nil { LogUtil.Error(ErrorConst.SqlUpdateError, "执行DeleteGovArea时发生严重错误:"+err.Error()) diff --git a/dsBaseRpc/Utils/SqlKit/SqlKit.go b/dsBaseRpc/Utils/SqlKit/SqlKit.go index f919e2a7..128da77c 100644 --- a/dsBaseRpc/Utils/SqlKit/SqlKit.go +++ b/dsBaseRpc/Utils/SqlKit/SqlKit.go @@ -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 -} - /** 功能:优先从缓存读取,检查到缺失的,就从数据库读取,然后两个结果集拼接后返回,同时将缺失的缓存补全 作者:黄海