add null check

This commit is contained in:
Looly 2021-10-10 14:03:04 +08:00
parent a81306ef5c
commit 0dd57b9e31
2 changed files with 21 additions and 21 deletions

View File

@ -6,6 +6,7 @@
# 5.7.15 (2021-10-10) # 5.7.15 (2021-10-10)
### 🐣新特性 ### 🐣新特性
* 【db 】 Db.quietSetAutoCommit增加判空issue#I4D75B@Gitee
### 🐞Bug修复 ### 🐞Bug修复
------------------------------------------------------------------------------------------------------------- -------------------------------------------------------------------------------------------------------------

View File

@ -1,10 +1,5 @@
package cn.hutool.db; package cn.hutool.db;
import java.sql.Connection;
import java.sql.SQLException;
import javax.sql.DataSource;
import cn.hutool.core.lang.func.VoidFunc1; import cn.hutool.core.lang.func.VoidFunc1;
import cn.hutool.db.dialect.Dialect; import cn.hutool.db.dialect.Dialect;
import cn.hutool.db.dialect.DialectFactory; import cn.hutool.db.dialect.DialectFactory;
@ -13,10 +8,14 @@ import cn.hutool.db.sql.Wrapper;
import cn.hutool.db.transaction.TransactionLevel; import cn.hutool.db.transaction.TransactionLevel;
import cn.hutool.log.StaticLog; import cn.hutool.log.StaticLog;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
/** /**
* 数据库操作类<br> * 数据库操作类<br>
* 通过给定的数据源执行给定SQL或者给定数据源和方言执行相应的CRUD操作<br> * 通过给定的数据源执行给定SQL或者给定数据源和方言执行相应的CRUD操作<br>
* *
* @author Looly * @author Looly
* @since 4.1.2 * @since 4.1.2
*/ */
@ -26,7 +25,7 @@ public class Db extends AbstractDb {
/** /**
* 创建Db<br> * 创建Db<br>
* 使用默认数据源自动探测数据库连接池 * 使用默认数据源自动探测数据库连接池
* *
* @return Db * @return Db
*/ */
public static Db use() { public static Db use() {
@ -36,7 +35,7 @@ public class Db extends AbstractDb {
/** /**
* 创建Db<br> * 创建Db<br>
* 使用默认数据源自动探测数据库连接池 * 使用默认数据源自动探测数据库连接池
* *
* @param group 数据源分组 * @param group 数据源分组
* @return Db * @return Db
*/ */
@ -47,7 +46,7 @@ public class Db extends AbstractDb {
/** /**
* 创建Db<br> * 创建Db<br>
* 会根据数据源连接的元信息识别目标数据库类型进而使用合适的数据源 * 会根据数据源连接的元信息识别目标数据库类型进而使用合适的数据源
* *
* @param ds 数据源 * @param ds 数据源
* @return Db * @return Db
*/ */
@ -57,7 +56,7 @@ public class Db extends AbstractDb {
/** /**
* 创建Db * 创建Db
* *
* @param ds 数据源 * @param ds 数据源
* @param dialect 方言 * @param dialect 方言
* @return Db * @return Db
@ -68,7 +67,7 @@ public class Db extends AbstractDb {
/** /**
* 创建Db * 创建Db
* *
* @param ds 数据源 * @param ds 数据源
* @param driverClassName 数据库连接驱动类名 * @param driverClassName 数据库连接驱动类名
* @return Db * @return Db
@ -80,7 +79,7 @@ public class Db extends AbstractDb {
// ---------------------------------------------------------------------------- Constructor start // ---------------------------------------------------------------------------- Constructor start
/** /**
* 构造从DataSource中识别方言 * 构造从DataSource中识别方言
* *
* @param ds 数据源 * @param ds 数据源
*/ */
public Db(DataSource ds) { public Db(DataSource ds) {
@ -89,7 +88,7 @@ public class Db extends AbstractDb {
/** /**
* 构造 * 构造
* *
* @param ds 数据源 * @param ds 数据源
* @param driverClassName 数据库连接驱动类名用于识别方言 * @param driverClassName 数据库连接驱动类名用于识别方言
*/ */
@ -99,7 +98,7 @@ public class Db extends AbstractDb {
/** /**
* 构造 * 构造
* *
* @param ds 数据源 * @param ds 数据源
* @param dialect 方言 * @param dialect 方言
*/ */
@ -118,7 +117,7 @@ public class Db extends AbstractDb {
public Db setWrapper(Wrapper wrapper) { public Db setWrapper(Wrapper wrapper) {
return (Db) super.setWrapper(wrapper); return (Db) super.setWrapper(wrapper);
} }
@Override @Override
public Db disableWrapper() { public Db disableWrapper() {
return (Db)super.disableWrapper(); return (Db)super.disableWrapper();
@ -147,7 +146,7 @@ public class Db extends AbstractDb {
/** /**
* 执行事务使用默认的事务级别<br> * 执行事务使用默认的事务级别<br>
* 在同一事务中所有对数据库操作都是原子的同时提交或者同时回滚 * 在同一事务中所有对数据库操作都是原子的同时提交或者同时回滚
* *
* @param func 事务函数所有操作应在同一函数下执行确保在同一事务中 * @param func 事务函数所有操作应在同一函数下执行确保在同一事务中
* @return this * @return this
* @throws SQLException SQL异常 * @throws SQLException SQL异常
@ -159,7 +158,7 @@ public class Db extends AbstractDb {
/** /**
* 执行事务<br> * 执行事务<br>
* 在同一事务中所有对数据库操作都是原子的同时提交或者同时回滚 * 在同一事务中所有对数据库操作都是原子的同时提交或者同时回滚
* *
* @param transactionLevel 事务级别枚举null表示使用JDBC默认事务 * @param transactionLevel 事务级别枚举null表示使用JDBC默认事务
* @param func 事务函数所有操作应在同一函数下执行确保在同一事务中 * @param func 事务函数所有操作应在同一函数下执行确保在同一事务中
* @return this * @return this
@ -208,7 +207,7 @@ public class Db extends AbstractDb {
// ---------------------------------------------------------------------------- Private method start // ---------------------------------------------------------------------------- Private method start
/** /**
* 静默回滚事务 * 静默回滚事务
* *
* @param conn Connection * @param conn Connection
*/ */
private void quietRollback(Connection conn) { private void quietRollback(Connection conn) {
@ -223,12 +222,12 @@ public class Db extends AbstractDb {
/** /**
* 静默设置自动提交 * 静默设置自动提交
* *
* @param conn Connection * @param conn Connection
* @param autoCommit 是否自动提交 * @param autoCommit 是否自动提交
*/ */
private void quietSetAutoCommit(Connection conn, Boolean autoCommit) { private void quietSetAutoCommit(Connection conn, Boolean autoCommit) {
if (null != autoCommit) { if (null != conn && null != autoCommit) {
try { try {
conn.setAutoCommit(autoCommit); conn.setAutoCommit(autoCommit);
} catch (Exception e) { } catch (Exception e) {
@ -237,4 +236,4 @@ public class Db extends AbstractDb {
} }
} }
// ---------------------------------------------------------------------------- Private method end // ---------------------------------------------------------------------------- Private method end
} }