dbaccess.java

java开发者突击源代码demo(struts).rar

package com.demo.javabean;

import java.sql.*;

public class DBAccess {
	private String drv="org.gjt.mm.mysql.Driver";
	private String url="jdbc:mysql://localhost:3306/demo";
	private String usr="root";
	private String pwd="";
	private Connection conn=null;
	private Statement stm=null;
	private ResultSet rs=null;
	
	public Connection getConn() {
		return conn;
	}
	public void setConn(Connection conn) {
		this.conn = conn;
	}
	public String getDrv() {
		return drv;
	}
	public void setDrv(String drv) {
		this.drv = drv;
	}
	public String getPwd() {
		return pwd;
	}
	public void setPwd(String pwd) {
		this.pwd = pwd;
	}
	public ResultSet getRs() {
		return rs;
	}
	public void setRs(ResultSet rs) {
		this.rs = rs;
	}
	public Statement getStm() {
		return stm;
	}
	public void setStm(Statement stm) {
		this.stm = stm;
	}
	public String getUrl() {
		return url;
	}
	public void setUrl(String url) {
		this.url = url;
	}
	public String getUsr() {
		return usr;
	}
	public void setUsr(String usr) {
		this.usr = usr;
	}
	
	public boolean createConn(){
		boolean b=false;
		try{
			Class.forName(drv).newInstance();
			conn=DriverManager.getConnection(url,usr,pwd);
			b=true;
		}catch(SQLException e){
			
		}catch(ClassNotFoundException e){
			
		}catch(InstantiationException e){
			
		}catch(IllegalAccessException e){
			
		}
		return b;
	}
	
	public boolean update(String sql){
		boolean b=false;
		try{
			stm=conn.createStatement();
			stm.execute(sql);
			b=true;
		}catch(Exception e){
			
		}
		return b;
	}
	
	public void query(String sql){
		try{
			stm=conn.createStatement();
			rs=stm.executeQuery(sql);
		}catch(Exception e){
			
		}
	}
	
	public boolean next(){
		boolean b=false;
		try{
			if(rs.next()) b=true;
		}catch(Exception e){
			
		}
		return b;
	}
	
	public String getValue(String field){
		String value=null;
		try{
			if(rs!=null) value=rs.getString(field);
		}catch(Exception e){
			
		}
		return value;
	}
	
	public void closeRs(){
		try{
			if(rs!=null) rs.close();
		}catch(SQLException e){
			
		}
	}
	
	public void closeStm(){
		try{
			if(stm!=null) stm.close();
		}catch(SQLException e){
			
		}
	}
	
	public void closeConn(){
		try{
			if(conn!=null) conn.close();
		}catch(SQLException e){
			
		}
	}

}