JDBC 入门 - 操作SQL语句

浏览数：22 / 时间：2015年06月12日

操作 SQL 语句

Statement, PreparedStatement, CallableStatement

一旦建立好连接, 就可以与数据库交互. JDBC 中Statement, PreparedStatement 和 CallableStatement 提供了SQL操作的相关API. 其中 CallableStatement 继承自 PreparedStatement, 而 PreparedStatement 又继承自 Statement. 他们的区别是:

Statement 提供基本的 SQL 操作. 适合静态SQL语句, 且传入的 SQL 语句无法接受参数.
PreparedStatement 可以在 SQL 中传递参数, 适合多次使用的 SQL 语句.
CallableStatement 可以调用 PL/SQL 存储过程.

尽管接口功能有不同, 但是使用方式大体相同, 分以下几步:

创建 Statement
执行 SQL 语句
关闭 Statement

在执行 SQL 语句的时候, 常用以下几个方法:

boolean execute(String SQL) : 如果有 ResultSet 产生返回true, 否则, 返回 false. 一般用于 CREATE, ALTER 这些操作.
int executeUpdate(String SQL) : 返回被影响的记录的条数, 一般用于 INSERT, UPDATE, DELETE 这些操作.
ResultSet executeQuery(String SQL) : 返回查询结果集, 专用语 SELECT.

以下三个例子分别示例了如何适用他们.

Statement 例子.
PreparedStatement 例子.
Statement 例子.

SQL 的批处理操作

SQL 批处理能够允许添加多个 SQL 到一个Statement对象, 并一并提交执行结果. 这减少了与 SQL 通信的频率. 但是, SQL 批处理不是 JDBC 要求一定要支持的. 使用前应该用 DatabaseMetaData.supportsBatchUpdates() 检查支持情况.

SQL 批处理相关的 API 有:

Statement.addBatch(): 往批处理中添加 SQL 语句
Statement.executeBatch(): 执行批处理, 并返回一个整型数组, 其中每个元素代表对应序号 SQL 的执行结果.
Statement.clearBatch(): 从批处理中删除已添加的所有 SQL 语句.

以下示例如何使用批处理往数据库添加数据:

 public static void batchInsertPosts(ArrayList<Post> posts) throws SQLException {
        Connection conn = getConnectionFromDS(dbProps);
        DatabaseMetaData md = conn.getMetaData();
        System.out.println("If support batch updates: " + md.supportsBatchUpdates());
        String sql = "INSERT INTO POSTS\n"
                   + "VALUES(NULL, ?, ?, DEFAULT, ?)";
        PreparedStatement stmt = conn.prepareCall(sql);

        for (Post post : posts) {
            stmt.setString(1, post.getTitle());
            stmt.setString(2, post.getContent());
            stmt.setBoolean(3, post.isVisible());
            stmt.addBatch();
        }
        stmt.executeBatch();
        printWarnings(stmt.getWarnings()); // 打印所有 warning. 见 "SQL异常处理"
        stmt.close();
        conn.close();
    }

SQL 异常处理

JDBC 中最常用的异常就是 SQLException, 不管是在建立连接, 还是在执行 SQL 语句的时候, 都有可能抛出这个异常. SQLException 包含以下信息:

关于错误的描述. 通过调用getMessage() 获得.
一个 SQL 状态码. 通过调用 getSQLState( ) 获取. SQL 状态码由5位字母和数字组成, 符合 XOPEN 规范.
一个错误码. 这个错误码的含义由实现规定, 有可能是数据库的错误码. 通过调用 SQLException.getErrorCode() 获取.
错误缘由. 引发异常的缘由, 有可能是一个或者多个 Throwable 的对象组成的一条链. 要想检查这些缘由, 要递归遍历 SQLException.getCause() 直到返回一个 null.
异常链. 通过 getNextException() 获取下一个异常.

以下代码示例如何打印异常链中的每个SQLException异常, 并且打印每个异常的 cause 链.

    public static void printSQLException(SQLException ex) {
        for (Throwable e : ex) {    // Iterator 会调用 getNextException()
            if (e instanceof SQLException) {

                e.printStackTrace(System.err);
                System.err.println("SQLState: " +
                        ((SQLException)e).getSQLState());

                System.err.println("Error Code: " +
                        ((SQLException)e).getErrorCode());

                System.err.println("Message: " + e.getMessage());

                Throwable t = ex.getCause();
                while(t != null) {  // 打印每个 cause
                    System.out.println("Cause: " + t);
                    t = t.getCause();
                }
            }
        }
    }

除了发生致命错误产生抛出 SQLException 之外, Connection, Statement, ResultSet 都有一个 getWarnings() 方法, 它返回一个 SQLWarning. SQLWarning 继承自 SQLException, 可以向遍历 SQLException 一样遍历它:

    public static void printWarnings(SQLWarning warning)
        throws SQLException {
        while (warning != null) {
            System.out.println("Message: " + warning.getMessage());
            System.out.println("SQLState: " + warning.getSQLState());
            System.out.print("Vendor error code: ");
            System.out.println(warning.getErrorCode());
            System.out.println("");
            warning = warning.getNextWarning();
        }
    }