jdbc java數據庫連接 3）Statement接口之執行DDL和DML語句的簡化

上一章的代碼中，可以發現，jdbc執行DDL和DML有幾個步驟都是一樣的：

 

　　　1）執行語句開始時，創建驅動注冊對象、獲取連接的數據庫對象、創建Statement對象

            // 創建驅動注冊對象
            Class.forName("com.mysql.jdbc.Driver");

            // 獲取連接的數據庫對象
             Connection conn = DriverManager.getConnection(url, user,
                    password);

            // 創建Statement對象
             Statement stsm = conn.createStatement();

　　

　　　　2）所有操作執行完后，關閉連接（后來的先關）

            if (stsm != null) {
                try {
                    stsm.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                    throw new RuntimeException(e);
                }

 

所以，我們可以把這三大部分湊起來，建立一個jdbc的工具類：

　　jdbcutil

　　　　

/**
 * 這是jdbc執行DDL和DML的工具類
 * 
 * @author LZl
 * 
 */
public class Jdbcutil {

    // 創建數據庫的基本信息
    // 創建url
    private static String url = "jdbc:mysql://localhost:3306/day1029?useUnicode=true&characterEncoding = GB2312 ";
    // 數據庫的用戶名和密碼
    private static String user = "root";
    private static String password = "root";
    public static Connection conn = null;
    static Statement stsm = null;

    /**
     * 一：注冊的驅動程序 獲取連接對象的方法 靜態代碼塊（好處是只需要加載一次，且隨着類的加載而加載）
     */

    static {
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("獲取數據庫連接對象出錯");
        }
    }

    /**
     * 二：獲取連接對象 該方法返回一個連接 33      */

    public static Connection getConnection() {

        // 創建連接對象
        try {
            conn = DriverManager.getConnection(url, user, password);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return conn;

    }

    /**
     * 三：釋放資源，斷開連接 參數列表：conn。stsm 51      */

    public static void close(Connection conn, Statement stsm) {

        if (stsm != null) {
            try {
                stsm.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }

        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
    }
　　
}

 

　　　工具類再重載一個帶有3個參數的關閉連接的方法：

 1     public static void close(Connection conn,Statement stmt,ResultSet rs){
 2         if(rs!=null) 3 try { 4  rs.close(); 5 } catch (SQLException e1) { 6  e1.printStackTrace(); 7 throw new RuntimeException(e1); 8  } 9 if(stmt!=null){ 10 try { 11  stmt.close(); 12 } catch (SQLException e) { 13  e.printStackTrace(); 14 throw new RuntimeException(e); 15  } 16  } 17 if(conn!=null){ 18 try { 19  conn.close(); 20 } catch (SQLException e) { 21  e.printStackTrace(); 22 throw new RuntimeException(e); 23  } 24  } 25 }

 

然后，1）jdbc使用DDL的方法要這樣：

public class UtilTest {

    private static Connection conn = null;
    // 創建Statement對象
    private static Statement stsm;

    // 執行DDL語句（創建）
    private static void DDL() {

        try {
            // 使用jdbc工具類來獲取連接對象
            conn = Jdbcutil.getConnection();

            // 准備sql語句
            String sql = "CREATE TABLE person(id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(10),sex VARCHAR(5),age INT,psot VARCHAR(10),email VARCHAR(20),phone INT)";

            stsm = conn.createStatement();

            // 發送sql語句
            int result = stsm.executeUpdate(sql);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 調用工具類的方法，關閉連接
            Jdbcutil.close(conn, stsm);
        }
    }
    public static void main(String[] args) {
        DDL();
    }
}

　

 

 

 

　　 

　　2）執行DML語句：

    //創建驅動注冊對象
    private static Connection conn = null;
    // 創建Statement對象
    private static Statement stsm = null;

// 執行DML語句（插入）
    private static void DML() {

        try {
            // 使用工具類獲取連接對象
            conn = Jdbcutil.getConnection();

            // 准備sql語句
            String sql = "INSERT INTO person (NAME,sex,age) VALUES ('張三','男',20);";

            // 創建statement對象
            stsm = conn.createStatement();

            // 執行sql語句
            int result = stsm.executeUpdate(sql);
            System.out.println("影響了" + result + "行");

        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 調用工具類關閉連接
            Jdbcutil.close(conn, stsm);
        }
    }

 

　　3）執行DQL語句：

    // 創建驅動注冊對象
    private static Connection conn = null;
    // 創建Statement對象
    private static Statement stsm = null;

        // 執行DQL語句
    private static void DQL() {

        try {

            // 調用工具類連接對象
            conn = Jdbcutil.getConnection();

            // 創建statement對象
            stsm = conn.createStatement();

            // 准備sql語句
            String sql = "SELECT * FROM person;";

            // 執行sql語句,返回的是RrsultSet對象
            ResultSet rs = stsm.executeQuery(sql);

            // 查看第二行數據

            // 移動光標
            rs.next();
            rs.next();
            // 使用列名來查看
            int id = rs.getInt("id");
            String name = rs.getString("name");
            String sex = rs.getString("sex");
            System.out.println(id + "," + name + "," + sex);

        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        } finally {
            // 調用工具類關閉連接,這里要多關閉一個連接：ResultSet，工具類的關閉方法要添加它
            Jdbcutil.close(conn, stsm,rs);
        }

    }