From 0b2af4b9d490f156e3bb5e1806bcaeb06bf627fd Mon Sep 17 00:00:00 2001 From: xiang2lin <251481237@qq.com> Date: Tue, 9 Jul 2024 14:09:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=96=B9=E6=B3=95namespace?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=202024=E5=B9=B47=E6=9C=889=E6=97=A5=2014:09:?= =?UTF-8?q?17?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/hzya/frame/execsql/service/ExecSqlServiceImpl.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java b/common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java index ff02bcc4..d7057698 100644 --- a/common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java +++ b/common/src/main/java/com/hzya/frame/execsql/service/ExecSqlServiceImpl.java @@ -1,5 +1,6 @@ package com.hzya.frame.execsql.service; +import cn.hutool.core.util.StrUtil; import com.hzya.frame.datasource.DataSourceUtil; import com.hzya.frame.execsql.entity.ExecSqlEntity; import org.apache.ibatis.session.SqlSession; @@ -79,15 +80,15 @@ public class ExecSqlServiceImpl implements IExecSqlService { */ @Override public int execUpdateSql(String sql, String data_source_code) throws Exception { - logger.info("=============进入execUpdateSql方法============"); - if (ObjectUtils.isEmpty(sql)) { + logger.info("=============进入execUpdateSql方法============{},{}",sql,data_source_code); + if (StrUtil.isNotEmpty(sql)) { if (sql.contains("where") || sql.contains("WHERE")) { // SqlSession sqlSession = getSqlSession(data_source_code); // SqlSession sqlSession = new DataSourceUtil().getDefaultSqlSession(); logger.info("=============execUpdateSql方法要执行的sql：============" + sql); ExecSqlEntity entity = new ExecSqlEntity(); entity.setSql(sql); - int result = sqlSession.update("com.hzya.frame.sysnew.execsql.entity.ExecSqlEntity.ExecSqlEntity_execsql_update", entity); + int result = sqlSession.update("com.hzya.frame.execsql.entity.ExecSqlEntity.ExecSqlEntity_execsql_update", entity); logger.info("update受影响行数：" + result); //sqlSession.close(); return result;