public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-15 04:22:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

!2 【fix】修复空项目启动的时候，使用spring默认数据源时 表实际存在，但是启动时候报无可用数据源的问题

Browse Source 
Merge pull request !2 from 韩华锋/fix_init_db_source_error
This commit is contained in:
韩华锋
2023-09-08 07:29:00 +00:00
committed by Gitee
parent 3815322721 1e7b142ad4
commit 6da2d2b3b7
1 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
liteflow-rule-plugin/liteflow-rule-sql/src/main/java/com/yomahub/liteflow/parser/sql/util/LiteFlowJdbcUtil.java
View File

@@ -13,14 +13,14 @@ import java.util.Map;
public class LiteFlowJdbcUtil {
private static final Logger LOG = LoggerFactory.getLogger(LiteFlowJdbcUtil.class);
private static final String CHECK_SQL_PATTERN = "SELECT {},{} FROM {} WHERE {}='{}'";
private static final String CHECK_SQL_PATTERN = "SELECT {},{} FROM {}";
/**
* 获取链接
* 此方法会根据配置，判读使用指定数据源，还是IOC容器中已有的数据源
*
* @param sqlParserVO
* @return
* @param sqlParserVO sql解析器参数
* @return 返回数据库连接
*/
public static Connection getConn(SQLParserVO sqlParserVO) {
Connection connection = null;
@@ -74,7 +74,7 @@ public class LiteFlowJdbcUtil {
stmt = conn.prepareStatement(sql, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
stmt.setFetchSize(1);
rs = stmt.executeQuery();
return rs.next();
return true;
} catch (Exception e) {
return false;
} finally {
@@ -87,7 +87,6 @@ public class LiteFlowJdbcUtil {
* 关闭
*
* @param conn conn
* @param conn conn
* @param rs rs
*/
public static void close(Connection conn, PreparedStatement stmt, ResultSet rs) {
@@ -120,15 +119,13 @@ public class LiteFlowJdbcUtil {
/**
* 构建检查 sql
*
* @param sqlParserVO
* @return
* @param sqlParserVO sql解析器参数
* @return 返回组合完成的检查sql
*/
private static String buildCheckSql(SQLParserVO sqlParserVO) {
String chainTableName = sqlParserVO.getChainTableName();
String elDataField = sqlParserVO.getElDataField();
String chainNameField = sqlParserVO.getChainNameField();
String chainApplicationNameField = sqlParserVO.getChainApplicationNameField();
String applicationName = sqlParserVO.getApplicationName();
return StrUtil.format(CHECK_SQL_PATTERN, chainNameField, elDataField, chainTableName, chainApplicationNameField, applicationName);
return StrUtil.format(CHECK_SQL_PATTERN, chainNameField, elDataField, chainTableName);
}
}