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


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

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

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

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

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

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

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

让我们使用如下所示的CREATE语句在Oracle数据库中创建一个名为**dispatches**的表:

CREATE TABLE Dispatches(
   PRODUCTNAME VARCHAR2(20),
   CUSTOMERNAME VARCHAR2(20),
   DISPATCHDATE DATE,
   DELIVERYTIME TIMESTAMP(6),
   PRICE NUMBER(38),
   LOCATION VARCHAR2(20)
);

现在,我们将使用INSERT语句在**dispatches**表中插入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数据库的连接,并创建一个名为retrieveData的过程,该过程检索上面创建的表的内容。

示例

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 {
      //Registering the Driver
      DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
      //Getting the connection
      String oracleUrl = "jdbc:oracle:thin:@localhost:1521/xe";
      Connection con = DriverManager.getConnection(oracleUrl, "system", "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......

更新于:2019年7月30日

605 次浏览

启动您的职业生涯

完成课程获得认证

开始学习
广告