爱玩科技网

全部频道

您的当前位置：首页java自学之路-----jdbc_分页查询，大数据，批处理，存储过程

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

来源：爱玩科技网


分页查询在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

blob：tinyblob，blob，mediumblob，longblob

大文本(Text){

存：

PreparedStatement的setCharacterStream（ 1， reader， length）方法，填充占位符

//	定义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.不知道怎么编写存储过程

}
显示全文