opendb.java

一个简单实用的网上书城,可当作原型使用

package czm;


import com.sun.org.apache.bcel.internal.classfile.JavaClass;
import java.sql.*;
import org.apache.tools.ant.taskdefs.Java;
import java.io.*;
public class opendb 
{
    
      //定义连接字符串
        public static String sDBDriver="sun.jdbc.odbc.JdbcOdbcDriver";      //panfock 20,14:00
        public static String sConnStr="jdbc:odbc:bookstore";
        private Connection conn =null;
        private ResultSet rs =null;
    public opendb() 
    {  
        try{
           Class.forName(sDBDriver);
        }catch(java.lang.ClassNotFoundException e){
            System.err.println("opendb():"+e.getMessage());
        }
    }
    
    public boolean executeUpdates(String[] commands) {   //事务性修改数据库  //panfock 20,14:00
        try {
            conn=DriverManager.getConnection(sConnStr);
            conn.setAutoCommit(false);// 更改JDBC事务的默认提交方式
            Statement stmt = conn.createStatement();
            for(int i=0;i<commands.length;i++)
            {
                stmt.executeUpdate(commands[i]);
            }
            conn.commit();//提交JDBC事务
            conn.setAutoCommit(true);// 恢复JDBC事务的默认提交方式
            conn.close();
            return true;
        }
        catch (Exception exc) {
            try{
                conn.rollback();//回滚JDBC事务
                conn.close();
            }
            catch(Exception eb)
            {
               exc.printStackTrace();
            }
            finally
            {
                return false;
            }
        }
    }
    
    public boolean executeUpdate(String command) {   //修改数据库  //panfock 20,14:00
        try {
            conn=DriverManager.getConnection(sConnStr);
            Statement stmt = conn.createStatement();
            stmt.executeUpdate(command);
            return true;
        }
        catch (Exception exc) {  
                return false;
        }
    }
    
    
    public ResultSet executeQuery(String sql)
    {
        rs=null;
        try
        {
           conn=DriverManager.getConnection(sConnStr);
           Statement stmt = conn.createStatement();
           rs=stmt.executeQuery(sql);
           //rs.next();
        }
        catch(SQLException ex)
        {
            System.err.println("aq.executeQuery:"+ex.getMessage());        
            return null;
        }
        return rs;
    }
    public void setSDBDriver(String newSDBDriver){
        sDBDriver=newSDBDriver;
    }
    public String getSDBDriver(){
        return sDBDriver;
    }
    public void setSConnStr(String newSConnStr){
        sConnStr=newSConnStr;
    }
    public String getSConnStr(){
        return sConnStr;
    }
    public void setConn(Connection newConn){
        conn=newConn;
    }
    public Connection getConn(){
        return conn;
    }
    public void setRs(ResultSet newRs){
        rs=newRs;
    }
    public ResultSet getRs(){
        return rs;
    }
}