如何使用JDBC API在数据库中创建存储过程?


A. 存储过程是子程序,是存储在SQL目录中的SQL语句段。所有能够访问关系数据库的应用程序(Java、Python、PHP等)都可以访问存储过程。

存储过程包含输入和输出参数,或两者兼有。如果使用SELECT语句,它们可能会返回结果集。存储过程可以返回多个结果集。

要在(MySQL)数据库中使用JDBC API创建存储过程,您需要:

  • 注册驱动程序:使用 **DriverManager** 类的 **registerDriver()** 方法注册驱动程序类。将驱动程序类名作为参数传递给它。

  • 建立连接:使用 **DriverManager** 类的 **getConnection()** 方法连接到数据库。将URL(字符串)、用户名(字符串)、密码(字符串)作为参数传递给它。

  • 创建Statement:使用 **Connection** 接口的 **createStatement()** 方法创建一个 Statement 对象。

  • 执行查询:使用 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的数据库中创建一个名为retrieveData的过程。

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 {
      //Registering the Driver
      DriverManager.registerDriver(new com.mysql.jdbc.Driver());
      //Getting the connection
      String mysqlUrl = "jdbc:mysql://127.0.0.1/MyDatabase";
      Connection con = DriverManager.getConnection(mysqlUrl, "root", "password");
      System.out.println("Connection established......");
      //Creating the Statement
      Statement stmt = con.createStatement();
      //Query to create stored procedures
      String query = "CREATE PROCEDURE `retrieveData`() " +
         "BEGIN "+
         " SELECT * FROM Customers; "+
         "END";
      //Executing the query
      stmt.execute(query);
      System.out.println("Procedure Created......");
   }
}

输出

Connection established......
Procedure Created......

SHOW CREATE PROCEDURE **procedure_name** 命令显示指定过程的源代码;如果过程不存在,则会报错。

使用此命令验证是否在MySQL数据库中创建了名为retrieveData的过程:

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)

更新于:2019年7月30日

3000+ 次浏览

启动您的职业生涯

完成课程获得认证

开始学习
广告