IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 开发工具 -> mybatis指定数据源新增查询数据 -> 正文阅读

[开发工具]mybatis指定数据源新增查询数据

近期遇到特殊场景需要指定数据源进行数据新增查询操作。代码如下:

/**
 * 数据源配置
 *
 * @author lyc
 * @date 2022/03/10
 */
@Component
public class TempDbSource {
	//数据库连接相关配置  说明:项目中使用的Druid数据源所以需要这些配置信息
    @Value("${lyc.datasource.url}")
    private String url;
    @Value("${lyc.datasource.type}")
    private String type;
    @Value("${lyc.datasource.driver-class-name}")
    private String driverClass;
    @Value("${lyc.datasource.username}")
    private String username;
    @Value("${lyc.datasource.password}")
    private String password;
    @Value("${lyc.datasource.pwd-public-key}")
    private String pwdPublicKey;

    private SqlSessionTemplate sqlSessionTemplate;

    @PostConstruct
    public void init() throws Exception {
        DruidDataSource slaveDataSource = new DruidDataSource();
        slaveDataSource.setUrl(url);
        slaveDataSource.setDbType(type);
        slaveDataSource.setFilters("config");
        slaveDataSource.setDriverClassName(driverClass);
        slaveDataSource.setUsername(username);
        slaveDataSource.setPassword(password);
        slaveDataSource.setConnectionProperties("config.decrypt=true;config.decrypt.key=" + pwdPublicKey);

        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        // 扫描相关mapper文件
        PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
        // 说明:mapper文件地址,可以添加多个
        // Resource[] mapperLocations = ArrayUtil.addAll(resolver.getResources("classpath*:mapper/com/lyc/BizMapper.xml"),resolver.getResources("classpath*:mapper/com/lyc/BizMapper2.xml"));
        Resource[] mapperLocations = ArrayUtil.addAll(resolver.getResources("classpath*:mapper/com/lyc/BizMapper.xml"));
        
        sqlSessionFactoryBean.setMapperLocations(mapperLocations);
        // 调用dataSource
        sqlSessionFactoryBean.setDataSource(slaveDataSource);
        // 映射实体类  说明:com.lyc.entity 对应实体类的包路径
        sqlSessionFactoryBean.setTypeAliasesPackage("com.lyc.entity");
        SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBean.getObject();
        sqlSessionTemplate = new SqlSessionTemplate(sqlSessionFactory);
    }

    public SqlSessionTemplate getSqlSessionTemplate() {
        return sqlSessionTemplate;
    }
}

业务service及实现:

/**
 * Service 接口
 * 
 * @author lyc
 * @date 2022/03/10
 */
public interface BizService {

    /**
     * 查询列表
     *
     * @param queryVo
     * @return
     */
    List<ModuleBean> listTestDatas(QueryVo queryVo);

    /**
     * 批量保存数据
     * 
     * @param list
     */
    void insertBatch(List<ModuleBean> list);
}



/**
 * serviceImpl
 *
 * @author lyc
 * @date 2022/03/10
 */
@Service
public class BizServiceImpl implements BizService {

    @Autowired
    private TempDbSource tempDbSource;**//这里就是自己加的数据源配置类**

    @Override
    public List<ModuleBean> listTestDatas(QueryVo queryVo) {
    	//这里的com.lyc.dao.BizDao.listTestDatas就是BizDao的包路径及对应要调用的接口方法
        return tempDbSource.getSqlSessionTemplate().selectList("com.lyc.dao.BizDao.listTestDatas", queryVo);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void insertBatch(List<ModuleBean> list) {
        tempDbSource.getSqlSessionTemplate().insert("com.lyc.dao.BizDao.insertBatch", list);
    }
}

BizDao接口:

/**
 * Dao
 *
 * @author lyc
 * @date 2022/03/10
 */
public interface BizDao {
    /**
     * 查询列表
     *
     * @param queryVo
     * @return
     */
    List<ModuleBean> listTestDatas(QueryVo queryVo);

    /**
     * 批量保存数据
     * 
     * @param list
     */
    void insertBatch(List<ModuleBean> list);
}

对应的BizMapper.xml文件(这个文件就是数据源配置类中扫描的mapper文件):

<?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.lyc.BizDao">
    <resultMap id="BaseResultMap" type="com.lyc.entity.ModuleBean"/>
    
    <!--查询列表-->
    <select id="listTestDatas" parameterType="com.lyc.vo.QueryVo" resultMap="BaseResultMap">
        SELECT
        id,name,age
        FROM
        test_module_bean_table
        <where>
            <if test="name!= null and name!= '' ">
                AND name=#{name}
            </if>
        </where>
    </select>

    <!--批量保存数据-->
    <insert id="insertBatch" parameterType="com.lyc.entity.ModuleBean">
        insert into test_module_bean_table(name,age,create_time,create_by) values
        <foreach collection="list" item="item" separator=",">
            (#{item.name},#{item.age},now(),'sys_test')
        </foreach>
    </insert>
</mapper>

ArrayUtil工具类的方法:

public static <T> T[] addAll(T[]... arrays) {
        if (arrays.length == 1) {
            return arrays[0];
        }

        int length = 0;
        for (T[] array : arrays) {
            if (array == null) {
                continue;
            }
            length += array.length;
        }
        T[] result = newArray(arrays.getClass().getComponentType().getComponentType(), length);

        length = 0;
        for (T[] array : arrays) {
            if (array == null) {
                continue;
            }
            System.arraycopy(array, 0, result, length, array.length);
            length += array.length;
        }
        return result;
    }


    public static <T> T[] newArray(Class<?> componentType, int newSize) {
        return (T[]) Array.newInstance(componentType, newSize);
    }

至此使用BizService调用接口方法就可以通过指定的数据源操作数据了。

  开发工具 最新文章
Postman接口测试之Mock快速入门
ASCII码空格替换查表_最全ASCII码对照表0-2
如何使用 ssh 建立 socks 代理
Typora配合PicGo阿里云图床配置
SoapUI、Jmeter、Postman三种接口测试工具的
github用相对路径显示图片_GitHub 中 readm
Windows编译g2o及其g2o viewer
解决jupyter notebook无法连接/ jupyter连接
Git恢复到之前版本
VScode常用快捷键
上一篇文章      下一篇文章      查看所有文章
加:2022-03-13 22:01:22  更:2022-03-13 22:02:06 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 6:40:46-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码