sqlhelper.java

来自「1 系统简介 1.1 系统名称：bugtrail 1.2 适用范围：大型或小」· Java 代码 · 共 75 行

/*
 * 创建日期 2006-12-19
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
package bugtrail.util;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import bugtrail.database.MysqlDBConn;

public class SqlHelper{
	private Connection conn;
	private Statement stmt;
	private ResultSet rs;

	public SqlHelper()  throws Exception{
		conn = MysqlDBConn.getConnection();
	}
	//帮助方法,执行数据库更新
	public  void updateHelper(String sql) throws Exception{
		stmt = conn.createStatement();
		stmt.executeUpdate(sql);
//		stmt.close();
//		conn.close();
	}


	//帮助方法,执行数据库操作
	public ResultSet executeHelper(String sql) throws Exception{
		stmt = conn.createStatement();
		rs = stmt.executeQuery(sql);
		return rs;
	}

	/**
	 * 帮助方法,执行数据库操作,实现分页查询:
	 * pageNum 页码
	 * rows 每页行数
	 */
	public  ResultSet executeHelper(String sql,int pageNum,int rows) throws Exception{
		int absoluteLocation; //游标位置

		stmt = conn.createStatement();
		stmt.setMaxRows(pageNum*rows);
		rs=stmt.executeQuery(sql);	

		absoluteLocation=rows*(pageNum-1); 

//		这个for循环的作用是让结果集rs定位到本页之前的最后一个结果处 
		for(int i=0;i<absoluteLocation;i++) 
		{ 
			rs.next(); 
		} 

		return rs;
	}

	//帮助方法,关闭连接
	public void closeAll(){
		try {
			if(rs!=null)
				rs.close();
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}