简介
Flyway是一款数据库迁移（migration）工具。简单点说，就是在部署应用的时候，帮你执行数据库脚本的工具。Flyway支持SQL和Java两种类型的脚本，你可以将脚本打包到应用程序中，在应用程序启动时，由Flyway来管理这些脚本的执行，这些脚本被Flyway称之为migration。
使用
添加依赖
xml<!-- flyway数据库版本迁移-->
<dependency>
<groupId>org.flywaydb</groupId>
<artifactId>flyway-core</artifactId>
<version>7.15.0</version>
</dependency>
前提
由于业务要求使用easyexcel无对象导出的方式，通过sql获取list<string,object>数据，同时列名还需要用字段名转成中文，导致for循环比较多，因为单线程执行，数据量又是几千条，每一行的数据又是七八百列，导致效率非常慢
思路
通过拆分list，将list拆成多段后，使用线程池，每个线程执行一个任务，最后把结果合并起来
代码
修改前
问题比较多，也没对异常做很好的处理
java
public void exportSqlScriptExcuteResultExcel(HttpServletResponse response, RecSearchSolutionSqlScriptExcuteResultRequest request) {
request.setType(1);
IPage<Map<String, Object>> iPage = this.getSqlScriptExcuteResult(request);
List<Map<String,Object>> dataMaplist= iPage.getRecords();
//查询当前方案的已选字段
RecSearchSolutionFieldRequest fieldRequest=new RecSearchSolutionFieldRequest();
fieldRequest.setSolutionId(request.getSolutionId());
List<RecSearchSolutionFieldEntity> recSearchSolutionFieldList=iRecSearchSolutionFieldService.getRecSearchSolutionFieldMapByIsDisplay(fieldRequest);
Map<String, String> recSearchSolutionFieldMap = recSearchSolutionFieldList.stream().collect(Collectors.toMap(arr -> arr.getField(), arr -> arr.getText(), (v1, v2) -> null, LinkedHashMap::new));
recSearchSolutionFieldMap.values().removeIf(Objects::isNull);
//列名的集合
List<List<String>> headList = new ArrayList<>();
//每行数据的集合
List<List<Object>> dataList = new ArrayList<>();
//是否为首次 0为首次
int i = 0;
try {
for (Map<String, Object> map : dataMaplist) {
List<Object> data = new ArrayList<>();
List<String>[] head = new List[]{null};
for (Map.Entry<String, Object> m : map.entrySet()) {
if (recSearchSolutionFieldMap!=null){
if (!recSearchSolutionFieldMap.containsKey(m.getKey())){
continue;
}
}
if (m.getValue() instanceof Date){
data.add(DateUtil.format((Date) m.getValue(),"yyyy-MM-dd HH:ss:mm"));
}else {
data.add(m.getValue());
}
//首次遍历就进入
if (i == 0) {
int headNum = 0;
head[headNum] = new ArrayList<>();
String text=recSearchSolutionFieldMap.get(m.getKey());
if(StrUtil.isBlank(text)){
head[headNum].add(m.getKey());
}else{
head[headNum].add(text);
}
headList.add(head[headNum]);
headNum++;
}
}
i++;
dataList.add(data);
}
String nowDate = DateUtil.format(new Date(),"yyyy_MM_dd_HH_mm_ss");
String fileName = "综合查询导出_" + nowDate;
response.setCharacterEncoding("utf-8");
response.setContentType("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");
response.setHeader("Content-disposition", "attachment;filename=" + URLEncoder.encode(fileName + ".xlsx", "utf-8"));
WriteCellStyle headWriteCellStyle = new WriteCellStyle();
WriteFont headWriteFont = new WriteFont();
headWriteFont.setFontHeightInPoints((short)10);
headWriteCellStyle.setWriteFont(headWriteFont);
HorizontalCellStyleStrategy horizontalCellStyleStrategy=new HorizontalCellStyleStrategy();
horizontalCellStyleStrategy.setHeadWriteCellStyle(headWriteCellStyle);
EasyExcel.write(response.getOutputStream()).registerWriteHandler(horizontalCellStyleStrategy).head(headList).autoCloseStream(Boolean.FALSE).sheet("sheet").doWrite(dataList);
} catch (IOException e) {
throw new BusinessException(ResultCodeEnum.ERR_0x1000);
}
}
前提
前台页面上不管分页选第几页，返回的结果都是相同的
分页相同的原因
- 使用了order by和limit语句，但是没有指定唯一的排序条件。这样可能导致排序结果不稳定，相同的值可能排序出来的结果和读出来的数据顺序不一致。
- 使用了子查询，但是没有在子查询中指定order by语句。这样可能导致子查询的结果顺序不确定，从而影响分页查询的结果。
- 使用了rownum作为分页条件，但是没有在外层查询中再次排序。这样可能导致rownum的值不按照预期的顺序分配，从而影响分页查询的结果。
为了避免这些问题，您可以尝试以下方法：
- 在order by语句中添加一个唯一的排序条件，比如主键或者时间戳等。这样可以保证排序结果的稳定性和一致性。
- 在子查询中也添加order by语句，以确保子查询的结果顺序和外层查询的顺序一致。
- 在使用rownum作为分页条件时，在外层查询中再次按照需要的顺序排序，以确保rownum的值正确地分配。
前提
由于业务需要得通过存储过程返回结果集，方便现场实施进行自主调整sql语句条件，查到结果集需要重新进行组合，按照和前端约定的数据结构进行返回，此次调用oracle存储函数通过jdbctemplate的方式调用
介绍
Oracle存储过程是一种用于执行特定数据库功能的SQL语句集合。它们经过编译后存储在数据库系统中，可以通过指定存储过程名称并给出相应的参数来调用和执行。
Oracle存储过程通常包含以下三部分：
过程声明：定义存储过程的名称、参数和返回值等信息。 例如，以下代码定义了一个名为"get_employee_details"的存储过程，它接受一个参数"employee_id"并返回一个结果集：
sqlCREATE OR REPLACE PROCEDURE get_employee_details (
employee_id IN NUMBER,
employee_details OUT sys_refcursor
) AS
BEGIN
-- 执行查询操作
OPEN employee_details FOR
SELECT * FROM employees WHERE employee_id = employee_id;
END;
/
执行过程部分：包含具体的数据库操作和逻辑判断。 例如，以下代码展示了一个简单的存储过程，它接受两个参数"start_date"和"end_date"，并返回一个结果集：
sqlCREATE OR REPLACE PROCEDURE get_sales_report (
start_date IN DATE,
end_date IN DATE,
sales_report OUT sys_refcursor
) AS
BEGIN
-- 执行查询操作
OPEN sales_report FOR
SELECT * FROM sales WHERE sale_date BETWEEN start_date AND end_date;
END;
/
存储过程异常：用于处理可能出现的异常情况，以保证存储过程的稳定性和可靠性。 例如，以下代码展示了一个带有异常处理的存储过程，它接受一个参数"employee_id"，并返回一个结果集：
sqlCREATE OR REPLACE PROCEDURE get_employee_details (
employee_id IN NUMBER,
employee_details OUT sys_refcursor
) AS
BEGIN
-- 判断参数是否为空
IF employee_id IS NULL THEN
RAISE_APPLICATION_ERROR(-20001, 'Please provide an employee ID.');
END IF;
-- 执行查询操作
OPEN employee_details FOR
SELECT * FROM employees WHERE employee_id = employee_id;
EXCEPTION WHEN OTHERS THEN
ROLLBACK; -- 处理异常并回滚事务
END;
/
实现
创建oracle存储过程
sql
create or replace procedure PRO_REC_HOMEPAGE_PANE(deptCode in varchar2,
startTime in date,
endTime in date,
list2 out sys_refcursor) is
begin
OPEN list2 FOR
select '出院人数' as CARD_NAME,
0 as UNDO_COUNT,
(SELECT COUNT(*) AS people_count
FROM pat_visit_v a
WHERE a.DISCHARGE_TIME IS NOT NULL
AND a.DISCHARGE_TIME >= startTime
AND a.DISCHARGE_TIME <= endTime
AND (deptCode IS NULL OR a.DEPT_DISCHARGE_FROM = deptCode)) as DO_COUNT
from dual
union all
select '病案提交' as CARD_NAME,
(select count(*) as people_count
from rec_mrhp_submit b, pat_visit_v t
where t.patient_id = b.PATIENT_ID(+)
and t.VISIT_NO = b.VISIT_ID(+)
and (b.mr_status is null or b.MR_STATUS = '0')
and t.DISCHARGE_TIME is not null
AND t.DISCHARGE_TIME >= startTime
AND t.DISCHARGE_TIME <= endTime
AND (deptCode IS NULL OR t.DEPT_DISCHARGE_FROM = deptCode)) as UNDO_COUNT,
(select count(*) as people_count
from rec_mrhp_submit b, pat_visit_v t
where t.patient_id = b.PATIENT_ID(+)
and t.VISIT_NO = b.VISIT_ID(+)
and b.mr_status in ('4', '5')
and t.DISCHARGE_TIME is not null
AND t.DISCHARGE_TIME >= startTime
AND t.DISCHARGE_TIME <= endTime
AND (deptCode IS NULL OR t.DEPT_DISCHARGE_FROM = deptCode)) as DO_COUNT
from dual;
end PRO_REC_HOMEPAGE_PANE;
前提
由于业务需要，需要返回多个值，不能在程序里写死sql，所以就改成写函数，让现场可以自动配置
问题
oracle函数和存储过程返回结果集是一件很麻烦的事情，其次就是不能使用同一个字段名union,如果设置成返回复杂对象或者游标类型，那么就不够动态，前端还是要不断因为现场调整函数而进行调整，所以我采用拼接字符串的方式，返回一个字符串，然后java根据字符串来中','，来进行分割成数组返回给前端，这个方式只能在函数中每个select查询都是查询一个结果的时候才能用，如果查询多个结果就不好用了
实现
oracle 函数
sql
create or replace function get_important_mark(patientId in varchar2,
visitNo in varchar2)
RETURN VARCHAR2 IS
result_marks VARCHAR2(100); -- 修改为result_marks变量，并指定适当的长度
mark1 VARCHAR2(10);
mark2 VARCHAR2(10);
BEGIN
-- 第一个查询语句
SELECT CASE
WHEN SYSDATE - t.admission_date_time > 3 THEN
'三'
ELSE
''
END
INTO mark1
FROM system.abc t
WHERE t.patietn_id = patientId
AND t.visit_id = visitNo;
-- 将第一个标记赋值给result_marks变量
result_marks := mark1;
-- 第二个查询语句（修改条件）
SELECT CASE
WHEN SYSDATE - t.discharge_date_time > 3 THEN
'四'
ELSE
''
END
INTO mark2
FROM system.abc t
WHERE t.patient_id = patientId
AND t.visit_id = visitNo;
-- 将第二个标记添加到result_marks变量中（使用字符串连接操作符）
result_marks := result_marks || ',' || mark2;
-- 返回结果值
RETURN result_marks;
END get_important_mark;
