如何使用JDBC API调用数据库中的现有函数?
您可以像存储过程一样使用CallableStatement对象调用函数,以使用所需的JDBC程序调用函数。
连接到数据库。
创建一个PreparedStatement对象,并向其构造函数传递String格式的函数调用。
为占位符设置值。
执行Callable语句。
以下是从JDBC调用函数的查询:
{? = call getDob(?)}如您所见,查询包含占位符(?),就像准备和可调用的语句一样。
在上面的查询中,第一个占位符代表函数的返回值,第二个占位符代表输入参数。
您需要使用CallableStatement接口的registerOutParameter()方法将代表返回值的占位符注册为输出参数。对于此方法,您需要传递一个表示占位符位置的整数值,以及一个表示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//
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(?)}");
//注册函数的out参数(返回类型)
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