dbhandler.java

eclipse java/jsp 航空管理系统

package zhangchunliang.model;

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


/**
 * @author			:张春亮|[e-mail]
 * @version			:0.1
 *
 * <p>Description	:该类用于实现数据库连接和相应的数据库操作</p>	
 * <p>Project		:CIQMS</p>
 * <P>Company		:东软股份国际合作事业部</p>
 * <p>CreateDate	:2005-4-26</p>
 */


public class DBHandler {
	private Connection con=null;
	private ResultSet rs=null;
	
	
	/*
     * name:         构造方法
     * Description:  用于实现数据库连接的初始化工作
     * @return       无 
     */
	
	public DBHandler(){
		
		/*注册MySQL驱动*/
		try{
			Class.forName("org.gjt.mm.mysql.Driver").newInstance();
							
			
		}catch(Exception e){
		//handle exception	
		}
		
		/*获得连接的实例*/
		try{
			con=DriverManager.getConnection("jdbc:mysql://192.168.219.148/"+
					"ciqms?user=zhangcl&useUnicode=true&characterEncoding=gbk");
			if(con==null){
				//handle connection failure	
			}
		}catch(SQLException ex){
			//handle connection sqlexception
		}
		
	}

	
	/*
     * name:         数据库查询方法
     * Description:  对给定的目标表进行无条件相询，即查询表中所有信息。
     * @return       ResultSet类型的实例对像，返查到的结果 。
     */
	
	public ResultSet dbQuery(String targetTable)throws SQLException{
			Statement stmt=null;
			stmt=con.createStatement();
			rs=stmt.executeQuery("select * from "+targetTable);
		
			return rs;
	}

	/*
     * name:         数据库记录的添加方法
     * Description:  对给定的目标表进行添加记录。
     * @return       返回添加的行数 。
     */
	
	public int dbAdd(String targetTable,String fields,String insertValues)
	throws SQLException{
		Statement stmt=null;
		int rt=0;
		stmt=con.createStatement();
		/*构造INSERT语句，并执行该语句*/
		rt=stmt.executeUpdate("insert into "+targetTable+fields+
				" values("+insertValues+");");
		
		return rt;
	}
	
	/*
     * name:         数据库更新方法
     * Description:  对给定的目标表进行更新操作。
     * @return       返回更新操作所影响的行数 。
     */
	
	public int dbUpdate(String targetTable,String expression,String condition)
	throws SQLException{
		Statement stmt=null;
		int rt=0;
		/*实例化Statement对象*/
		stmt=con.createStatement();
		/*构造UPDATE语句，并执行更新操作*/
		rt=stmt.executeUpdate("update "+targetTable+" set "+expression+
				" where "+condition+";");

		return rt;
	}

	/*
     * name:         判断目标表的给定记录是否存在的方法
     * Description:  对给定的目标表按给定条件相询。
     * @return       返回boolean型，该记录存在返回true,否则返回false。
     */

	public boolean isExist(String targetTable,String condition)
	throws SQLException{
		ResultSet rs=null;
		Statement stmt=null;
		/*实例化Statement对象*/
		stmt=con.createStatement();
		/*根据给定的条件构造SELECT语句，并执行该查询*/
		rs=stmt.executeQuery("select * from "+targetTable+" where "+condition);
	
	
		if(!rs.next()){
			
			return false;
		}
		else{
			return true;
		}
			
	}

}