zhouxy108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-08-18 20:38:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

add page of sql support

Browse Source
This commit is contained in:
Looly
2020-12-06 07:41:54 +08:00
parent 897dea0b30
commit 36588f7e07
23 changed files with 711 additions and 451 deletions
Download Patch File Download Diff File Expand all files Collapse all files

79
hutool-db/src/main/java/cn/hutool/db/dialect/Dialect.java
View File

@@ -1,23 +1,26 @@
package cn.hutool.db.dialect;
import cn.hutool.core.collection.ListUtil;
import cn.hutool.db.Entity;
import cn.hutool.db.Page;
import cn.hutool.db.sql.Order;
import cn.hutool.db.sql.Query;
import cn.hutool.db.sql.SqlBuilder;
import cn.hutool.db.sql.Wrapper;
import java.io.Serializable;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import cn.hutool.db.Entity;
import cn.hutool.db.sql.Query;
import cn.hutool.db.sql.Wrapper;
/**
* SQL方言，不同的数据库由于在某些SQL上有所区别，故为每种数据库配置不同的方言。<br>
* 由于不同数据库间SQL语句的差异，导致无法统一拼接SQL，<br>
* Dialect接口旨在根据不同的数据库，使用不同的方言实现类，来拼接对应的SQL，并将SQL和参数放入PreparedStatement中
*
* @author loolly
*
* @author loolly
*/
public interface Dialect extends Serializable{
public interface Dialect extends Serializable {
/**
* @return 包装器
@@ -26,36 +29,37 @@ public interface Dialect extends Serializable{
/**
* 设置包装器
*
*
* @param wrapper 包装器
*/
void setWrapper(Wrapper wrapper);
// -------------------------------------------- Execute
/**
* 构建用于插入的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param entity 数据实体类（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
*/
PreparedStatement psForInsert(Connection conn, Entity entity) throws SQLException;
/**
* 构建用于批量插入的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param entities 数据实体，实体的结构必须全部一致，否则插入结果将不可预知
* @return PreparedStatement
* @throws SQLException SQL执行异常
*/
PreparedStatement psForInsertBatch(Connection conn, Entity... entities) throws SQLException;
/**
* 构建用于删除的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param query 查找条件（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
@@ -64,20 +68,21 @@ public interface Dialect extends Serializable{
/**
* 构建用于更新的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param entity 数据实体类（包含表名）
* @param query 查找条件（包含表名）
* @param query 查找条件（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
*/
PreparedStatement psForUpdate(Connection conn, Entity entity, Query query) throws SQLException;
// -------------------------------------------- Query
/**
* 构建用于获取多条记录的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param query 查询条件（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
@@ -86,28 +91,46 @@ public interface Dialect extends Serializable{
/**
* 构建用于分页查询的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param query 查询条件（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
*/
PreparedStatement psForPage(Connection conn, Query query) throws SQLException;
/**
* 构建用于分页查询的PreparedStatement<br>
* 可以在此方法中使用{@link SqlBuilder#orderBy(Order...)}方法加入排序信息，
* 排序信息通过{@link Page#getOrders()}获取
*
* @param conn 数据库连接对象
* @param sqlBuilder SQL构建器，可以使用{@link SqlBuilder#of(CharSequence)} 包装普通SQL
* @param page 分页对象
* @return PreparedStatement
* @throws SQLException SQL执行异常
* @since 5.5.3
*/
PreparedStatement psForPage(Connection conn, SqlBuilder sqlBuilder, Page page) throws SQLException;
/**
* 构建用于查询行数的PreparedStatement
*
* @param conn 数据库连接对象
*
* @param conn 数据库连接对象
* @param query 查询条件（包含表名）
* @return PreparedStatement
* @throws SQLException SQL执行异常
*/
PreparedStatement psForCount(Connection conn, Query query) throws SQLException;
default PreparedStatement psForCount(Connection conn, Query query) throws SQLException{
query.setFields(ListUtil.toList("count(1)"));
return psForFind(conn, query);
}
/**
* 方言名
*
*
* @return 方言名
* @since 5.5.3
*/
DialectName dialectName();
String dialectName();
}