文档主页
MySQL Connector/J 开发人员指南
相关文档 下载本手册
PDF (US Ltr) - 1.2Mb
PDF (A4) - 1.2Mb


MySQL Connector/J 开发人员指南  /  JDBC 概念  /  使用 JDBC Statement 对象执行 SQL

7.2 使用 JDBC Statement 对象执行 SQL

Statement 对象允许您执行基本的 SQL 查询,并通过 ResultSet 类检索结果,这将在后面描述。

要创建 Statement 实例,您可以在使用前面描述的 DriverManager.getConnection()DataSource.getConnection() 方法检索到的 Connection 对象上调用 createStatement() 方法。

获得 Statement 实例后,您可以通过使用要使用的 SQL 调用 executeQuery(String) 方法来执行 SELECT 查询。

要更新数据库中的数据,请使用 executeUpdate(String SQL) 方法。此方法返回与更新语句匹配的行数,而不是已修改的行数。

如果您事先不知道 SQL 语句是 SELECT 还是 UPDATE/INSERT,则可以使用 execute(String SQL) 方法。如果 SQL 查询是 SELECT,则此方法将返回 true,如果它是 UPDATEINSERTDELETE 语句,则返回 false。如果该语句是 SELECT 查询,则可以通过调用 getResultSet() 方法来检索结果。如果该语句是 UPDATEINSERTDELETE 语句,则可以通过在 Statement 实例上调用 getUpdateCount() 来检索受影响的行数。

示例 7.2 Connector/J:使用 java.sql.Statement 执行 SELECT 查询

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

// assume that conn is an already created JDBC connection (see previous examples)

Statement stmt = null;
ResultSet rs = null;

try {
    stmt = conn.createStatement();
    rs = stmt.executeQuery("SELECT foo FROM bar");

    // or alternatively, if you don't know ahead of time that
    // the query will be a SELECT...

    if (stmt.execute("SELECT foo FROM bar")) {
        rs = stmt.getResultSet();
    }

    // Now do something with the ResultSet ....
}
catch (SQLException ex){
    // handle any errors
    System.out.println("SQLException: " + ex.getMessage());
    System.out.println("SQLState: " + ex.getSQLState());
    System.out.println("VendorError: " + ex.getErrorCode());
}
finally {
    // it is a good idea to release
    // resources in a finally{} block
    // in reverse-order of their creation
    // if they are no-longer needed

    if (rs != null) {
        try {
            rs.close();
        } catch (SQLException sqlEx) { } // ignore

        rs = null;
    }

    if (stmt != null) {
        try {
            stmt.close();
        } catch (SQLException sqlEx) { } // ignore

        stmt = null;
    }
}