dbclass.java

连接mysql数据库的javabean

package bean;
import java.io.*;
import java.util.*;
import java.sql.*;
public class DBclass
{
  private String driver;
  private String url;
  private String username;
  private String password;
  private Connection connection;
  private Statement statement;
  private String message="";
  public DBclass(){
  driver="sun.jdbc.odbc.JdbcOdbcDriver";
  url="jdbc:odbc:bookshop";
  username="";
  password="";
  connection=null;
  statement=null;
  message="";
  }
  public DBclass(String driver,String url,String username,String password)
  {
   this.driver=driver;
   this.url=url;
   this.username=username;
   this.password=password;
   this.message=message;
   }
   public String getDriver(){
   return driver;
   }
   public void setDriver(String driver){
   this.driver=driver;
   }
   public String getUrl(){
   return url;
   }
   public void setUrl(String url){
   this.url=url;
   }
   public String getUsername(){
   return username;
   }
   public void setUsername(String username){
   this.username=username;
   }
   public String getPassword(){
   return password;
   }
   public void setPasssword(String password){
   this.password=password;
   }
   public Connection getConnection(){
   return connection;
   }
   public void setConnection(Connection connection){
   this.connection=connection;
   }
   public Statement getStatment(){
   return statement;
   }
   public void setStatement(Statement statement){
   this.statement=statement;
   }
   public String getMessage(){
   return message;
   }
   public void setMessage(String message){
   this.message=message;
   }
   /**连接数据库*/
   public void connect(){
   try{
        Class.forName(driver);
		connection=DriverManager.getConnection(url,username,password);
		statement=connection.createStatement();
	  }catch (ClassNotFoundException cnfe){
	  message="connection:"+cnfe;
	  }catch (SQLException sqle){
	  message="executequery:"+sqle;
	  }
	}
	public ResultSet executeQuery(String query){
	ResultSet resultset=null;
	try{
	    resultset=statement.executeQuery(query);
		}catch (SQLException sqle){
		 message="executeQuery:"+sqle;
		}
		return resultset;
	}
    public void executeUpdate(String command){
     try{
          statement.executeUpdate(command);
        }catch (SQLException sqle){
          message="executUpdate:"+sqle;
        }
    }
    public void closeConnection(){
    try{
        connection.close();
       }catch(SQLException sqle){
        message="closeConnection:"+sqle;
        }
     }
}