SpringBoot中使用Mybatis调用Oracle存储过程

古城微笑少年丶 2024-03-30 14:23 35阅读 0赞

#### 文章目录 ####

*  SpringBoot中使用Mybatis调用Oracle存储过程
 *   *  1. 添加Maven依赖
     *  2. Yaml中配置好Db、Mybatis相关配置
     *  3. 测试的 entity实体类
     *  4. Mapper(Dao)接口
     *  5. GyBrjbxxkDao.xml
     *  6. Oracle中的存储过程
     *  7. 测试类Mybatisplus\_OracleProcedure\_自测通过

## SpringBoot中使用Mybatis调用Oracle存储过程 ##

### 1. 添加Maven依赖 ###

<dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus-boot-starter</artifactId>
        <version>3.3.1</version>
    </dependency>
    
    <dependency>
        <groupId>com.oracle</groupId>
        <artifactId>ojdbc6</artifactId>
        <version>11.2.0.3</version>
    </dependency>

### 2. Yaml中配置好Db、Mybatis相关配置 ###

# 比如Oracle连接配置：   
    spring:
    	datasource:
    		url: jdbc:oracle:thin:@127.0.0.1:1521/orcl
    		username: system
    		password: 123456
    		driver-class-name: oracle.jdbc.OracleDriver

# 比如Mybatis相关配置
    # 	配置mysqlplus生成的Sql打印到控制台，用于观察Sql的实际情况
    # 	mybatis-plus:
    #  configuration:
    #    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    mybatis-plus: # 配置mybaitis-plus，关闭自动驼峰命名规则映射
      configuration:
        map-underscore-to-camel-case: false
      # 配置Mybatis-Plus自定义分Mappe.xml路径
      mapper-locations: classpath*:/mapper/**/*.xml
      # 配置entity实体对象的包路径，这样mapper.xml可以不用带包名
      type-aliases-package: com.mediinfo.entity
    # 配置全局的实体类ID生成策略 ，插入数据时，ID自增  Oracle通过序列策略，此处无需开启
    #  global-config:
    #    db-config:
    #      id-type: auto

### 3. 测试的 entity实体类 ###

// gy_brjbxxk 表结构，这里就不创建了，参考下方实体的属性，随便建两个字段，就可以模拟出来啦
    @SuppressWarnings("serial")
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    @ApiModel("人员信息")
    public class GyBrjbxxk extends Model<GyBrjbxxk> {
        
        /* 就诊卡号 */
        @TableId(value = "JZKH")
        @ApiModelProperty(value = "就诊卡号")
        private String jzkh;
        /* 姓名 */
        @ApiModelProperty(value = "姓名")
        private String xm;
        /* 性别 */
        @ApiModelProperty(value = "性别")
        private String xb;
       
        /**
         * 获取主键值
         *
         * @return 主键值
         */
        @Override
        protected Serializable pkVal() {
        
            return this.jzkh;
        }
    }

### 4. Mapper(Dao)接口 ###

@Mapper
    public interface GyBrjbxxkDao extends BaseMapper<GyBrjbxxk> {
        
    
        // 调用oracle存储过程返回单个结果集
        void findDeptNameById(Map<String,Object> map);
    
        // 调用oracle存储过程返回多个结果集
        void findAllDeptProcedure(Map<String,Object> map);
    }

### 5. GyBrjbxxkDao.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.mediinfo.dao.GyBrjbxxkDao">
    	
        <resultMap id="deptResultMap" type="com.mediinfo.entity.GyBrjbxxk">
    
    
    
    
        </resultMap>
    
        
        
        <select id="findDeptNameById" statementType="CALLABLE" parameterType="map">
            
            <![CDATA[
           {call  findDeptNameById(
                        #{deptNo,mode=IN,jdbcType=VARCHAR},
                        #{d_Name,mode=OUT,jdbcType=VARCHAR}
                    )}
           ]]>
        </select>
    
        
        <select id="findAllDeptProcedure" statementType="CALLABLE">
            <![CDATA[
                call findAllDeptProcedure(
                    #{deptList, mode=OUT,jdbcType=CURSOR,javaType=ResultSet,resultMap=deptResultMap})
            ]]>
        </select>
    
    </mapper>

### 6. Oracle中的存储过程 ###

-- Oracle用户下创建该存储 过程，用于下方测试用
     --  测试过程1 -- 入参、出参    调用oracle存储过程返回单个结果集
        create or replace procedure findDeptNameById(v_deptno in  String, v_dname out String) is
        begin
        	-- 返回单个字符串，取出赋给出参v_dname即可
        	select xm into v_dname  from gy_brjbxxk where jzkh = v_deptno;
        end findDeptNameById;
    
     --   测试过程2 -- 调用oracle存储过程返回多个结果集
        create or replace procedure findAllDeptProcedure(v_dept out sys_refcursor) is
        begin
        	-- 直接将select *查询的所有数据，赋值给返回游标v_dept
        	open v_dept for select * from gy_brjbxxk where rownum <= 100;
        end findAllDeptProcedure;

### 7. 测试类Mybatisplus\_OracleProcedure\_自测通过 ###

package com.mediinfo.healthtzplatform;
    
    import com.alibaba.fastjson.JSONArray;
    import com.mediinfo.dao.GyBrjbxxkDao;
    import com.mediinfo.entity.GyBrjbxxk;
    import org.junit.jupiter.api.Test;
    import org.springframework.boot.test.context.SpringBootTest;
    
    import javax.annotation.Resource;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    @SpringBootTest
    class Mybatisplus_OracleProcedure {
        
    
        @Resource
        GyBrjbxxkDao gyBrjbxxkDao;
    
        // 参考链接： https://blog.csdn.net/qq_45297578/article/details/121136233
        // Oracle存储过程调用  注意：  过程名区分大小写！！！
        @Test
        public void testFindDeptNameById() {
        
            HashMap<String, Object> map = new HashMap<>();
            // 这里的deptNo和 GyBrjbxxkDao.xml中定义的名称 一致！
            map.put("deptNo","A10014599");
            gyBrjbxxkDao.findDeptNameById(map);
            // 取得返回的内容，其实只要存储过程执行后， map里就有值了
            //		d_Name和Mapper.xml中的变量名一致
            System.out.println(map.get("d_Name"));
        }
    
        /**
         * 测试: 调用oracle存储过程返回多个结果集
         */
        @Test
        public void testFindAllDeptProcedure() {
        
    		// 因该存储过程没有入参，故new个Map传入即可，方法执行后， 再通过该Map取出返回值
            Map<String, Object> param = new HashMap<String, Object>();
            gyBrjbxxkDao.findAllDeptProcedure(param);
    
    		// 取出返回的结果集，这里变量名“deptList” 和 GyBrjbxxkDao.xml中定义的名称 一致！
            List<GyBrjbxxk> list = (List<GyBrjbxxk>) param.get("deptList");
    
            // 返回结果转JsonArr
            JSONArray jsonArray = (JSONArray) JSONArray.toJSON(list);
            System.out.println(jsonArray);
        }
    }