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

答：存储过程是子例程，是SQL语句的一部分，存储在SQL目录中。所有可以访问关系数据库的应用程序（Java，Python，PHP等）都可以访问存储过程。

存储过程包含IN和OUT参数或两者。如果您使用SELECT语句，它们可能会返回结果集。存储过程可以返回多个结果集。

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

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

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

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

• 执行查询：使用execute()Statement接口的方法执行查询以创建存储过程。

示例

假设我们在数据库中有一个名为“客户”的表，其内容如下：

+---------+---------------+------+-----+---------+-------+
| 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的数据库中创建一个名为restoreData的过程。

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命令显示指定程序的源代码，如果它不存在，你会得到一个错误。

使用以下命令，验证是否在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)