码迷,mamicode.com
首页 > 编程语言 > 详细

Java调用存储过程

时间:2019-02-14 09:12:53      阅读:119      评论:0      收藏:0      [点我收藏+]

标签:begin   tst   encoding   strong   int   client   xxx   this   factor   

Java调用存储过程

public static void main(String[] args ){
    String driver = "oracle.jdbc.driver.OracleDriver";
    String strUrl = "jdbc:oracle:thin:@127.0.0.1:1521:hyq";
    Statement stmt = null;
    ResultSet rs = null;
    Connection conn = null;
    try {
      Class.forName(driver);
      conn = DriverManager.getConnection(strUrl, "hyq", "hyq");
      CallableStatement proc = null;
      proc = conn.prepareCall("{ call hyq.testc(?) }");
      proc.registerOutParameter(1,oracle.jdbc.OracleTypes.CURSOR);
      proc.execute();
      rs = (ResultSet)proc.getObject(1);
      while(rs.next())
     

 

  1. //调用存储过程 删除流程相关记录  
  2.             String procdure = "{Call sp_deleteInstByRootID(?)}";  
  3.             CallableStatement cs = this.getHibernateTemplate().getSessionFactory().getCurrentSession().connection().prepareCall(procdure);  
  4.             //this.getSession().connection().prepareCall(procdure).setString(0, orgdefid);  
  5.             cs.setString(1, procinstid);  
  6.             cs.execute();  

   

 

 

 

ibatis配置文件:

 

复制代码

<parameterMap id="parameterMapCesu" class="java.util.Map"> 

    <!-- 参数 --> 

    <parameter property="cesuDate" jdbcType="VARCHAR2"  javaType="java.lang.String" mode="IN" /> 

    <parameter property="csCount" jdbcType="DOUBLE" javaType="java.lang.Long" mode="OUT"/>

</parameterMap> 

<!-- 调用存储过程--> 

<procedure id="cesu" parameterMap="parameterMapCesu">  

    {call handiwork(?,?)}          

</procedure>

Java代码

public Long doTest(final String cesuDate) {
    return (Long) this.getSqlMapClientTemplate().execute(new SqlMapClientCallback() {
        @SuppressWarnings("unchecked")
        public Object doInSqlMapClient(SqlMapExecutor executor)
                throws SQLException {
            long csCount = 0;
            try {   
                //设置存储过程参数
                Map cesu = new HashMap();
                cesu.put("cesuDate", cesuDate);//输入参数
                cesu.put("csCount", 0);//输出参数
                //调用存储过程
                executor.queryForObject("test.cesu",cesu);//ibatis文件的namespace是test
                csCount = (Long)cesu.get("csCount");//获取返回值   
                return csCount;
            } catch (Exception e) {   
                e.printStackTrace();   
                return null;
            } 
        }
    });
}

 

 

hibernate中调用存储过程

  1. /** 
  2.  * 直接调用存储过程 
  3.  * @param procString 
  4.  * @author kongqz 
  5.  * @throws Exception  
  6.  * @date 2009-03-03 
  7.  * **/  
  8. public void callProcedure(String procString,List<Object> params) throws Exception {  
  9.     CallableStatement stmt = null;  
  10.     try {  
  11.         stmt = this.getSession().connection().prepareCall(procString);  
  12.         if (params != null){  
  13.             int idx = 1;  
  14.             for (Object obj : params) {  
  15.                 if (obj != null) {  
  16.                     stmt.setObject(idx, obj);  
  17.                 } else {  
  18.                     stmt.setNull(idx, Types.NULL);  
  19.                 }  
  20.                 idx++;  
  21.             }  
  22.         }  
  23.         stmt.execute();  
  24.     } catch (SQLException e) {  
  25.         e.printStackTrace();  
  26.         throw new Exception("调用存储过程的时候发生错误[sql = " + procString + "]", e);  
  27.           
  28.     }  
  29. }  

tx = session.beginTransaction();
Connection con=session.connection();

String procedure = "{call batchUpdateStudent(?) }";
CallableStatement cstmt = con.prepareCall(procedure);
cstmt.setInt(1,0); //把年龄参数设为0
cstmt.executeUpdate();
tx.commit();

spring调用存储过程

1.继承StoredProcedure

org.springframework.jdbc.object.StoredProcedure是对应存储过程调用的操作对象,它通过其父类

org.springframework.jdbc.object.SqlCall获得相应的底层API支持(CallableStatementCreator), 然

后在此基础之上构建了调用存储过程的执行方法。

2、重写父类的execute()方法。将存储过程的参数封装成Map类型的传入该方法

.
3、写一个方法来封装存储过程的方法及把参数放到Map里面.

如:
  Map paraMap = new HashMap();
  paraMap.put(IN_PARAMETER_NAME, tableName);
  paraMap.put(INOUT_PARAMETER_NAME, v);
注意:key值一定要与前面构造函数里面声明的参数一致。


4、execute()返回的map值要取到里面的value值,可以用前面构造函数声明时候用到的key值去取。
  如:(String)resultMap.get(OUT_PARAMETER_NAME);就得到了存储过程的返回值。

示例如下:

public class xxxxProcedure extends StoredProcedure {
    private static final String PROCEDURE_NAME = "xxxx";

    protected xxxxProcedure() {
        /* empty */
        }
    
    public xxxxProcedure(JdbcTemplate jdbcTemplate) {
        super(jdbcTemplate, PRO_NAME);
        declareParameter(new SqlParameter("xxxx", Types.VARCHAR));
        declareParameter(new SqlParameter("xxxx", Types.VARCHAR));
        declareParameter(new SqlParameter("xxxx", Types.NUMERIC));
    }

    public void execute(String xxxx,String xxxx,int xxxx) {
        Map<String, Object> paramsIn = new HashMap<String, Object>();
        paramsIn.put("xxxx", xxxx);
        paramsIn.put("xxxx", xxxx);
        paramsIn.put("xxxx", xxxx);
        super.execute(paramsIn);
    }

}

在mybatis中调用存储过程,然后获取该结果集:

1、xml配置文件

<?xml version="1.0" encoding="UTF-8" ?>  
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.ifeng.iis.bean.iis.Report" >
 <resultMap type="java.util.HashMap" id="resultMap">
      <result column="id" property="id" javaType="java.lang.Integer" jdbcType="INTEGER"/>
      <result column="name" property="name" javaType="java.lang.String" jdbcType="VARCHAR"/>
      <result column="repDate" property="repDate" javaType="java.lang.String" jdbcType="VARCHAR"/>
      <result column="summ" property="summ" javaType="java.lang.Long" jdbcType="BIGINT"/>
    </resultMap>
    
 <select id="test123" parameterType="java.util.Map"  resultMap="resultMap" statementType="CALLABLE" >  
      {call pro_sql_data(
      #{obj,jdbcType=VARCHAR,mode=IN}
    )
      }
    </select>  
</mapper>

Java代码

public String query(String param) throws Exception {
  logger.info(param);
  Map queryMap = new HashMap();
  queryMap.put("obj", param);
  //List<Map> listIis1 = reportDao.select4MapParam(queryMap, "currentSql");
  
  List<Map> listIis2 =reportDao.select4MapParam(queryMap,"test123");
  
  return JSONArray.fromObject(listIis2).toString();
 }

 

Java调用存储过程

标签:begin   tst   encoding   strong   int   client   xxx   this   factor   

原文地址:https://www.cnblogs.com/heartwarming/p/10372690.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!