如何使用 JDBC API 调用数据库中的现有函数?

jdbcjava 8object oriented programmingprogramming

您可以像存储过程一样使用 CallableStatement 对象调用函数,以使用 JDBC 程序调用函数。

  • 连接到数据库。

  • 创建一个 PreparedStatement 对象,并以字符串格式向其构造函数传递函数调用。

  • 将值设置为占位符。

  • 执行 Callable 语句。

以下是从 JDBC 调用函数的查询:

{? = call getDob(?)}

如您所见,查询包含占位符(?),就像准备好的和可调用的语句一样。

在上面的查询中,第一个占位符表示函数的返回值,第二个占位符表示输入参数。

您需要使用 registerOutParameter() 方法(CallableStatement 接口)将表示返回值的占位符注册为输出参数。对于此方法,您需要传递一个表示占位符位置的整数值和一个表示 SQL 类型(参数的)的整数变量

示例

假设我们有一个名为 EmployeeDetails 的表,其中包含以下内容:

+--------+------------+----------------+
| Name   | DOB        | Location       |
+--------+------------+----------------+
| Amit   | 1989-09-26 | Hyderabad      |
| Sumith | 1989-09-01 | Vishakhapatnam |
| Sudha  | 1980-09-01 | Vijayawada     |
+--------+------------+----------------+

我们创建了一个名为 getDob() 的函数,如下所示:

mysql> DELIMITER // ;
mysql> CREATE FUNCTION getDob(emp_name VARCHAR(50)) RETURNS DATE
       BEGIN
           declare dateOfBirth DATE;
           select DOB into dateOfBirth from EMP where Name = emp_name;
           return dateOfBirth;
       END//
Query OK, 0 rows affected (0.00 sec)
mysql> DELIMITER ;

此函数接受员工姓名,检索并返回指定员工的出生日期。

以下 JDBC 程序与 MySQL 数据库建立连接,并通过将员工姓名作为参数传递给它来调用名为 getDob() 的函数,并从函数的返回值中检索出生日期值。

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Types;
public class CallingFunctionsExample {
   public static void main(String args[]) throws SQLException {
      //注册驱动程序
      DriverManager.registerDriver(new com.mysql.jdbc.Driver());
      //获取连接
      String mysqlUrl = "jdbc:mysql://localhost/mydatabase";
      Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
      System.out.println("Connection established......");
      //准备 CallableStatement 来调用函数
      CallableStatement cstmt = con.prepareCall("{? = call getDob(?)}");
      //注册函数的输出参数(返回类型)
      cstmt.registerOutParameter(1, Types.DATE);
      //设置函数的输入参数
      cstmt.setString(2, "Amit");
      //执行语句
      cstmt.execute();
      System.out.print("Date of birth: "+cstmt.getDate(1));
   }
}

输出

Connection established......
Date of birth: 1970-01-08

相关文章