如何使用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)

以上是 如何使用JDBC API在数据库中创建存储过程? 的全部内容, 来源链接: utcz.com/z/326483.html

回到顶部