标签:存储过程 add class code 变量 receive temp end var
用户需要提交加密数据,提交之后需要解密还原,还原有两种结果:成功和失败!
100个用户,之前7天,判断是否有提交数据,如果有提交有数据,判断是否解密成功(分别存在两个表中)。如果没有提交,显示黄色;提交,未解密成功,红色;提交并解密成功,绿色,并显示对应时间。
测试过遍历所有单位,之后遍历每一天,去查询提交数据,然后在去查询解密数据。结果一个100家单位,竟然需要大概2-3分钟的时间来查询。(接收记录里面数据大约50w条,后期可能会更多),明显不合适,虽然加过缓存,但是不符合要求。
优化思路:
1. 我想用100家单位和7天同时去关联接收记录表,进行查询。也就是多条件左外连接查询。
2. 我要获取100家单位和7天的这样的表,需要100家单位和7个日期的笛卡尔积
3. 我需要一个7天日期的表,可以在存储过程中进行创建临时表。
整体思路就是这样的。
整体存储过程代码如下:
ALTER PROCEDURE [dbo].[AUTOTRANS] @xz VARCHAR(10)=‘410000‘ , @day INT =7, @industryCode varchar(10)=‘6001‘ AS BEGIN SET NOCOUNT ON; --定义一个变量:临时表,用户存储7天数据。 DECLARE @days table (date date) DECLARE @today date = GETDATE() --定义一个循环,用于插入之前7天的数据,从当天开始 WHILE @day >= 0 BEGIN insert into @days select DATEadd(dd,-@day, @today ); set @day =@day-1 END --业务区域 SELECT D.XZ_CODE,D.UNIT_CODE,D.UNIT_NAME, CONVERT(varchar,D.RECEIVE_TIME,108) RECEIVE_TIME, CONVERT(varchar,MAX (E.RESTORE_TIME),108) RESTORE_TIME,D.date SELECT_DATE FROM ( SELECT A.XZ_CODE,A.UNIT_CODE,A.UNIT_NAME,MAX(C.RECEIVE_TIME) RECEIVE_TIME,B.date FROM (SELECT XZ_CODE,UNIT_CODE,UNIT_NAME FROM T_UNIT_AUDIT WHERE XZ_CODE = @xz AND INDUSTRY_CODE = @industryCode ) A CROSS JOIN @days B LEFT JOIN T_FILE_RECEIVE_RECORD C ON A.UNIT_CODE = C.UNIT_CODE AND A.XZ_CODE = C.XZ_CODE AND CONVERT(VARCHAR,B.date,23) = CONVERT(VARCHAR,C.RECEIVE_TIME,23) GROUP BY A.XZ_CODE,A.UNIT_CODE,A.UNIT_NAME,B.date ) D LEFT JOIN T_FILE_RESTORE_RECORD E ON D.XZ_CODE = E.XZ_CODE AND D.UNIT_CODE = E.UNIT_CODE AND CONVERT(VARCHAR,D.RECEIVE_TIME,23) = CONVERT(VARCHAR,E.RESTORE_TIME,23) GROUP BY D.RECEIVE_TIME,D.XZ_CODE,D.UNIT_CODE,D.UNIT_NAME,D.date END
目前,针对100家单位7天的数据,可以保证大约2秒内完成查询,当然这还包含了我在后期进行数据处理的时间。
由于项目是使用的jdbcTemplate进行的持久层操作,所以持久层操作代码附上:
public List<Map<String, Object>> autoTrans(Map<String, Object> param) { String sql = "{call AUTOTRANS(?,?,?)} "; //调用存储过程 List<Map<String, Object>> resultList = jdbcTemplate.execute( //定义传入参数,返回statement (connection)->{ CallableStatement statement = connection.prepareCall(sql); statement.setString(1,param.get("xzCode").toString()); statement.setString(2,param.get("days").toString()); statement.setString(3,param.get("industryCode").toString()); return statement; }, //执行存储过程,拿到结果集,处理结果集。因为这里lambda表达式如果不设置参数类型会导致重复,就设置了参数类型 (CallableStatement callableStatement) -> { List<Map<String,Object>> resultListParam =new ArrayList<>(); callableStatement.execute(); ResultSet resultSet = callableStatement.getResultSet(); while (resultSet.next()){ Map<String,Object> result = new HashMap<>();
result.put("xzCode",resultSet.getString("XZ_CODE"));
result.put("unitCode",resultSet.getString("UNIT_CODE"));
result.put("unitName",resultSet.getString("UNIT_NAME"));
result.put("receiveTime",resultSet.getString("RECEIVE_TIME"));
result.put("restoreTime",resultSet.getString("RESTORE_TIME"));
result.put("selectDate",resultSet.getDate("SELECT_DATE")); resultListParam.add(result); } return resultListParam; }); return resultList; }
到此结束,本次查询优化完成,基本达到目标要求。
标签:存储过程 add class code 变量 receive temp end var
原文地址:https://www.cnblogs.com/chenmc/p/9449712.html