如何使用 JDBC API 在数据库中创建存储过程?
jdbcjava 8object oriented programmingprogramming
答:存储过程是存储在 SQL 目录中的子例程、SQL 语句片段。所有可以访问关系数据库(Java、Python、PHP 等)的应用程序都可以访问存储过程。
存储过程包含 IN 和 OUT 参数或两者。如果您使用 SELECT 语句，它们可能会返回结果集。存储过程可以返回多个结果集。
要使用 JDBC API 在数据库(MySQL)中创建存储过程，您需要:
注册驱动程序:使用 DriverManager 类的 registerDriver() 方法注册驱动程序类。将驱动程序类名作为参数传递给它。
建立连接:使用 DriverManager 类的 getConnection() 方法连接数据库。将 URL(字符串)、用户名(字符串)、密码(字符串)作为参数传递给它。
创建语句:使用 Connection 接口的 createStatement() 方法创建语句对象。
执行查询:使用 Statement 接口的 execute() 方法执行查询以创建存储过程。
示例
假设数据库中有一个名为 Customers 的表，其描述如下:
+---------+---------------+------+-----+---------+-------+ | Field | Type | Null | Key | Default | Extra | +---------+---------------+------+-----+---------+-------+ | ID | int(11) | NO | PRI | NULL | | | NAME | varchar(20) | NO | | NULL | | | AGE | int(11) | NO | | NULL | | | SALARY | decimal(18,2) | YES | | NULL | | | ADDRESS | char(25) | YES | | NULL | | +---------+---------------+------+-----+---------+-------+
以下 JDBC 程序与 MySQL 建立连接，并在名为 mydatabase 的数据库中创建一个名为 triesteData 的过程。
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class CreateStoredProcedureExample {
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......");
//创建语句
Statement stmt = con.createStatement();
//查询以创建存储过程
String query = "CREATE PROCEDURE `retrieveData`() " +
"BEGIN "+
" SELECT * FROM Customers; "+
"END";
//执行查询
stmt.execute(query);
System.out.println("Procedure Created......");
}
}
输出
Connection established...... Procedure Created......
SHOW CREATE PROCEDURE procedure_name 命令显示指定过程的源代码，如果不存在，您将收到错误。
验证名为retrieveData 的过程是否在 MySQL 数据库中创建，使用此命令如下:
mysql> SHOW CREATE PROCEDURE retrieveData; +--------------+----------------------------------------------------------------+----------------------------------------------------------------------------------------------------+----------------------+----------------------+--------------------+ | Procedure | sql_mode | Create Procedure | character_set_client | collation_connection | Database Collation | +--------------+----------------------------------------------------------------+----------------------------------------------------------------------------------------------------+----------------------+----------------------+--------------------+ | retrieveData | STRICT_TRANS_TABLES,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION | CREATE DEFINER=`root`@`localhost` PROCEDURE `retrieveData`() BEGIN SELECT * FROM Customers; END | utf8 | utf8_general_ci | utf8_general_ci | +--------------+----------------------------------------------------------------+----------------------------------------------------------------------------------------------------+----------------------+----------------------+--------------------+ 1 row in set (0.00 sec)
