connectdatebase.java

网上购书系统

package datamanage;

import java.sql.*;

public class ConnectDatebase {
    Connection con;
    public ConnectDatebase(){
        openDb();
    }

    public void openDb(){
        try {
            Class.forName(DBInfo.driver);
            String url=DBInfo.url;
            try {
                con=DriverManager.getConnection(url, DBInfo.username, DBInfo.passworld);
                System.out.println("OK");
            } catch (Exception ex1) {
                System.out.println(ex1.getStackTrace());
            }
        } catch (Exception ex) {
            System.out.println(ex.getStackTrace());
        }
    }

    public ResultSet query(String strSql) {
        try {
            Statement stmt = con.createStatement();
            ResultSet rs = stmt.executeQuery(strSql);
            return rs;
        } catch (Exception ex) {
            System.out.println(ex.getStackTrace());
            return null;
        }
    }

    public boolean update(String strSql) {
        try {
            Statement stmt = con.createStatement();
            stmt.executeUpdate(strSql);
        } catch (Exception ex) {
            System.out.println(ex.getStackTrace());
            return false;
        }
        return true;
}
    public boolean add(String strSql) {
        try {
            Statement stmt = con.createStatement();
            stmt.execute(strSql);
        } catch (Exception ex) {
            System.out.println(ex.getStackTrace());
            return false;
        }
        return true;
}

}