本站源码全部测试通过,配有前台及后台演示图,绿色安全,希望能对大家有所帮助!
  • 收藏本站
  • 网站地图
  • 发布源码
  • 首 页
  • app源码
  • 小程序源码
  • VPS/云主机
  • Spring boot调用Oracle存储过程的两种方式及完整代码
    时间:2020-08-19 14:05:30来源:模板之家 作者:转载大师 下载:42627 次

    box-sizibox-sizing: border-box; border: 0px; margin-top: 10px; margin-bottom: 10px; padding: 0px; -webkit-font-smoothing: antialiased; font-size: 18px; font-family: "Microsoft YaHei", Arial, Verdana, Tahoma, sans-serif; vertical-align: baseline; background: rgb(255, 255, 255); line-height: 32px; color: rgb(85, 85, 85); white-space: normal;>前言

    因工作需要将公司SSH项目改为Spingboot项目网站源码,将项目中部分需要调用存储过程的部分用entityManagerFactory.unwrap(SessionFactory.class).openSession()来获取Session实现后发现项目访问数据库超过十次就会挂掉,原因是Springboot连接池数量默认为10,猜测是每次访问数据库后连接未释放导致的,手动关闭session后问题解决。

    解决问题的过程中又发现了另外两种调用方式:

    • 直接用EntityManager的createStoredProcedureQuery()方法调用 (推荐)

    • 通过如下方式获取Session来调用,这种方式不需要手动关闭Session来释放连接,具体原因我也没搞明白,有知道的朋友欢迎指点

    Session session = entityManager.unwrap(Session.class);

    完整代码

    package com.hzjd.produre.repository;
     
    import javax.persistence.EntityManager;
    import javax.persistence.EntityManagerFactory;
    import javax.persistence.ParameterMode;
    import javax.persistence.PersistenceContext;
    import javax.persistence.StoredProcedureQuery;
     
    import org.hibernate.Session;
    import org.hibernate.SessionFactory;
    import org.hibernate.procedure.ProcedureCall;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Repository;
     
    import com.hzjd.produre.bean.QueryResponse;
    import com.hzjd.produre.utils.Assistant;
     
    @Repository
    public class ProdureDAO {
    public final static String PUBLIC_PAG_SYS_GETNEXTID = PUBLIC_PAG.SYS_GETNEXTID;
    public final static String PSBC_QUERYBILL = PSBCPAY.QUERYBILL;
    @PersistenceContext
    EntityManager entityManager;
    @Autowired
    EntityManagerFactory entityManagerFactory;
     
    public Session getSession() {
    return entityManagerFactory.unwrap(SessionFactory.class).openSession();
    }
     
    /**
    * 使用entityManager调用存储过程
    *
    * @param pay_ID
    * @return
    */
    public QueryResponse queryBill1(String pay_ID) throws Exception {
    QueryResponse queryResponse = new QueryResponse();
    StoredProcedureQuery call = entityManager.createStoredProcedureQuery(PSBC_QUERYBILL);
    call.registerStoredProcedureParameter(1, String.class, ParameterMode.IN).setParameter(1, pay_ID);
    call.registerStoredProcedureParameter(2, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(3, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(4, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(5, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(6, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(7, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(8, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(9, String.class, ParameterMode.OUT);
    call.registerStoredProcedureParameter(10, String.class, ParameterMode.OUT);
    call.execute();
    queryResponse.getBody().setPAY_ID(pay_ID);
    queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputParameterValue(2)));
    queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputParameterValue(3)));
    queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputParameterValue(5)));
    queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputParameterValue(6)));
    queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputParameterValue(8)));
    int errorcode = Assistant.nullToInt(call.getOutputParameterValue(9));
    String errormsg = Assistant.nullToEmpty(call.getOutputParameterValue(10));
    if (errorcode == 0) {
    return queryResponse;
    } else {
    throw new Exception(errormsg);
    }
    }
     
    /**
    * 使用sessionFactory开启Session调用存储过程
    *
    * @param pay_ID
    * @return
    */
    public QueryResponse queryBill2(String pay_ID) throws Exception {
    QueryResponse queryResponse = new QueryResponse();
    // 调用完成后需关闭Session否则会出现连接失效
    try (Session session = getSession();) {
    ProcedureCall call = session.createStoredProcedureCall(PSBC_QUERYBILL);
    call.registerParameter(1, String.class, ParameterMode.IN).bindValue(pay_ID);
    call.registerParameter(2, String.class, ParameterMode.OUT);
    call.registerParameter(3, String.class, ParameterMode.OUT);
    call.registerParameter(4, String.class, ParameterMode.OUT);
    call.registerParameter(5, String.class, ParameterMode.OUT);
    call.registerParameter(6, String.class, ParameterMode.OUT);
    call.registerParameter(7, String.class, ParameterMode.OUT);
    call.registerParameter(8, String.class, ParameterMode.OUT);
    call.registerParameter(9, String.class, ParameterMode.OUT);
    call.registerParameter(10, String.class, ParameterMode.OUT);
    queryResponse.getBody().setPAY_ID(pay_ID);
    queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(2)));
    queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(3)));
    queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(5)));
    queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(6)));
    queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(8)));
    int errorcode = Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
    String errormsg = Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
    if (errorcode == 0) {
    return queryResponse;
    } else {
    throw new Exception(errormsg);
    }
    }
    }
     
    /**
    * 使用sessionFactory开启Session调用存储过程
    *
    * @param pay_ID
    * @return
    */
    public QueryResponse queryBill3(String pay_ID) throws Exception {
    QueryResponse queryResponse = new QueryResponse();
    Session session = entityManager.unwrap(Session.class);
    ProcedureCall call = session.createStoredProcedureCall(PSBC_QUERYBILL);
    call.registerParameter(1, String.class, ParameterMode.IN).bindValue(pay_ID);
    call.registerParameter(2, String.class, ParameterMode.OUT);
    call.registerParameter(3, String.class, ParameterMode.OUT);
    call.registerParameter(4, String.class, ParameterMode.OUT);
    call.registerParameter(5, String.class, ParameterMode.OUT);
    call.registerParameter(6, String.class, ParameterMode.OUT);
    call.registerParameter(7, String.class, ParameterMode.OUT);
    call.registerParameter(8, String.class, ParameterMode.OUT);
    call.registerParameter(9, String.class, ParameterMode.OUT);
    call.registerParameter(10, String.class, ParameterMode.OUT);
    queryResponse.getBody().setPAY_ID(pay_ID);
    queryResponse.getBody().setCUSTNAME(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(2)));
    queryResponse.getBody().setHOME_ADDR(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(3)));
    queryResponse.getBody().setTRAN_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(5)));
    queryResponse.getBody().setTOTAL_AMT(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(6)));
    queryResponse.getBody().setBALANCE(Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(8)));
    int errorcode = Assistant.nullToInt(call.getOutputs().getOutputParameterValue(9));
    String errormsg = Assistant.nullToEmpty(call.getOutputs().getOutputParameterValue(10));
    if (errorcode == 0) {
    return queryResponse;
    } else {
    throw new Exception(errormsg);
    }
    }
    }


    转载请注明来源:Spring boot调用Oracle存储过程的两种方式及完整代码
    本文永久链接地址:bencandy.php?fid=32&id=12286
    本文标签:

    版权声明:
    —— 本文内容由互联网用户自发贡献, 本站不拥有所有权, 不承担相关法律责任, 如果发现本站有涉嫌抄袭的内容, 欢迎发送邮件至 :
    —— 1034252225@qq.com 举报, 并提供相关证据, 一经查实, 本站将立刻删除涉嫌侵权内容。

    QQ在线客服

    服务热线

    织梦建站咨询