dbopertaion.java

网上书店全部原代码

package bean.db.common;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class dbOpertaion {
    /**
     * 执行SQL查询语句
     */
    public ResultSet executeQuery(String sqlString){
        if(sqlString==null) return null;
        System.out.println("ddd");
        Connection conn=openDB();
        System.out.println("ss");
        ResultSet rs=null;//结果记录集
        Statement sql=null;//SQL语句对象
        try{
            sql=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
            rs=sql.executeQuery(sqlString);
            return rs;
        } catch (SQLException e) {
            e.printStackTrace();
            rs=null;
        }
        closeDB(conn);
        return rs;
    }
    public static void main(String ag[]){
    	dbOpertaion dbc=new dbOpertaion();
    	String sql="select * from book_type";
    	System.out.println(dbc.executeQuery(sql)+"sssongsheng");
    }
    /**
     * 执行SQL更新语句,返回影响的行数
     */
    public int executeUpdate(String sqlString){
        if(sqlString==null) return 0;
        Connection conn=openDB();
        Statement sql=null;//SQL语句对象
        int i=0;//影响的行数
        try{
            sql=conn.createStatement();
            i=sql.executeUpdate(sqlString);
        } catch (SQLException e) {
            e.printStackTrace();
            i=0;
        }
        closeDB(conn);
        return i;
    }
    /**
     * 打开数据库连接
     */
    public Connection openDB(){
        dbconn dbconnOBject=new dbconn();//数据库连接对象
        System.out.println("opendb");
        Connection dbconn1=dbconnOBject.getDBConn();//得到数据库连接
        System.out.println("dbcon");
        return dbconn1;
    }
    /**
     * 关闭数据库连接
     */
    public void closeDB(Connection conn){
        if(conn!=null){
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}