java开发之Jdbc分页源码详解
作者:mianhuaman 发布时间:2021-10-28 16:06:48
标签:java,Jdbc,分页
总之是用jdbc 的游标移动
package com.sp.person.sql.util;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;
import java.util.TreeMap;
import javax.sql.DataSource;
/**
* 常常有同事在问JDBC 分页查询 这里给二个例子介绍一下
* JDBC 分页查询
* 分成二种方式希望对大家有所帮助
* 分另表示了absolute 与relative 的区别
* @see 这时用到一个数据源设计模式
* 数据源与数据库连接没有关系
* 例用接口回调的特性
* @author liuqing
* @version 1.0
*
*/
public class JdbcUtil {
/**
* 数据源
*/
private DataSource dataSource;
/**
* 不否启用多数据源
*/
private boolean isMultipleDataSource;
/**
* 有时一个系统可能要使用多个数据源,存放多个数据源
*/
private Map<String,DataSource> dataSources = new TreeMap<String,DataSource>();
/**
* if true isMultipleDataSource is Key to DataSource
*/
private String dataSourceKey;
/**
* 默认构造器
*/
public JdbcUtil() {
}
/**
* 构造器 Spring 的构造器注入
* @param dataSource
*/
public JdbcUtil(DataSource dataSource) {
this.dataSource = dataSource;
}
/**
* JDBC 分页查询
* @param sql SQL 查询语句
* @param firstSize 起始页
* @param maxSize 返回数据条数
* @return ResultSet
* @throws SQLException
*/
public ResultSet queryPageAbsolute(String sql,
int firstSize,int maxSize) throws SQLException {
PreparedStatement pre = this.getConn().prepareStatement(sql);
pre.setMaxRows(maxSize);
ResultSet rs = pre.executeQuery();
rs.absolute(firstSize * maxSize);
return rs;
}
/**
* JDBC 分页查询
* @param sql SQL 查询语句
* @param firstSize 起始页
* @param maxSize 返回数据条数
* @return ResultSet 返回结果集
* @throws SQLException
*/
public ResultSet queryPageRelative(String sql,
int firstSize,int maxSize) throws SQLException {
PreparedStatement pre = getConn().prepareStatement(sql);
pre.setMaxRows(maxSize);
ResultSet rs = pre.executeQuery();
rs.relative(firstSize);
return rs;
}
/**
*
* @return Connection
* @throws SQLException
*/
private Connection getConn() throws SQLException {
//使用多数据源的情况
if (this.isMultipleDataSource) {
DataSource v_dataSource = this.queryDataSourceByKey();
if (v_dataSource != null) {
return v_dataSource.getConnection();
}
}
return this.dataSource.getConnection();
}
/**
* 获得多数据源方法
* @return DataSource
*/
public DataSource queryDataSourceByKey() {
for (Map.Entry<String, DataSource> ds:this.dataSources.entrySet()) {
if (ds.getKey().equals(dataSourceKey)) {
return ds.getValue();
}
}
return null;
}
/**
* 获得多数据源方法
* @return DataSource
*/
public DataSource queryDataSourceByKey(String useKey) {
for (Map.Entry<String, DataSource> ds:this.dataSources.entrySet()) {
if (ds.getKey().equals(useKey)) {
return ds.getValue();
}
}
return null;
}
/**
* 数据源
*/
public DataSource getDataSource() {
return dataSource;
}
/**
* 数据源 setter 注入
*/
public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
}
/**
* @return the isMultipleDataSource
*/
public boolean isMultipleDataSource() {
return isMultipleDataSource;
}
/**
* @param isMultipleDataSource the isMultipleDataSource to set
*/
public void setMultipleDataSource(boolean isMultipleDataSource) {
this.isMultipleDataSource = isMultipleDataSource;
}
/**
* @return the dataSources
*/
public Map<String, DataSource> getDataSources() {
return dataSources;
}
/**
* @param dataSources the dataSources to set
*/
public void setDataSources(Map<String, DataSource> dataSources) {
this.dataSources = dataSources;
}
/**
* 返回当前使用的数据源
* @return the dataSourceKey
*/
public String getDataSourceKey() {
return dataSourceKey;
}
/**
* 要使用的数据源为
* @param dataSourceKey the dataSourceKey to set
*/
public void setDataSourceKey(String dataSourceKey) {
this.dataSourceKey = dataSourceKey;
}
}
来源:https://www.iteye.com/blog/mianhuaman-1137995
0
投稿
猜你喜欢
- 一、需求分析:1、输入一个数组-----------------------------------------》程序要接收一组输入的数组,
- 1.spring-kafka<dependency> <groupId>org.springframe
- springboot整合tkmapper1.导入pom依赖1.1 导入springboot的parent依赖<parent> &
- 循环依赖定义循环依赖就 循环引用,就是两个或多个 bean 相互之间的持有对方,比如 CircleA 引用 CircleB , Circle
- Java 用反射设置对象的属性值实例详解/** * 用反射设置对象的属性值 * @param obj 需要設置值的對象 * @param f
- 一、本地仓库初始化与远程仓库推送操作Idea 基本环境配置Github 配置Git 执行文件目录指定创建工程git02创建本地仓库并提交项目
- 1.最常用的方法是创建一个计数器,判断是否遇到‘\0',不是'\0'指针就往后加一。int my_strlen(co
- 配置两个parent的方法在向pom.xml 文件中添加依赖之前需要先添加spring-boot-starter-parent。spring
- 下截JNative组件jnative.sourceforge.net/ 到这里下载JNative开源项目,我下载的是1.3.2解压JNati
- 1、引言在SpringMVC的使用中,后端与前端的交互一般是使用Json格式进行数据传输,SpringMVC的@Response
- 前言在这一期的文章中,我将继续介绍 Either,使用它构建树形结构,该结构允许我模拟 Scala 的模式匹配来构建遍历方法。在 Java
- 前言Java虽然五脏俱全但总有软肋,譬如获取CPU等硬件信息,当然我们可以通过JNI调用C/C++来获取,但对于对C/C++和Windows
- 默认情况下,如果应用以 Android Q 为目标平台,则在访问外部存储设备中的文件时会进入过滤视图。应用可以使用 Context.getE
- 本文实例讲述了Spring使用ClassPathResource加载xml资源。分享给大家供大家参考,具体如下:一 代码package le
- 这一篇写一下springboot整合solr,代码已经上传到github,传送门。1、新建core并配置schemasolr create
- 1. 公共字段自动填充1.1 问题分析在新增员工时需要设置创建时间、创建人、修改时间、修改人等字段,在编辑员工时需要设置修改时间、修改人等字
- 摘要:Java8通过Function获取字段名,解决硬编码,效果类似于mybatis-plus的LambdaQueryWrapper。本文总
- jdk8之前 一、java.lang.Systemlong times = System.currentTimeMillis();
- 前言最近新整了个博客网站,同事在gitee上找的,还不错,gitee上的地址在这里:拾壹博客管理系统。别人的业务,再好也有不满足自己的地方,
- static :静态常量,静态方法,静态代码块静态变量: 静态变量属于类的,使用类名来访问,非静态变量是属于对象的,"必须&quo