0
点赞
收藏
分享

微信扫一扫

java调用存储过程(jdbc & hibernate)


 

一、JDBC调用存储过程

creat proc proc_select

  @pid varchar(20)

  @address varchar(20) output

  as

  select @address=address from userinfo where pid=@pid

  go

  用java调用:

 

class.forName(/"sun.jdbc.odbc.JdbcOdbcDriver/"); //加载驱动 

   Connection con=DriverManager.getConnection(/"Jdbc:Odbc:test/",/"sa/",/"/"); //获得连接 

   String call=/"{call proc_select(?,?)};/" //调用语句 

   CallableStatement proc=con.preparecall(call); //调用存储过程 

   proc.setString(1,/"12345678/"); //给输入参数传值 

   proc.registerOutParameter(2,Type.varchar); //声明输出参数是什么类型的 

   proc.execute(); //执行 

   String address=proc.getString(2); //获得输出参数



  java调用存储过程

  存储过程可以有返回值,所以CallableStatement类有类似getResultSet这样的方法来获取返回值。当存储过程返回一个值时,你必须使用registerOutParameter方法告诉JDBC驱动器该值的SQL类型是什么。你也必须调整存储过程调用来指示该过程返回一个值。

  下面接着上面的例子。这次我们查询Dylan Thomas逝世时的年龄。这次的存储过程使用PostgreSQL的pl/pgsql:

 

create function snuffed_it_when (VARCHAR) returns integer ’declare 

   poet_id NUMBER; 

   poet_age NUMBER; 

   begin 

   --first get the id associated with the poet. 

   SELECT id INTO poet_id FROM poets WHERE name = $1; 

   --get and return the age. 

   SELECT age INTO poet_age FROM deaths WHERE mort_id = poet_id; [Page] 

   return age; 

   end;’ language ’pl/pgsql’;


  另外,注意pl/pgsql参数名通过Unix和DOS脚本的$n语法引用。同时,也注意嵌入的注释,这是和Java代码相比的另一个优越性。在Java中写这样的注释当然是可以的,但是看起来很凌乱,并且和SQL语句脱节,必须嵌入到Java String中。

  下面是调用这个存储过程的Java代码:

connection.setAutoCommit(false); 

   CallableStatement proc = connection.prepareCall(/"{ ? = call snuffed_it_when(?) }/"); 

   proc.registerOutParameter(1, Types.INTEGER); 

   proc.setString(2, poetName); 

   cs.execute(); 

   int age = proc.getInt(2);



  如果指定了错误的返回值类型会怎样?那么,当调用存储过程时将抛出一个RuntimeException,正如你在ResultSet操作中使用了一个错误的类型所碰到的一样。

  复杂的返回值

  关于存储过程的知识,很多人好像就熟悉我们所讨论的这些。如果这是存储过程的全部功能,那么存储过程就不是其它远程执行机制的替换方案了。存储过程的功能比这强大得多。

  当你执行一个SQL查询时,DBMS创建一个叫做cursor(游标)的数据库对象,用于在返回结果中迭代每一行。ResultSet是当前时间点的游标的一个表示。这就是为什么没有缓存或者特定数据库的支持,你只能在ResultSet中向前移动。

  某些DBMS允许从存储过程中返回游标的一个引用。JDBC并不支持这个功能,但是Oracle、PostgreSQL和DB2的JDBC驱动器都支持在ResultSet上打开到游标的指针(pointer)。

  设想列出所有没有活到退休年龄的诗人,下面是完成这个功能的存储过程,返回一个打开的游标,同样也使用PostgreSQL的pl/pgsql语言:

 

create procedure list_early_deaths () return refcursor as ’declare toesup refcursor; 

   begin 

   open toesup for SELECT poets.name, deaths.age FROM poets, deaths 

   -- all entries in deaths are for poets. -- but the table might become generic. 

   WHERE poets.id = deaths.mort_id AND deaths.age < 60; 

   return toesup; 

   end;’ language ’plpgsql’;



  下面是调用该存储过程的Java方法,将结果输出到PrintWriter:

 

