jdbcbean.java

本源码主要从数据库的开发过程出发

package Source;

import java.sql.*;
import java.util.logging.Level;
import java.util.logging.Logger;

public class JDBCBean {

    private Connection conn;
    private Statement stmt = null;
    private ResultSet rs = null;

    public JDBCBean() {
        try {
            Class.forName("com.mysql.jdbc.Driver");

        } catch (ClassNotFoundException ex) {
        }
    }

    public Connection getConn() {
        try {
            conn = DriverManager.getConnection("jdbc:mysql://localhost/gradeiosystem", "root", "root");
        } catch (SQLException ex) {
            Logger.getLogger(JDBCBean.class.getName()).log(Level.SEVERE, null, ex);
        }
        return conn;
    }

    public void closeConn() {
        if (conn != null) {
            try {
                conn.close();
                conn = null;
            } catch (SQLException ex) {
                Logger.getLogger(JDBCBean.class.getName()).log(Level.SEVERE, null, ex);
                ex.printStackTrace();
            }
        }
    }

    public void closeStmt() {
        if (stmt != null) {
            try {
                stmt.close();
                stmt = null;
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }
    }

    private void closeRs() {
        if (rs != null) {
            try {
                rs.close();
                rs = null;
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }
    }

    public void close() {
        this.closeRs();
        this.closeStmt();
        this.closeConn();
    }

    public int executeUpdate(String sql) {
        int num = 0;
        try {
            conn = this.getConn();
            stmt = conn.createStatement();
            num = stmt.executeUpdate(sql);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return num;
    }

    public ResultSet executeQuery(String sql) {
        rs = null;
        try {
            conn = this.getConn();
            stmt = conn.createStatement();
            rs = stmt.executeQuery(sql);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return rs;
    }
    public void setCommit(boolean o){
        try {
            conn.setAutoCommit(o);
        } catch (SQLException ex) {
            Logger.getLogger(JDBCBean.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
    public void Commit(){
        try {
            conn.commit();
        } catch (SQLException ex) {
            Logger.getLogger(JDBCBean.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}