dbconn.java

一个Struts的简易留言本

package net.javafan.guestbook.dboperator;
import java.sql.*;

public class DBConn{
    String sDBDriver="org.gjt.mm.mysql.Driver";
    String sConnStr="jdbc:mysql://127.0.0.1:3306/gb?user=root&password=123456&useUnicode=true&characterEncoding=ISO-8859-1";
    Connection conn=null;
    ResultSet rs=null;
    
	public DBConn(){
		try{
            Class.forName(sDBDriver);
        }
        catch(java.lang.ClassNotFoundException e){
            System.out.println("Jdbc_conn():"+e.getMessage());
        }
    }
	
	public void executeUpdate(String sql)throws Exception{
		//sql=new String(sql.getBytes("GBK"),"ISO8859_1");
		try{
			conn=DriverManager.getConnection(sConnStr);
            Statement stmt=conn.createStatement();
            stmt.executeUpdate(sql);
			conn.close();
			stmt.close();
        }
        catch(SQLException ex){
            System.out.println("sql.executeUpdate:"+ex.getMessage());
        }
    }
	public ResultSet executeQuery(String sql)throws Exception{
        rs=null;
		try{
			sql=new String(sql.getBytes("GBK"),"ISO8859_1");
            conn=DriverManager.getConnection(sConnStr);
            Statement stmt=conn.createStatement();
            rs=stmt.executeQuery(sql);
        }
        catch(SQLException ex){
            System.out.println("sql.executeQuery:"+ex.getMessage());
        }
		return rs;
    }

        public void CloseConn() 
          throws Exception {
          try
          {
            if (rs!=null)
              rs.close();
            if (conn!=null)
              conn.close();
          }
            catch(SQLException ex)
          {
            System.out.println ("closeConn: " + ex);
          }
       }
}