0

0

java自学之路-----jdbc_分页查询,大数据,批处理,存储过程

php中文网

php中文网

发布时间:2016-06-07 16:09:49

|

1512人浏览过

|

来源于php中文网

原创

分页查询{ 实际上就是每次查询一部分记录,并显示: select * from table_name limit StartIndex, PageSize;StartIndex:从第几个记录开始查。PageSize:每次查多少记录 分页查询在javaweb中的案例: //该对象封装了分页查询的配置信息,用于dao层public cla

分页查询{

实际上就是每次查询一部分记录,并显示:

select * from table_name limit StartIndex, PageSize;——>StartIndex:从第几个记录开始查。PageSize:每次查多少记录

分页查询在javaweb中的案例:

//该对象封装了分页查询的配置信息,用于dao层
public class QueryInfo {
	private int startindex;//查询的每页在数据库的起始位置,该值可以根据其他参数计算出,不需要set属性
	private int pagesize = 5;//查询的每页记录数,赋一个初始值
	private int querypage = 1;//查询第几页,赋一个初始值
	//提供get,set方法,便于设置,获取属性值
	public int getStartindex() {
		this.startindex = (this.querypage-1) + 1;
		return startindex;
	}
	public int getPagesize() {
		return pagesize;
	}
	public void setPagesize(int pagesize) {
		this.pagesize = pagesize;
	}
	public int getQuerypage() {
		return querypage;
	}
	public void setQuerypage(int querypage) {
		this.querypage = querypage;
	}
}
 
//该类封装了分页查询的结果信息,作为中间值,用于给QueryBean提供信息
public class QueryResult {
	private List list;//封装了查询后某页的所有记录
	private int totalrecord;//总记录数,用于给用户提供交互信息
//	提供属性的get,set方法,
	public List getList() {
		return list;
	}
	public void setList(List list) {
		this.list = list;
	}
	public int getTotalrecord() {
		return totalrecord;
	}
	public void setTotalrecord(int totalrecord) {
		this.totalrecord = totalrecord;
	}
}
 
//该类封装了分页查询的所有信息,用于与用户交互,用于jsp页面,web层
public class QueryBean {
	private List list;//封装查询的所有记录信息
	private int totalrecord;//告诉用户总共有多少记录,可以从QueryResult对象获取
	private int pagesize;//告诉用户每页有多少记录,从QueryInfo对象获取
	private int totalpage;//告诉用户一共有多少页,可以通过totalrecord和pagesize计算
	private int currentpage;//告诉用户当前查看的是第几页,从QueryInfo对象获取
	private int previouspage;//上一页是第几页,通过当前页计算出
	private int nextpage;//下一页是第几页,通过当前页计算出
	private int[] pagebar;//记录页码条,通过currentpage和pagesize计算出的一个数组
//	提供所有属性的get,set方法
	public int getTotalrecord() {
		return totalrecord;
	}
	public void setTotalrecord(int totalrecord) {
		this.totalrecord = totalrecord;
	}
	public int getPagesize() {
		return pagesize;
	}
	public void setPagesize(int pagesize) {
		this.pagesize = pagesize;
	}
	public int getTotalpage() {
//		计算总页数,21条,每页5条,有5页。20条,每页5条,有4页。
		if(this.totalrecord%this.pagesize == 0){
			this.totalpage = this.totalrecord / this.pagesize;
		}else{
			this.totalpage = this.totalrecord / this.pagesize + 1;
		}
		return totalpage;
	}
	public int getCurrentpage() {
		return currentpage;
	}
	public void setCurrentpage(int currentpage) {
		this.currentpage = currentpage;
	}
	public int getPreviouspage() {
		this.previouspage = this.currentpage - 1;
//		如果当前页小于等于0,就指向第一页
		if(this.previouspage<=0){
			this.previouspage = 1;
		}
		return previouspage;
	}
	public int getNextpage() {
		this.previouspage = this.currentpage - 1;
//		如果当前页小于等于0,就指向最后一页
		if(this.nextpage<=0){
			this.nextpage = 1;
		}
		return nextpage;
	}
	public int[] getPagebar() {
		int startindex;
		int endindex;
//		如果总页数小于10
		if(this.pagesize <= 10){
			startindex = 1;
			endindex = this.pagesize;
		}else{
			startindex = this.currentpage - 4;
			endindex = this.currentpage + 5;
//			如果startindex小于1,就从0开始,如果endindex大于总页数,就用总页数作为结束
			if(startindex < 1){
				startindex = 1;
				endindex = 10;
			}
			if(endindex > this.pagesize){
				startindex = this.pagesize - 9;
				endindex = this.pagesize;
			}
		}
//		更具两个索引值定义数组pagebar
		this.pagebar = new int[endindex-startindex+1];
//		为数组赋值
		for (int i = 0; i < pagebar.length; i++) {
			this.pagebar[i] = startindex++;
		}		
		return pagebar;
	}
}
//	在dao层提供一个分页查询的方法,将索引的初始位置和每页记录数传入
	public QueryResult pageQuery(int startIndex, int pageSize){
		Connection conn = null;
		PreparedStatement st = null;
		ResultSet rs = null;
		try {
//			获取数据库连接
			conn = JdbcUtils.getConnection();
//			提供分页查询的sql语句
			String sql = "select * from customer limit ?,?";
//			预编译sql语句,获得preparedstatement对象
			st = conn.prepareStatement(sql);
//			为占位符'?' 赋值
			st.setInt(1, startIndex);
			st.setInt(2, pageSize);
//			执行sql语句,获得结果集
			rs = st.executeQuery();
//			将结果封装到QueryResult对象中
				//在service层,将该对象封装到QueryBean中,传给jsp用于显示
			...
		} catch (Exception e) {
		}finally{
			JdbcUtils.release(conn, st, rs);
		}
	}

}

大数据{

用处:程序需要将大文本或二进制数据保存到数据库中,一般在实际开发中不直接使用数据库存储大文本大数据,因为在存取操作的时候,会占用连接大量的时间。
大数据(Large Objects):
clob:存储大文本,text文件
blob:存储二进制数据,如图像,音频、二进制文

mysql中用Text代替clob:

Text:Tinytext,text,mediumtext,longtext

立即学习Java免费学习笔记(深入)”;

blob:tinyblob,blob,mediumblob,longblob

大文本(Text){

存:

PreparedStatement的setCharacterStream( 1, reader, length)方法,填充占位符

 

ChartGen
ChartGen

AI快速生成专业数据图表

下载
//		定义sql语句
		String sql = "insert into testclob(id,resum) values(?,?)";
//		预编译sql
		PreparedStatement st = conn.prepareStatement(sql);
//		赋值占位符
		st.setString(1, "1");
//		不建议用类装载器读取文件,因为文本内容可能太大,不适合读取至内存中
		File file = new File("src/1.txt");
		Reader reader = new FileReader(file);
		st.setCharacterStream(2, reader, file.length());//reader:一个读取文本的流 length:文本的大小
//										 这是long型的,使用1.6一下的jdk必须将其转成int

读:

reader = resultSet.getCharacterStream(i);

reader = resultSet.get Clob(i).getCharacterStream();

String s = resultSet.getSting(i);

 

//		定义sql语句
		String sql = "select * from testclob where id= '1'";
//		预编译sql
		PreparedStatement st = conn.prepareStatement(sql);
//		无占位符直接执行sql
		ResultSet rs = st.executeQuery();
//		通过结果集获取大数据文件
		while(rs.next()){
			String id = rs.getString(1);
//			将数据库的文本数据放在一个流中,供用户使用
			Reader reader = rs.getCharacterStream(2);
//			读取数据
			Writer writer = new FileWriter("src/2.txt");
			...
		}

}

二进制(Blob){

 

存:

 

PreparedStatement的setBinaryStream(i, inputStream, length)方法,填充占位符

 

//		定义sql语句
		String sql = "insert into testblob(id,image) values(?,?)";
//		预编译sql
		PreparedStatement st = conn.prepareStatement(sql);
//		赋值占位符
		st.setString(1, "1");
//		不建议用类装载器读取文件,因为文本内容可能太大,不适合读取至内存中
		File file = new File("src/1.jpg");
		InputStream inputStream = new FileInputStream(file); 
		st.setBinaryStream(2, inputStream, file.length());//inputStream:一个读取文本的流 length:文本的大小
//										 这是long型的,使用1.6一下的jdk必须将其转成int

读:查看数据不能直接通过命令行程序读取

inputStream = resultSet.getBinaryStream(i);

inputStream = resultSet.getBlob(i).getBinaryStream();

 

//		定义sql语句
		String sql = "select * from testblob where id= '1'";
//		预编译sql
		PreparedStatement st = conn.prepareStatement(sql);
//		无占位符直接执行sql
		ResultSet rs = st.executeQuery();
//		通过结果集获取大数据文件
		while(rs.next()){
			String id = rs.getString(1);
//			将数据库的文本数据放在一个流中,供用户使用
			InputStream in = rs.getBinaryStream(2);
//			存储数据
			OutputStream out = new FileOutputStream("c:\\2.jpg");
			...

}

}

批处理{

用处:当需要向数据库发送一批SQL语句执行时,应避免向数据库中一条条的发送执行,应该采用批处理机制,提升效率

第一种实现方式{

存储sql语句:Statement.addBatch(sql);

执行批处理语句:executeBatch()-->执行批处理命令 clearBatch();-->清除批处理命令

 

//		定义sql语句
		String sql1 = "insert into testBatch(id,name) values('1', 'aaa')";
		String sql2 = "update testBatch set name = 'bbb' where id = '1'";
//		获取Statement对象
		Statement st = conn.createStatement();
//		将sql语句存到对象中,实际是将sql语句存放在内部的list对象中
		st.addBatch(sql1);
		st.addBatch(sql2);
//		执行sql
		int result[] = st.executeBatch();//该数组一次存放着每一条sql语句影响数据库数据的行数
//		清除
		st.clearBatch();
1.可以发送不同的sql语句

2.性能不够

}

第二种实现方式{

//		定义sql语句
		String sql = "insert into testBatch(id,name) values(?,?)";
//		获取PreparedStatement对象
		PreparedStatement st = conn.prepareStatement(sql);
////		替换占位符,第一个sql,存到list中
//		st.setString(1, "1");
//		st.setString(2, "aaa");
//		st.addBatch();
////		替换占位符,第二个sql,存到list中
//		st.setString(1, "2");
//		st.setString(2, "bbb");
//		st.addBatch();
		//例:
		for(int i=0; i<10; i++){
			st.setString(1, ""+i);
			st.setString(2, "aa"+i);
			st.addBatch();
		}
//		执行
		st.executeBatch();
//		清除
		st.clearBatch();
1.只能发送相同sql语句,比较适合作为批量插入或批量更新

2.预先编译,提升性能

}

 

		//如果批处理的语句过多,可能造成内存溢出:使用下列处理方法
		for(int i=0; i<100000; i++){
			st.setString(1, ""+i);
			st.setString(2, "aa"+i);
			st.addBatch();
//			每次处理1000条sql语句
			if(i%1000==0){
				st.executeBatch();
				st.clearBatch();
			}
		}
//		以防sql语句未执行
		st.executeBatch();
//		清除
		st.clearBatch();

}

存储过程{

该对象作用:

1.相当于数据库的一个方法,在数据库中处理数据,然后再java程序中直接获取数据

2.没有该对象就需要使用jdbc调用来处理数据

3.一般都用在金融证券领域,都内部写了存储过程,程序员直接调用。

4.存储过程中一般在参数中指定了输入数据,和输出数据

用法:

1.先在数据库中注册一个存储过程

\

2.在java程序中使用

 

//		获取连接,通过数据库的方法,先得到一个数据,处理后再输出
		Connection conn = JdbcUtils.getConnection();
//		用存储过程名来获取存储过程的对象
		CallableStatement st = conn.prepareCall("{call demoSp(?,?)}");//通过demoSp这个名字调用存储过程
//		替换占位符
			//输入的数据
		st.setString(1, "aaa");
			//输出的数据,提供输出的类型
		st.registerOutParameter(2, Types.VARCHAR);//Types封装了数据库中常用类型
		st.execute();
//		通过第二个?获得数据,并且它已经指定了数据类型
		st.getString(2);

问题:1.只知道存储过程在java程序中的输入,输出关系。不知道会对数据库造成怎样的影响 2.不知道怎么编写存储过程

}

相关文章

java速学教程(入门到精通)
java速学教程(入门到精通)

java怎么学习?java怎么入门?java在哪学?java怎么学才快?不用担心,这里为大家提供了java速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
Golang gRPC 服务开发与Protobuf实战
Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践,涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC(Unary/Server/Client/Bidirectional)、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例,帮助学习者掌握 使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系,适用于微服务与内部系统通信场景。

8

2026.01.15

公务员递补名单公布时间 公务员递补要求
公务员递补名单公布时间 公务员递补要求

公务员递补名单公布时间不固定,通常在面试前,由招录单位(如国家知识产权局、海关等)发布,依据是原入围考生放弃资格,会按笔试成绩从高到低递补,递补考生需按公告要求限时确认并提交材料,及时参加面试/体检等后续环节。要求核心是按招录单位公告及时响应、提交材料(确认书、资格复审材料)并准时参加面试。

44

2026.01.15

公务员调剂条件 2026调剂公告时间
公务员调剂条件 2026调剂公告时间

(一)符合拟调剂职位所要求的资格条件。 (二)公共科目笔试成绩同时达到拟调剂职位和原报考职位的合格分数线,且考试类别相同。 拟调剂职位设置了专业科目笔试条件的,专业科目笔试成绩还须同时达到合格分数线,且考试类别相同。 (三)未进入原报考职位面试人员名单。

58

2026.01.15

国考成绩查询入口 国考分数公布时间2026
国考成绩查询入口 国考分数公布时间2026

笔试成绩查询入口已开通,考生可登录国家公务员局中央机关及其直属机构2026年度考试录用公务员专题网站http://bm.scs.gov.cn/pp/gkweb/core/web/ui/business/examResult/written_result.html,查询笔试成绩和合格分数线,点击“笔试成绩查询”按钮,凭借身份证及准考证进行查询。

11

2026.01.15

Java 桌面应用开发(JavaFX 实战)
Java 桌面应用开发(JavaFX 实战)

本专题系统讲解 Java 在桌面应用开发领域的实战应用,重点围绕 JavaFX 框架,涵盖界面布局、控件使用、事件处理、FXML、样式美化(CSS)、多线程与UI响应优化,以及桌面应用的打包与发布。通过完整示例项目,帮助学习者掌握 使用 Java 构建现代化、跨平台桌面应用程序的核心能力。

65

2026.01.14

php与html混编教程大全
php与html混编教程大全

本专题整合了php和html混编相关教程,阅读专题下面的文章了解更多详细内容。

36

2026.01.13

PHP 高性能
PHP 高性能

本专题整合了PHP高性能相关教程大全,阅读专题下面的文章了解更多详细内容。

75

2026.01.13

MySQL数据库报错常见问题及解决方法大全
MySQL数据库报错常见问题及解决方法大全

本专题整合了MySQL数据库报错常见问题及解决方法,阅读专题下面的文章了解更多详细内容。

21

2026.01.13

PHP 文件上传
PHP 文件上传

本专题整合了PHP实现文件上传相关教程,阅读专题下面的文章了解更多详细内容。

35

2026.01.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 2.5万人学习

C# 教程
C# 教程

共94课时 | 6.8万人学习

Java 教程
Java 教程

共578课时 | 46.3万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号