如何使用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:///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)
广告
数据结构
网络
关系数据库管理系统 (RDBMS)
操作系统
Java
iOS
HTML
CSS
Android
Python
C语言编程
C++
C#
MongoDB
MySQL
Javascript
PHP