标签：
一旦建立好连接, 就可以与数据库交互. JDBC 中Statement, PreparedStatement 和 CallableStatement 提供了SQL操作的相关API. 其中 CallableStatement 继承自 PreparedStatement, 而 PreparedStatement 又继承自 Statement. 他们的区别是:
Statement 提供基本的 SQL 操作. 适合静态SQL语句, 且传入的 SQL 语句无法接受参数.PreparedStatement 可以在 SQL 中传递参数, 适合多次使用的 SQL 语句.CallableStatement 可以调用 PL/SQL 存储过程.尽管接口功能有不同, 但是使用方式大体相同, 分以下几步:
在执行 SQL 语句的时候, 常用以下几个方法:
boolean execute(String SQL) : 如果有 ResultSet 产生返回true, 否则, 返回 false. 一般用于 CREATE, ALTER 这些操作.int executeUpdate(String SQL) : 返回被影响的记录的条数, 一般用于 INSERT, UPDATE, DELETE 这些操作.ResultSet executeQuery(String SQL) : 返回查询结果集, 专用语 SELECT.以下三个例子分别示例了如何适用他们.
SQL 批处理能够允许添加多个 SQL 到 一个Statement对象, 并一并提交执行结果. 这减少了与 SQL 通信的频率. 但是, SQL 批处理不是 JDBC 要求一定要支持的. 使用前应该用 DatabaseMetaData.supportsBatchUpdates() 检查支持情况.
SQL 批处理相关的 API 有:
以下示例如何使用批处理往数据库添加数据:
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(); }
JDBC 中最常用的异常就是 SQLException, 不管是在建立连接, 还是在执行 SQL 语句的时候, 都有可能抛出这个异常. SQLException 包含以下信息:
getMessage() 获得.getSQLState( ) 获取. SQL 状态码由5位字母和数字组成, 符合 XOPEN 规范.SQLException.getErrorCode() 获取.以下代码示例如何打印异常链中的每个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(); } }
标签：
原文地址：http://www.cnblogs.com/pragmatic/p/4247998.html
