對已儲存過程的調(diào)用是CallableStatement對象所含的內(nèi)容。這種調(diào)用是用一種換碼語法來寫的,有兩種形式:一種形式帶結(jié)果參,另一種形式不帶結(jié)果參數(shù)。結(jié)果參數(shù)是一種輸出(OUT)參數(shù),是已儲存過程的返回值。兩種形式都可帶有數(shù)量可變的輸入(IN參數(shù))、輸出(OUT參數(shù))或輸入和輸出(INOUT參數(shù))的參數(shù)。問號將用作參數(shù)的占位符。在JDBC中調(diào)用已儲存過程的語法如下所示。注意,方括號表示其間的內(nèi)容是可選項;方括號本身并非語法的組成部份。 {call過程名[(?,?,...)]} 返回結(jié)果參數(shù)的過程的語法為: {?=call過程名[(?,?,...)]} 不帶參數(shù)的已儲存過程的語法類似: {call過程名} 通常,創(chuàng)建CallableStatement對象的人應(yīng)當(dāng)知道所用的DBMS是支持已儲存過程的,并且知道這些過程都是些什么。然而,如果需要檢查,多種DatabaseMetaData方法都可以提供這樣的信息。例如,如果DBMS支持已儲存過程的調(diào)用,則supportsStoredProcedures方法將返回true,而getProcedures方法將返回對已儲存過程的描述。 CallableStatement繼承Statement的方法(它們用于處理一般的SQL語句),還繼承了PreparedStatement的方法(它們用于處理IN參)。 CallableStatement中定義的所有方法都用于處理OUT參數(shù)或INOUT參數(shù)的輸出部分:注冊O(shè)UT參數(shù)的JDBC類型(一般SQL類型)、從這些參數(shù)中檢索結(jié)果,或者檢查所返回的值是否為JDBCNULL。 JDBC存儲過程1、創(chuàng)建CallableStatement對象 CallableStatement對象是用Connection方法prepareCall創(chuàng)建的。下例創(chuàng)建CallableStatement的實例,其中含有對已儲存過程getTestData調(diào)用。該過程有兩個變量,但不含結(jié)果參數(shù):CallableStatementc stmt=con.prepareCall("{callgetTestData(?,?)}");其中?占位符為IN、OUT還是INOUT參數(shù),取決于已儲存過程getTestData。 JDBC存儲過程2、IN和OUT參數(shù) 將IN參數(shù)傳給CallableStatement對象是通過setXXX方法完成的。該方法繼承自PreparedStatement。所傳入?yún)?shù)的類型決定了所用的setXXX方法(例如,用setFloat來傳入float值等)。如果已儲存過程返回OUT參數(shù),則在執(zhí)行CallableStatement對象以前必須先注冊每個OUT參數(shù)的JDBC類型(這是必需的,因為某些DBMS要求JDBC類型)。注冊JDBC類型是用registerOutParameter方法來完成的。語句執(zhí)行完后,CallableStatement的getXXX方法將取回參數(shù)值。正確的getXXX方法是為各參數(shù)所注冊的JDBC類型所對應(yīng)的Java類型。換言之,registerOutParameter使用的是JDBC類型(因此它與數(shù)據(jù)庫返回的JDBC類型匹配),而getXXX將之轉(zhuǎn)換為Java類型。 作為示例,下述代碼先注冊O(shè)UT參數(shù),執(zhí)行由cstmt所調(diào)用的已儲存過程,然后檢索在OUT參數(shù)中返回的值。方法getByte從第一個OUT參數(shù)中取出一個Java字節(jié),而getBigDecimal從第二個OUT參數(shù)中取出一個BigDecimal對象(小數(shù)點后面帶三位數(shù)): CallableStatementc stmt=con.prepareCall("{callgetTestData(?,?)}"); cstmt.registerOutParameter(1,java.sql.Types.TINYINT); cstmt.registerOutParameter(2,java.sql.Types.DECIMAL,3); cstmt.executeQuery(); byte x=cstmt.getByte(1); java.math.BigDecimaln=cstmt.getBigDecimal(2,3); CallableStatement與ResultSet不同,它不提供用增量方式檢索大OUT值的特殊機制。JDBC存儲過程3、INOUT參數(shù) 既支持輸入又接受輸出的參數(shù)(INOUT參數(shù))除了調(diào)用registerOutParameter方法外,還要求調(diào)用適當(dāng)?shù)膕etXXX方法(該方法是從PreparedStatement繼承來的)。setXXX方法將參數(shù)值設(shè)置為輸入?yún)?shù),而registerOutParameter方法將它的JDBC類型注冊為輸出參數(shù)。setXXX方法提供一個Java值,而驅(qū)動程序先把這個值轉(zhuǎn)換為JDBC值,然后將它送到數(shù)據(jù)庫中。這種IN值的JDBC類型和提供給registerOutParameter方法的JDBC類型應(yīng)該相同。然后,要檢索輸出值,就要用對應(yīng)的getXXX方法。例如,Java類型為byte的參數(shù)應(yīng)該使用方法setByte來賦輸入值。應(yīng)該給registerOutParameter提供類型為TINYINT的JDBC類型,同時應(yīng)使用getByte來檢索輸出值。 下例假設(shè)有一個已儲存過程reviseTotal,其唯一參數(shù)是INOUT參數(shù)。方法setByte把此參數(shù)設(shè)為25,驅(qū)動程序?qū)阉鳛镴DBCTINYINT類型送到數(shù)據(jù)庫中。接著,registerOutParameter將該參數(shù)注冊為JDBCTINYINT。執(zhí)行完該已儲存過程后,將返回一個新的JDBCTINYINT值。方法getByte將把這個新值作為Javabyte類型檢索。 CallableStatementc stmt=con.prepareCall("{callreviseTotal(?)}"); cstmt.setByte(1,25); cstmt.registerOutParameter(1,java.sql.Types.TINYINT); cstmt.executeUpdate(); byte x=cstmt.getByte(1); 1)返回一個結(jié)果集(ResultSet)。2)返回一個特定的值?!∠旅鎭碓敿?xì)的說明?!?)返回一個結(jié)果集(ResultSet),這種類似通常的處理結(jié)果集如果事先就有一個類似如下的procedure CREATE PROCEDURE getShipQuantity @jsid int ASSELECT jf_js_id,SUM(jf_ship_quantity) AS shipqty FROM tjobsheet_finish f WHERE (jf_js_id=@jsid)GROUP BY jf_js_id 那么我們將通過如下的代碼來調(diào)用 String sql = "{ call getShipQuantity(?) }";Connection con = conn.connection();ResultSet rs = null;BigDecimal shipQuantity = new BigDecimal(0);try{ CallableStatement cs = con.prepareCall(sql); cs.setInt(1,jsoId);//設(shè)置輸入?yún)?shù) rs = cs.executeQuery();//返回結(jié)果集 if(rs.next()){ shipQuantity = new BigDecimal(rs.getDouble(2)); } logger.debug("shipQuantity --------------------- "+shipQuantity);}catch(Exception e){ logger.debug(e);}2)返回一個特定的值。也就是說,在procedure的定義中已經(jīng)用output輸出參數(shù)了。請看下面的proceduercreate procedure getSingleWgt @@singleWgt numeric(8,3) output,@jsnum varchar(11) = '0000-0480'asdeclare @stwgt numeric(8,3)select @stwgt = sum(b.stwgt)from js as ainner join jsactdtl as b on a.jsnum = b.jsnumwhere a.completion = 1 and b.stflag = 22and a.jsnum = @jsnumselect @@singleWgt = (@stwgt/orderedqty) from js where jsnum = @jsnum那么我們將通過如下的代碼來調(diào)用String sql = "{ call getSingleWgt(?,?) }";Connection con = getSession().connection();//得到connectiontry{ CallableStatement cs = con.prepareCall(sql);//通過它來執(zhí)行sql cs.registerOutParameter(1,java.sql.Types.FLOAT);//注冊輸出參數(shù) cs.setString(2,shipment.getJsnum());//指出輸入?yún)?shù) if(cs.execute()){//執(zhí)行 float output = cs.getFloat(1);//返回值 }}catch(Exception e){logger.debug(e);}
為襄城等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù),及襄城網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都網(wǎng)站建設(shè)、成都做網(wǎng)站、襄城網(wǎng)站設(shè)計,以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會得到認(rèn)可,從而選擇與我們長期合作。這樣,我們也可以走得更遠(yuǎn)!
JDBC調(diào)用存儲過程: CallableStatement\x0d\x0a在Java里面調(diào)用存儲過程,寫法那是相當(dāng)?shù)墓潭ǎ篭x0d\x0aClass.forName(....\x0d\x0aConnection conn = DriverManager.getConnection(....\x0d\x0a/**\x0d\x0a*p是要調(diào)用的存儲過程的名字,存儲過程的4個參數(shù),用4個?號占位符代替\x0d\x0a*其余地方寫法固定\x0d\x0a*/\x0d\x0aCallableStatement cstmt = conn.prepareCall("{call p(?,?,?,?)}");\x0d\x0a/**\x0d\x0a*告訴JDBC,這些個參數(shù),哪些是輸出參數(shù),輸出參數(shù)的類型用java.sql.Types來指定\x0d\x0a*下面的意思是,第3個?和第4個?是輸出參數(shù),類型是INTEGER的\x0d\x0a*Types后面具體寫什么類型,得看你的存儲過程參數(shù)怎么定義的\x0d\x0a*/\x0d\x0acstmt.registerOutParameter(3, Types.INTEGER);\x0d\x0acstmt.registerOutParameter(4, Types.INTEGER);\x0d\x0a/**\x0d\x0a*在我這里第1個?和第2個?是輸入?yún)?shù),第3個是輸出參數(shù),第4個既輸入又輸出\x0d\x0a*下面是設(shè)置他們的值,第一個設(shè)為3,第二個設(shè)為4,第4個設(shè)置為5\x0d\x0a*沒設(shè)第3個,因為它是輸出參數(shù)\x0d\x0a*/\x0d\x0acstmt.setInt(1, 3);\x0d\x0acstmt.setInt(2, 4);\x0d\x0acstmt.setInt(4, 5);\x0d\x0a//執(zhí)行\(zhòng)x0d\x0acstmt.execute();\x0d\x0a//把第3個參數(shù)的值當(dāng)成int類型拿出來\x0d\x0aint three = cstmt.getInt(3);\x0d\x0aSystem.out.println(three);\x0d\x0a//把第4個參數(shù)的值當(dāng)成int類型拿出來\x0d\x0aint four = cstmt.getInt(4);\x0d\x0aSystem.out.println(four);\x0d\x0a//用完別忘給人家關(guān)了,后開的先關(guān)\x0d\x0acstmt.close();\x0d\x0aconn.close();\x0d\x0a\x0d\x0aJDBC調(diào)用存儲過程,掌握這一個程序足夠了.\x0d\x0a以下是上面程序使用的存儲過程的代碼,我用的是Oracle數(shù)據(jù)庫,不過不論是什么數(shù)據(jù)庫,對于你的程序,JDBC這一端寫法都是一樣的.\x0d\x0a\x0d\x0acreate or replace procedure p\x0d\x0a(v_a in number,v_b number,v_ret out number,v_temp in out number)\x0d\x0ais\x0d\x0abegin\x0d\x0aif(v_a v_b) then\x0d\x0av_ret := v_a;\x0d\x0aelse\x0d\x0av_ret := v_b;\x0d\x0aend if;\x0d\x0av_temp := v_temp + 1;\x0d\x0aend;
最近做一個自動發(fā)郵件的schedule,由于取數(shù)據(jù)的sql太長,直接分割很麻煩,就想到調(diào)用PL/SQL,網(wǎng)上查了資料做了練習(xí),在此做下小結(jié)。
1、只有輸入?yún)?shù)而沒有返回結(jié)果的存儲過程。
sql:
1 create or replace procedure prc_1(deptno in number,dname in varchar2,loc in varchar2)
2 is
3 begin
4 insert into dept values(deptno,dname,loc);
5 end prc_1;
java:
1 static void test1(){
2 Connection conn=null;
3 CallableStatement csmt=null;
4 try {
5 conn=JDBCUtils.getConnection();
6 conn.setAutoCommit(false);
7 csmt=conn.prepareCall("call prc_1(?,?,?)");
8 csmt.setInt(1,80);
9 csmt.setString(2,"ioc");
10 csmt.setString(3,"fhp");
11 csmt.execute();
12 conn.commit();
13 System.out.println("success insert data");
14 } catch (SQLException e) {
15 e.printStackTrace();
16 }
17 }
2、有輸入?yún)?shù)且有一個返回值的存儲過程。
sql:
1 create or replace procedure prc_2(p_deptno in number,p_loc out varchar2) is
2 begin
3 select loc into p_loc from dept where deptno=p_deptno;
4 end prc_2;
java:
1 static void test2(){
2 Connection conn=null;
3 CallableStatement csmt=null;
4 try {
5 conn=JDBCUtils.getConnection();
6 conn.setAutoCommit(false);
7 csmt=conn.prepareCall("call prc_2(?,?)");
8 csmt.setInt(1,70);
9 csmt.registerOutParameter(2,Types.VARCHAR);
10 csmt.execute();
11 conn.commit();
12 System.out.println("MIS位置:"+csmt.getString(2));
13 } catch (SQLException e) {
14 e.printStackTrace();
15 }
16 }
3、返回多行記錄(游標(biāo))的存儲過程。
sql:
首先要建立一個返回游標(biāo),以便接收返回結(jié)果。
1 create or replace package testpackage is
2 type test_cursor is ref cursor;
3 end testpackage;
4
5 create or replace procedure prc_3(p_cursor out testpackage.test_cursor)is
6 begin
7 open p_cursor for
8 select * from dept order by deptno;
9 end prc_3;
java:
1 static void test3(){
2 Connection conn=null;
3 CallableStatement csmt=null;
4 ResultSet rs=null;
5 try {
6 conn=JDBCUtils.getConnection();
7 conn.setAutoCommit(false);
8 csmt=conn.prepareCall("call prc_3(?)");
9 csmt.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
10 csmt.execute();
11 rs=(ResultSet) csmt.getObject(1);
12 while(rs.next()){
13 System.out.println(rs.getString("deptno")+'\t'+rs.getString("dname")+'\t'+rs.getString("loc"));
14 }
15 } catch (SQLException e) {
16 // TODO Auto-generated catch block
17 e.printStackTrace();
18 }finally{
19 JDBCUtils.free(rs, csmt, conn);
20 }
21 }
方法如下:importjava.sql.Connection;importjava.sql.DriverManager;importjava.sql.ResultSet;importjava.sql.SQLException;importjava.sql.Statement;/***LoadJDBCDriver*最基本的方法通過JDBC連接數(shù)據(jù)庫*@authorJacob**/publicclassLoadByPrimary{publicstaticvoidmain(String[]args)throwsClassNotFoundException{Stringdriver="oracle.jdbc.OracleDriver";Connectioncn=null;/***Class.forName手動加載一個類到方法區(qū),Driver類中包含自動注冊驅(qū)動的靜態(tài)代碼塊*會自動在DriverManager中注冊驅(qū)動*/Class.forName(driver);Stringurl="jdbc:oracle:thin:@localhost:1521:ORACLE";//1521代表端口號,默認(rèn)的Stringuser="用戶名";Stringpwd="密碼";try{/**Connection是接口,返回值是一個引用對象,是Oracle驅(qū)動提供實現(xiàn)類ojdbc7.jar*使用JDBCAPI接口,實際上是驅(qū)動實現(xiàn)類*/cn=DriverManager.getConnection(url,user,pwd);Statementstmt=cn.createStatement();Stringsql="SELECT*FROMstu_empWHEREdeptno=10";ResultSetrs=stmt.executeQuery(sql);while(rs.next()){System.out.println(rs.getInt("empno")+""+rs.getString("ename")+""+rs.getString("job"));}rs.close();stmt.close();}catch(SQLExceptione){e.printStackTrace();}finally{try{if(cn!=null){cn.close();}}catch(SQLExceptione2){e2.printStackTrace();}}}}這是通過preparedstatement實現(xiàn)更新數(shù)據(jù),這里我把連接數(shù)據(jù)庫的方法進(jìn)行了封裝,每次直接調(diào)用了。publicstaticvoidmain(String[]args){PreparedStatementDemopsd=newPreparedStatementDemo();psd.updateSalary("JACOB",3000);psd.selectSalary("JACOB");}publicvoidupdateSalary(Stringename,doublesal){Stringsql="Updatestu_empsetsal=?Whereename=?";Connectioncn=null;PreparedStatementps=null;try{cn=DBPUtil.getConnection();ps=cn.prepareStatement(sql);ps.setDouble(1,sal);ps.setString(2,ename);intnum=ps.executeUpdate();System.out.println("提示:總共有"+num+"條數(shù)據(jù)已經(jīng)更新!");}catch(SQLExceptione){e.printStackTrace();}finally{DBUtil.stmtClose(ps);DBUtil.connClose(cn);}}publicvoidselectSalary(Stringname){Stringsql="Select*Fromstu_empWhereename=?";Connectioncn=null;PreparedStatementps=null;ResultSetrs=null;try{cn=DBPUtil.getConnection();ps=cn.prepareStatement(sql);ps.setString(1,name);rs=ps.executeQuery();while(rs.next()){System.out.println(rs.getString("ename")+"的工資是:"+rs.getInt("sal"));}}catch(SQLExceptione){e.printStackTrace();}finally{DBUtil.stmtClose(ps);DBUtil.rsClose(rs);DBUtil.connClose(cn);}}}
新聞名稱:java代碼查存儲過程,java實現(xiàn)存儲過程
當(dāng)前地址:http://jinyejixie.com/article32/dssegpc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供小程序開發(fā)、品牌網(wǎng)站制作、自適應(yīng)網(wǎng)站、定制網(wǎng)站、搜索引擎優(yōu)化、企業(yè)網(wǎng)站制作
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)