1
mirror of https://github.com/CarmJos/EasySQL.git synced 2026-06-04 23:41:15 +08:00

[v0.2.7] [U] 修改了SQLQuery的包位置。

This commit is contained in:
2022-01-12 11:06:28 +08:00
parent 4963719956
commit 8878379f66
10 changed files with 32 additions and 30 deletions
@@ -4,7 +4,6 @@ import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction; import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
import cc.carm.lib.easysql.api.action.SQLUpdateAction; import cc.carm.lib.easysql.api.action.SQLUpdateAction;
import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction; import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
import cc.carm.lib.easysql.api.action.query.SQLQuery;
import cc.carm.lib.easysql.api.builder.*; import cc.carm.lib.easysql.api.builder.*;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
@@ -1,6 +1,8 @@
package cc.carm.lib.easysql.api.action.query; package cc.carm.lib.easysql.api;
import cc.carm.lib.easysql.api.SQLManager; import cc.carm.lib.easysql.api.SQLManager;
import cc.carm.lib.easysql.api.action.query.PreparedQueryAction;
import cc.carm.lib.easysql.api.action.query.QueryAction;
import java.sql.Connection; import java.sql.Connection;
import java.sql.ResultSet; import java.sql.ResultSet;
@@ -19,7 +19,7 @@ public interface SQLUpdateBatchAction extends SQLAction<List<Integer>> {
List<String> getSQLContents(); List<String> getSQLContents();
@Override @Override
default SQLExceptionHandler<List<Integer>> defaultExceptionHandler() { default SQLExceptionHandler defaultExceptionHandler() {
return (exception, action) -> { return (exception, action) -> {
getManager().getLogger().severe("Error when execute SQLs : "); getManager().getLogger().severe("Error when execute SQLs : ");
int i = 1; int i = 1;
@@ -1,23 +1,24 @@
package cc.carm.lib.easysql.api.action.query; package cc.carm.lib.easysql.api.action.query;
import cc.carm.lib.easysql.api.SQLAction; import cc.carm.lib.easysql.api.SQLAction;
import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
import cc.carm.lib.easysql.api.function.SQLFunction; import cc.carm.lib.easysql.api.function.SQLFunction;
import cc.carm.lib.easysql.api.function.SQLHandler;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
/** /**
* SQLQueryAction 是用于承载SQL查询语句并进行处理、返回并自动关闭连接的基本类。 * SQLQueryAction 是用于承载SQL查询语句并进行处理、返回并自动关闭连接的基本类。
* *
* <ul> * <ul>
* <li>同步执行 {@link #execute()}, {@link #execute(SQLFunction, BiConsumer)} * <li>同步执行 {@link #execute()}, {@link #execute(SQLFunction, SQLExceptionHandler)}
* <br>同步执行方法中有会抛出异常的方法与不抛出异常的方法, * <br>同步执行方法中有会抛出异常的方法与不抛出异常的方法,
* <br>若选择不抛出异常,则返回值可能为空,需要特殊处理。</li> * <br>若选择不抛出异常,则返回值可能为空,需要特殊处理。</li>
* *
* <li>异步执行 {@link #executeAsync(Consumer, BiConsumer)} * <li>异步执行 {@link #executeAsync(SQLHandler, SQLExceptionHandler)}
* <br>异步执行时将提供成功与异常两种处理方式 * <br>异步执行时将提供成功与异常两种处理方式
* <br>可自行选择是否对数据或异常进行处理 * <br>可自行选择是否对数据或异常进行处理
* <br>默认的异常处理器为 {@link #defaultExceptionHandler()}</li> * <br>默认的异常处理器为 {@link #defaultExceptionHandler()}</li>
@@ -30,22 +31,22 @@ import java.util.function.Consumer;
*/ */
public interface QueryAction extends SQLAction<SQLQuery> { public interface QueryAction extends SQLAction<SQLQuery> {
/** /**
* 执行语句并处理返回值 * 执行语句并处理返回值
* *
* @param function 处理方法 * @param function 处理方法
* @param <R> 需要返回的内容 * @param <R> 需要返回的内容
* @return 指定类型数据 * @return 指定类型数据
* @throws SQLException 当SQL操作出现问题时抛出 * @throws SQLException 当SQL操作出现问题时抛出
*/ */
@Nullable @Nullable
default <R> R executeFunction(@NotNull SQLFunction<SQLQuery, R> function) default <R> R executeFunction(@NotNull SQLFunction<SQLQuery, R> function)
throws SQLException { throws SQLException {
try (SQLQuery value = execute()) { try (SQLQuery value = execute()) {
return function.apply(value); return function.apply(value);
} catch (SQLException exception) { } catch (SQLException exception) {
throw new SQLException(exception); throw new SQLException(exception);
} }
} }
} }
@@ -1,7 +1,7 @@
package cc.carm.lib.easysql; package cc.carm.lib.easysql;
import cc.carm.lib.easysql.api.SQLManager; import cc.carm.lib.easysql.api.SQLManager;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.util.TimeDateUtils; import cc.carm.lib.easysql.api.util.TimeDateUtils;
import cc.carm.lib.easysql.manager.SQLManagerImpl; import cc.carm.lib.easysql.manager.SQLManagerImpl;
import cn.beecp.BeeDataSource; import cn.beecp.BeeDataSource;
+1 -1
View File
@@ -1,5 +1,5 @@
import cc.carm.lib.easysql.api.SQLManager; import cc.carm.lib.easysql.api.SQLManager;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.util.TimeDateUtils; import cc.carm.lib.easysql.api.util.TimeDateUtils;
import cc.carm.lib.easysql.api.util.UUIDUtil; import cc.carm.lib.easysql.api.util.UUIDUtil;
@@ -1,7 +1,7 @@
package cc.carm.lib.easysql; package cc.carm.lib.easysql;
import cc.carm.lib.easysql.api.SQLManager; import cc.carm.lib.easysql.api.SQLManager;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.util.TimeDateUtils; import cc.carm.lib.easysql.api.util.TimeDateUtils;
import cc.carm.lib.easysql.manager.SQLManagerImpl; import cc.carm.lib.easysql.manager.SQLManagerImpl;
import com.zaxxer.hikari.HikariConfig; import com.zaxxer.hikari.HikariConfig;
@@ -2,7 +2,7 @@ package cc.carm.lib.easysql.action.query;
import cc.carm.lib.easysql.action.AbstractSQLAction; import cc.carm.lib.easysql.action.AbstractSQLAction;
import cc.carm.lib.easysql.api.action.query.QueryAction; import cc.carm.lib.easysql.api.action.query.QueryAction;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.function.SQLExceptionHandler; import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
import cc.carm.lib.easysql.api.function.SQLHandler; import cc.carm.lib.easysql.api.function.SQLHandler;
import cc.carm.lib.easysql.manager.SQLManagerImpl; import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -8,7 +8,7 @@ import cc.carm.lib.easysql.api.SQLManager;
import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction; import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction; import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction; import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.api.builder.*; import cc.carm.lib.easysql.api.builder.*;
import cc.carm.lib.easysql.builder.impl.*; import cc.carm.lib.easysql.builder.impl.*;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
@@ -1,7 +1,7 @@
package cc.carm.lib.easysql.query; package cc.carm.lib.easysql.query;
import cc.carm.lib.easysql.action.query.QueryActionImpl; import cc.carm.lib.easysql.action.query.QueryActionImpl;
import cc.carm.lib.easysql.api.action.query.SQLQuery; import cc.carm.lib.easysql.api.SQLQuery;
import cc.carm.lib.easysql.manager.SQLManagerImpl; import cc.carm.lib.easysql.manager.SQLManagerImpl;
import java.sql.Connection; import java.sql.Connection;