JDBC - CallableStatement 对象示例

以下示例使用了 CallableStatement 以及以下 **getEmpName()** MySQL 存储过程。此过程根据提供的 ID 返回一个值，即员工的姓氏。

确保您已在 EMP 数据库中创建了此存储过程。您可以使用 MySQL 查询浏览器来完成此操作。

DELIMITER $$

DROP PROCEDURE IF EXISTS `EMP`.`getEmpName` $$
CREATE PROCEDURE `EMP`.`getEmpName` 
   (IN EMP_ID INT, OUT EMP_FIRST VARCHAR(255))
BEGIN
   SELECT first INTO EMP_FIRST
   FROM Employees
   WHERE ID = EMP_ID;
END $$

DELIMITER ;

此示例代码是根据前面章节中完成的环境和数据库设置编写的。

使用存储过程示例获取员工姓名

在此示例中，我们有四个静态字符串，包含数据库连接 URL、用户名、密码以及调用存储过程并带有占位符的查询。现在，使用 DriverManager.getConnection() 方法，我们准备了一个数据库连接。连接准备就绪后，我们使用 connection.prepareCall() 方法创建了一个 CallableStatement 对象。使用 CallableStatement.setInt()，我们设置了 IN 参数，并使用 CallableStatement.registerOutParameter() 准备了一个 OUT 变量来存储调用的存储过程的结果。

现在，使用 CallableStatement.execute()，我们运行了查询。最后，使用 statement.getString() 方法，我们检索了员工的姓名，并打印了结果。

将以下示例复制并粘贴到 JDBCCallableStatementExample.java 中，编译并运行如下：

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCCallableStatementExample {
   static final String DB_URL = "jdbc:mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY = "{call getEmpName (?, ?)}";

   public static void main(String[] args) {
      // Open a connection
      try(Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         CallableStatement stmt = conn.prepareCall(QUERY);
      ) {		      
         // Bind values into the parameters.
         stmt.setInt(1, 102);  // This would set ID
         // Because second parameter is OUT so register it
         stmt.registerOutParameter(2, java.sql.Types.VARCHAR);
         //Use execute method to run stored procedure.
         System.out.println("Executing stored procedure..." );
         stmt.execute();
         //Retrieve employee name with getXXX method
         String empName = stmt.getString(2);
         System.out.println("Emp Name with ID: 102 is " + empName);
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

输出

现在让我们按如下方式编译以上示例：

C:\>javac JDBCCallableStatementExample.java
C:\>

运行 **JDBCCallableStatementExample** 时，会产生以下结果：

C:\>java JDBCCallableStatementExample
Executing stored procedure...
Emp Name with ID: 102 is Zaid
C:\>

使用存储过程示例获取学生姓名和姓氏

在此示例中，我们使用了 CallableStatement 以及以下 **displayName()** MySQL 存储过程。此过程根据提供的 ID 返回两个值，即学生的姓名和姓氏。

确保您已在 EMP 数据库中创建了此存储过程。您可以使用 MySQL 查询浏览器来完成此操作。

DELIMITER //
 CREATE PROCEDURE displayName( IN StID int, OUT FName VARCHAR(255), OUT LName VARCHAR(255) )
     BEGIN
       SELECT FirstName, LastName 
       INTO FName,  LName
       FROM students 
       WHERE StudentID = StID;
END //

在此示例中，我们有四个静态字符串，包含数据库连接 URL、用户名、密码以及调用存储过程并带有占位符的查询。现在，使用 DriverManager.getConnection() 方法，我们准备了一个数据库连接。连接准备就绪后，我们使用 connection.prepareCall() 方法创建了一个 CallableStatement 对象。使用 CallableStatement.setInt()，我们设置了 IN 参数，并使用 CallableStatement.registerOutParameter() 准备了两个 OUT 变量来存储调用的存储过程的结果。

现在，使用 CallableStatement.execute()，我们运行了查询。最后，使用 statement.getString() 方法，我们检索了学生的姓名和姓氏，并打印了结果。

将以下示例复制并粘贴到 JDBCExample.java 中，编译并运行如下：

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JDBCCallableStatementExample {
   static final String DB_URL = "jdbc:mysql:///TUTORIALSPOINT";
   static final String USER = "guest";
   static final String PASS = "guest123";
   static final String QUERY = "{call displayName (?,?,?)}";

   public static void main(String[] args) {
      // Open a connection
      try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
         CallableStatement cstmt = conn.prepareCall(QUERY);
      ) {		      
         // Bind values into the parameters.
         cstmt.setInt(1, 1000);  // This would set stID
         // Because second parameter is OUT so register it
         cstmt.registerOutParameter(2, java.sql.Types.VARCHAR);
         cstmt.registerOutParameter(3, java.sql.Types.VARCHAR);
         //Use execute method to run stored procedure.
         System.out.println("Executing stored procedure..." );
         cstmt.execute();
         
        //Display First Name/ Last Name with getXXX method
          System.out.println(cstmt.getString(2));
          System.out.println(cstmt.getString(3));
      } catch (SQLException e) {
         e.printStackTrace();
      } 
   }
}

输出

现在让我们按如下方式编译以上示例：

C:\>javac JDBCCallableStatementExample.java
C:\>

运行 **JDBCCallableStatementExample** 时，会产生以下结果：

C:\>java JDBCCallableStatementExample
Executing stored procedure...
Bonny
Agarwal  
C:\>