oracle关闭流和in语句

master
zengwh 3 years ago
parent 39d8675f27
commit dcad9e69ac

@ -1402,7 +1402,7 @@ public class Archive_MasterServiceImpl implements Archive_MasterService {
}
//判断电子病历是否完成sysFlag = 2
//查询电子病历采集任务
String sql2 = "SELECT FPAT_NO,FREC_ID,FENTRY_NAME,FLOGLUDATE FROM VIEW_DOCTOR_DATA_2 WHERE FISAVAILABLE = 'Y' AND FENTRY_NAME NOT IN ('手术同意书'、'手术安全审核单'、'手术风险评估单') AND FPAT_NO = '"+jzh+"'";
String sql2 = "SELECT FPAT_NO,FREC_ID,FENTRY_NAME,FLOGLUDATE FROM VIEW_DOCTOR_DATA_2 WHERE FISAVAILABLE = 'Y' AND FENTRY_NAME NOT IN ('手术同意书','手术安全审核单','手术风险评估单') AND FPAT_NO = '"+jzh+"'";
try {
List<Map> selectList2 = OracleConnect.selectListConvertMap(sql2);
if(!CollectionUtils.isEmpty(selectList2)) {

@ -102,12 +102,17 @@ public class OracleConnect {
Connection conn = new OracleConnect().getConnect();
pst = conn.prepareStatement(arg0);
rs = pst.executeQuery();
if (rs != null) {
while (rs.next()) {
str = rs.getString(1);
try {
if (rs != null) {
while (rs.next()) {
str = rs.getString(1);
}
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
OracleConnect.CloseConn(rs, pst, conn);
}
OracleConnect.CloseConn(rs, pst, conn);
return str;
}
public static List<String> selectList(String arg0) throws Exception {
@ -115,12 +120,17 @@ public class OracleConnect {
Connection conn = new OracleConnect().getConnect();
pst = conn.prepareStatement(arg0);
rs = pst.executeQuery();
if (rs != null) {
while (rs.next()) {
str.add(rs.getString(1));
try {
if (rs != null) {
while (rs.next()) {
str.add(rs.getString(1));
}
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
OracleConnect.CloseConn(rs, pst, conn);
}
OracleConnect.CloseConn(rs, pst, conn);
return str;
}
public static List<Map> selectListConvertMap(String sql) throws Exception{
@ -128,18 +138,23 @@ public class OracleConnect {
Connection conn = new OracleConnect().getConnect();
pst = conn.prepareStatement(sql);
rs = pst.executeQuery();
if (rs != null) {
ResultSetMetaData md = rs.getMetaData();//获取键名
int columnCount = md.getColumnCount();//获取列的数量
while (rs.next()) {
Map<String, Object> rowData = new HashMap<>();//声明Map
for (int i = 1; i <= columnCount; i++) {
rowData.put(md.getColumnName(i), rs.getObject(i));//获取键名及值
try {
if (rs != null) {
ResultSetMetaData md = rs.getMetaData();//获取键名
int columnCount = md.getColumnCount();//获取列的数量
while (rs.next()) {
Map<String, Object> rowData = new HashMap<>();//声明Map
for (int i = 1; i <= columnCount; i++) {
rowData.put(md.getColumnName(i), rs.getObject(i));//获取键名及值
}
list.add(rowData);
}
list.add(rowData);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
OracleConnect.CloseConn(rs, pst, conn);
}
OracleConnect.CloseConn(rs, pst, conn);
return list;
}

Loading…
Cancel
Save