JDBC 學習筆記（五）—— Statement

JDBC 使用 Statement 作為 SQL 語句的執行器。

Statement 通過 Connection.createStatement() 方法創建，一共支持以下6種方式執行 SQL 語句：

• execute()
• executeUpdate()
• executeQuery() 
• executeLargeUpdate() 
• executeBatch()
• executeLargeBatch()

 

 

1. execute()

boolean execute(String sql) throws SQLException;

execute() 方法，提供了一個通用的接口去執行 SQL 語句，它能夠接受任何 SQL 語句，返回的布爾值是判斷是否有 ResultSet 返回。

Statement 提供了一下兩個接口去獲得 execute() 真正的執行結果（分別針對 executeUpdate() 和 executeQuery() 的情況）：

ResultSet getResultSet() throws SQLException;

int getUpdateCount() throws SQLException;

 

 

2. executeUpdate()

int executeUpdate(String sql) throws SQLException;

executeUpdate() 方法，是用來執行 DML 語句中的 INSERT, DELETE, UPDATE，返回受這個 DML 語句影響的行數。

但是，這個方法，在執行 SELECT 語句，或者是 DDL、DCL 語句也不會出錯，並且能夠正確執行，返回結果是0。

 

 

3. executeQuery()

ResultSet executeQuery(String sql) throws SQLException;

executeQuery() 方法，是用來執行 DML 語句中的 SELECT，返回 ResultSet 結果集。

這個方法在執行非 SELECT 的 SQL 語句時，會拋出異常，執行的內容不會影響數據庫。

java.sql.SQLException: query does not return ResultSet
	at org.sqlite.jdbc3.JDBC3Statement.executeQuery(JDBC3Statement.java:85)
	at com.gerrard.demo.StatementDemo.main(StatementDemo.java:20)

 

 

4. executeLargeUpdate()

在 Java8 中，還新增了 executeLargeUpdate() 方法，針對更新行數超過 Integer.MAX_VALUE 的情況：

default long executeLargeUpdate(String sql) throws SQLException {
    throw new UnsupportedOperationException("executeLargeUpdate not implemented");
}

executeLargeUpdate() 方法適用的范圍很小，返回結果是 long 型，接受的 SQL 語句與 executeUpdate() 完全相同。

很多數據庫廠商都沒有開放對 executeLargeUpdate() 的支持。

 

 

5. executeBatch()

Statement 還提供了 executeBatch() 方法來支持 SQL 語句的批處理：

int[] executeBatch() throws SQLException;

使用 executeBatch() 方法，首先需要通過 addBatch() 方法注入 SQL 語句：

void addBatch( String sql ) throws SQLException;

這里需要注意的是，executeBatch() 不支持 SELECT 語句。

 

 

6. executeLargeBatch()

與 executeUpdate() 類似，Java8 提供了 executeLargeBatch() 方法增強批量更新。

批處理的時候，任意一條 SQL 語句返回值大於 Integer.MAX_VALUE，就要使用這個方法：

default long[] executeLargeBatch() throws SQLException {
    throw new UnsupportedOperationException("executeLargeBatch not implemented");
}

 

 

7. Demo

最后貼一個自己寫的例子：

package com.gerrard.demo;

import com.gerrard.util.Connector;
import com.gerrard.util.DriverLoader;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public final class StatementDemo {

    public static void main(String[] args) {

        String querySql = "SELECT * from STUDENT";
        String updateSql1 = "UPDATE STUDENT SET STUDENT_PASSWORD = '123456' WHERE STUDENT_PASSWORD = '123456'";
        String updateSql2 = "UPDATE STUDENT SET STUDENT_PASSWORD = '223456' WHERE STUDENT_PASSWORD = '223456'";

        DriverLoader.loadSqliteDriver();
        try (Connection conn = Connector.getSqlConnection();
             Statement stmt = conn.createStatement()) {

            // execute
            boolean hasResult = stmt.execute(updateSql1);
            if (hasResult) {
                System.out.println("Execute query success");
            } else {
                System.out.println("Execute update success, affect" + stmt.getUpdateCount() + " rows");
            }

            // executeUpdate
            int rowCount1 = stmt.executeUpdate(updateSql1);
            System.out.println("Affected " + rowCount1 + " rows");

            // executeQuery
            try (ResultSet rs = stmt.executeQuery(querySql)) {
                int counter = 0;
                while (rs.next()) {
                    counter++;
                }
                System.out.println(counter + " students in all");
            }

            // executeBatch
            stmt.addBatch(updateSql1);
            stmt.addBatch(updateSql2);
            stmt.addBatch(updateSql1);
            int[] results = stmt.executeBatch();
            for (int result : results) {
                System.out.println("Affected " + result + " rows");
            }

            // executeLargeUpdate
            stmt.executeLargeUpdate(updateSql1);

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

 

執行結果：