存储过程是子例程,是SQL语句的一部分,存储在SQL目录中。所有可以访问关系数据库的应用程序(Java,Python,PHP等)都可以访问存储过程。
存储过程包含IN和OUT参数或两者。如果您使用SELECT语句,它们可能会返回结果集。存储过程可以返回多个结果集。
要使用JDBC API在(MySQL)数据库中创建存储过程,您需要-
注册驱动程序:使用DriverManager 类的registerDriver() 方法注册驱动程序类。将驱动程序类名称作为参数传递给它。
建立连接:使用DriverManager 类的 getConnection() 方法连接到数据库。将URL(字符串),用户名(字符串),密码(字符串)作为参数传递给它。
创建语句:使用Connection 接口的 createStatement()方法创建一个Statement对象。
执行查询:使用execute()
Statement接口的方法执行查询以创建存储过程。
让我们使用CREATE语句在Oracle数据库中创建一个带有名称调度 的表,如下所示-
CREATE TABLE Dispatches( PRODUCTNAME VARCHAR2(20), CUSTOMERNAME VARCHAR2(20), DISPATCHDATE DATE, DELIVERYTIME TIMESTAMP(6), PRICE NUMBER(38), LOCATION VARCHAR2(20) );
现在,我们将使用INSERT语句在分派 表中插入5条记录-
insert into dispatches values('Key-Board', 'Raja', TO_DATE('2019-09-01', 'yyyy/mm/dd'), TO_DATE('11:00:00', 'hh:mi:ss'), 7000, 'India'); insert into dispatches values('Earphones', 'Roja', TO_DATE('2019-05-01', 'yyyy/mm/dd'), TO_DATE('11:00:00', 'hh:mi:ss'), 2000, 'Vishakhapatnam'); insert into dispatches values('Mouse', 'Puja', TO_DATE('2019-03-01', 'yyyy/mm/dd'), TO_DATE('10:59:59', 'hh:mi:ss'), 3000, 'Vijayawada'); insert into dispatches values('Mobile', 'Vanaja', TO_DATE('2019-03-01', 'yyyy/mm/dd'), TO_DATE('10:10:52', 'hh:mi:ss'), 9000, 'Chennai'); insert into dispatches values('Headset', 'Jalaja', TO_DATE('2019-04-06', 'yyyy/mm/dd'), TO_DATE('11:08:59', 'hh:mi:ss' ), 6000, 'Goa');
接下来的JDBC程序建立与Oracle数据库的连接,并创建一个名为restoreData的过程,该过程将检索上面创建的表的内容。
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; public class CreatingStoredProcedures_Oracle { public static void main(String args[]) throws SQLException { //注册驱动程序 DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver()); //获得连接 String oracleUrl = "jdbc:oracle:thin:@localhost:1521/xe"; Connection con = DriverManager.getConnection(oracleUrl, "system", "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......