dbsession.java

来自「基于mvc的java进销存系统」· Java 代码 · 共 148 行

/*
 * DBSession.java
 *
 * Created on 2007年4月22日, 下午8:05
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package util;

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

/**
 *
 * @author s
 */
public class DBSession {
     /** 声明static final成员变量*/
    
    /** 声明实例变量*/
    
    /** 数据连接对象*/
    private Connection conn;
    
    /** 数据库预处理执行对象 */
    private PreparedStatement prepstmt;
    
    /** 生成DBSession类的实例*/
    /** Creates a new instance of DBSession */
    public DBSession() {
        init();
    }
    private void init(){
        conn=DBConnection.getConn();
    }
    
    /** 声明/定义方法 */
      /**
     * 闭预处理执行对象，释放连接
     * 该方法不能被子类访问
     *
     * <p>
     * @param
     * @return
     * @exception
     */
     public void connClose(){
        try{
            prepstmtClose();
            conn.close();
        }catch(Exception sqle){
            sqle.printStackTrace ();
        }        
    }
    
    /**
     * 关闭预处理执行对象
     * 该方法不能被子类访问
     *
     * <p>
     * @param
     * @return
     * @exception
     */
    private void prepstmtClose(){
        try{
             if(prepstmt != null){
                 prepstmt.close ();
             }      
        }catch(SQLException sqle){
            sqle.printStackTrace ();
        }         
    }
        
    /**
     * 关闭结果集
     * 该方法不能被子类访问
     *
     * <p>
     * @param rs 结果集类型
     * @return
     * @exception
     */
    private void resultsetClose(ResultSet rs){
        try{
            if(rs != null){
                rs.close ();                
            }
        }catch(SQLException sqle){
            sqle.printStackTrace ();
        }
    } 
    
   
   /**
     * 执行数据查询的Sql语句
     *
     * <p>
     * @param sql 字符串类型：转换后的sql语句 
     * @return 结果集类型：用于为业务逻辑类的实例提供数据
     * @exception   
     */
    public ResultSet executeQuery(String sql){       
        ResultSet rs = null;
        try{
            prepstmt = conn.prepareStatement(sql);
            rs = prepstmt.executeQuery();
        }catch(SQLException sqle){
            sqle.printStackTrace();
        }         
        return rs;
    } 

    /**
     * 执行数据查询的Sql语句
     *
     * <p>
     * @param sql 字符串类型：转换后的sql语句 
     * @return PreparedStatement类型开放PreparedStatemet
     * @exception   
     */
    public PreparedStatement DPreparedStatement(String sql){
        try{
            prepstmt = conn.prepareStatement(sql);
        }catch(SQLException sqle){
            sqle.printStackTrace();
        }         
        return prepstmt;
    }
    /**
     * 关闭所有和数据相关的连接,释放资源     
     * 该方法可被子类访问 
     *
     * <p>
     * @param rs: 结果集实例
     * @return
     * @exception
     */
    public void closedALL(ResultSet rs){
        resultsetClose(rs);
        connClose ();
    }
}