PrintWriter: 

   static void sendEarlyDeaths(PrintWriter out){ 

   Connection con = null;



二、Hibernate调用存储过程

Java代码

1.CREATE   TABLE  `proctab` (   
 2.`id`  int ( 11 )  NOT   NULL  auto_increment,   
 3.`Name`  varchar ( 20 ),   
 4.`age`  int ( 11 ),   
 5.PRIMARY   KEY   (`id`)   
 6.)  
 CREATE   TABLE  `proctab` (
 `id`  int ( 11 )  NOT   NULL  auto_increment,
 `Name`  varchar ( 20 ),
 `age`  int ( 11 ),
 PRIMARY   KEY   (`id`)
 )


简单的存储过程

Java代码

1.create   PROCEDURE  proc()   
 2. begin   
 3.    select   *   from  proctab;   
 4. end ;   
 create   PROCEDURE  proc()
  begin
     select   *   from  proctab;
  end ;



一种方法是通过hibernate传统的xml映射方式去调用

Java代码

1.<class name="com.test.User" table="proctab">   
 2.        <id name="id" column="id">   
 3.            <generator class="native"/>   
 4.        </id>   
 5.        <property name="name" column="name" type="string" />   
 6.        <property name="age" column="age" type="integer" />   
 7.</class>   
 8.   <sql-query name="getUser" callable="true">   
 9.     <return alias="user" class="com.test.User">   
 10.     <return-property name="id" column="id" />   
 11.     <return-property name="name" column="name" />   
 12.     <return-property name="age" column="age" />   
 13.     </return>   
 14.     {call proc()}   
 15.   </sql-query>  
 <class name="com.test.User" table="proctab">
         <id name="id" column="id">
             <generator class="native"/>
         </id>
         <property name="name" column="name" type="string" />
         <property name="age" column="age" type="integer" />
 </class>
    <sql-query name="getUser" callable="true">
      <return alias="user" class="com.test.User">
      <return-property name="id" column="id" />
      <return-property name="name" column="name" />
      <return-property name="age" column="age" />
      </return>
      {call proc()}
    </sql-query>



调用方法

Java代码

1.Session ss= HibernateSessionFactory.getSession()   
 2.List li=ss.getNamedQuery("getUser").list();   
 3.ss.close();  
         Session ss= HibernateSessionFactory.getSession()
         List li=ss.getNamedQuery("getUser").list();
         ss.close();



及其类似jdbc的方法

Java代码

1.Session session =HibernateSessionFactory.getSession();    
 2.Connection conn = session.connection();    
 3.ResultSet rs =null;   
 4.CallableStatement call = conn.prepareCall("{Call proc()}");   
 5.rs = call.executeQuery();   
 6.rs.close();   
 7.session.close();  
 Session session =HibernateSessionFactory.getSession(); 
 Connection conn = session.connection(); 
 ResultSet rs =null;
 CallableStatement call = conn.prepareCall("{Call proc()}");
 rs = call.executeQuery();
 rs.close();
 session.close();



这种方法基本上就是jdbc,不过很简单,总是感觉怪怪的~!

还有就是通过强大的createSQLQuery来实现
o(∩_∩)o...哈哈  个人比较喜欢这种方法

Java代码

1.Session session =HibernateSessionFactory.getSession();    
 2.SQLQuery query = session.createSQLQuery("{Call proc()}");   
 3.List list =query.list();   
 4.session.close();  
 Session session =HibernateSessionFactory.getSession(); 
 SQLQuery query = session.createSQLQuery("{Call proc()}");
 List list =query.list();
 session.close();


如果没有返回值 直接用execute的方法就可以了
(*^__^*)  忘了一个重要的问题就是存储过程的传参问题

Java代码

1.CallableStatement call = conn.prepareCall("{Call proc(?)}");   
 2.call.setString(1, 参数);   
 3.rs = call.executeQuery();  
 CallableStatement call = conn.prepareCall("{Call proc(?)}");
 call.setString(1, 参数);
 rs = call.executeQuery();
 Java代码 
 1.SQLQuery query = session.createSQLQuery("{Call proc(?)}");   
 2.query.setString(0, 参数);   
 3.List list =query.list();


举报

相关推荐

0 条评论