标签：Jdbc.Druid.Mybatis.Plus； 。

1、简介

项目工程中，集成数据库实现对数据的增晒改查管理，是最基础的能力，而对于这个功能的实现，其组件选型也非常丰富； 。

通过如下几个组件来实现数据库的整合； 。

Druid连接池 ：阿里开源的数据库连接池，并且提供 SQL 执行的监控能力； 。

MybatisPlus框架 ：基于Mybatis框架的增强工具包，可以用于简化持久层开发，显著的提高效率； 。

MySQL数据库 ：常用的关系型数据库组件，在案例中使用 Druid 组件来连接数据库； 。

2、工程搭建

1、工程结构

2、依赖管理

Druid连接池使用的是 1.2.18 版本；在 mybatis-plus 组件中依赖 mybatis 框架的 3.5.10 版本；MySQL本地环境是 5.7 版本，这里依赖包使用 8.0.19 版本； 。

                        
                          <!-- MySql数据库 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>
<!-- Druid组件 -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-3-starter</artifactId>
    <version>${druid-spring-boot.version}</version>
</dependency>
<!-- JDBC依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
    <version>${spring-boot.version}</version>
</dependency>
<!-- MybatisPlus组件 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>${mybatis-plus.version}</version>
</dependency>

                        
                      

3、Druid连接池

1、配置文件

有关于 Druid 连接池的可配置参数还有很多，可以参考源码中的描述或者官方案例，此处只提供部分常见的参数配置； 。

                        
                          spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      # 数据库
      url: jdbc:mysql://localhost:3306/boot-jdbc
      username: root
      password: 123456
      driver-class-name: com.mysql.cj.jdbc.Driver
      # 连接池-初始化大小
      initial-size: 10
      # 连接池-最大连接数
      max-active: 100
      # 最大等待时间
      max-wait: 60000
      # 连接池-最小空闲数
      min-idle: 10
      # 检测空闲连接
      test-while-idle: true
      # 最小空闲时间
      min-evictable-idle-time-millis: 300000

                        
                      

1.2 配置类

配置两个Bean对象，分别 DruidDataSource 类和 JdbcTemplate 类； 。

                        
                          @Configuration
public class DruidConfig {

    @Bean("dataSource")
    @ConfigurationProperties(prefix = "spring.datasource.druid")
    public DruidDataSource dataSource() {
        return new DruidDataSource();
    }

    @Bean("jdbcTemplate")
    public JdbcTemplate jdbcTemplate() {
        return new JdbcTemplate(dataSource());
    }
}

                        
                      

4、JDBC操作

1、数据库表

在 boot-jdbc 数据库中添加两张测试表，用户基础信息 tb_user 表和用户扩展信息 tb_user_extd 表，脚本文件在工程的 resources/sql-script 目录下； 。

                        
                          CREATE TABLE `tb_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键ID',
  `user_name` varchar(30) NOT NULL COMMENT '用户名称',
  `email` varchar(50) DEFAULT NULL COMMENT '邮件',
  `phone` varchar(20) NOT NULL COMMENT '手机号',
  `create_time` datetime DEFAULT NULL COMMENT '创建时间',
  `update_time` datetime DEFAULT NULL COMMENT '更新时间',
  `state` int(1) DEFAULT '1' COMMENT '状态：1启用，2删除',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户基础信息';

CREATE TABLE `tb_user_extd` (
  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键ID',
  `user_id` int(11) NOT NULL COMMENT '用户ID',
  `city_name` varchar(50) DEFAULT NULL COMMENT '城市名称',
  `school` varchar(200) DEFAULT NULL COMMENT '学校名称',
  PRIMARY KEY (`id`),
  KEY `user_id_index` (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户扩展信息';

                        
                      

2、JdbcTemplate

JdbcTemplate 是由 spring-jdbc 组件提供，支持 DataSource 的注册，是对数据库操作的深层封装，支持一系列数据操作方法； 。

                        
                          @Service
public class JdbcService {

    private static final Logger logger = LoggerFactory.getLogger(JdbcService.class);
    @Resource
    private JdbcTemplate jdbcTemplate ;

    /**
     * 添加数据
     */
    public int addData (User user){
        return jdbcTemplate.update(
                "INSERT INTO `tb_user` (`user_name`, `email`, `phone`, `create_time`, `update_time`) VALUES (?, ?, ?, ?, ?)",
                user.getUserName(),user.getEmail(),user.getPhone(),user.getCreateTime(),user.getUpdateTime());
    }
    /**
     * 查询全部
     */
    public List<User> queryAll (){
        return jdbcTemplate.query("SELECT * FROM tb_user WHERE state=1",new BeanPropertyRowMapper<>(User.class));
    }
    /**
     * 修改字段
     */
    public int updateName (Integer id,String name){
        return jdbcTemplate.update("UPDATE `tb_user` SET `user_name` = ? WHERE `id` = ?",name,id);
    }
    /**
     * 主键删除
     */
    public int deleteId (Integer id){
        return jdbcTemplate.update("DELETE FROM `tb_user` WHERE `id` = ?",id);
    }
}

                        
                      

5、MybatisPlus框架

1、配置管理

1.1 配置类 。

在配置类中，添加 MapperScan 注解用来扫描和注册MyBatis框架的 mapper 接口，以及设置 PaginationInnerInterceptor 分页拦截器； 。

                        
                          @Configuration
@MapperScan("com.boot.jdbc.mapper")
public class MybatisConfig {

    /**
     * 分页
     */
    @Bean
    public MybatisPlusInterceptor paginationInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
        return interceptor;
    }
}

                        
                      

1.2 配置文件 。

在日志中输出 mybatis 框架解析的SQL语句，方便在测试的时候快速发现问题； 。

                        
                          mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

                        
                      

2、Mapper

Mapper 接口编写数据库操作方法， Mapper.xml 文件中定义数据库执行的 SQL 语句，在 mybatis-plus 组件中提供很多单表操作的默认方法实现，也可以自定义方法； 。

2.1 Mapper接口 。

                        
                          public interface UserMapper extends BaseMapper<User> {

    /**
     * 自定义分页
     */
    IPage<UserModel> queryUserPage(@Param("page") IPage<User> page);
}

                        
                      

2.2 Mapper文件 。

                        
                          <mapper namespace="com.boot.jdbc.mapper.UserMapper">
    <select id="queryUserPage" resultType="com.boot.jdbc.entity.UserModel">
        SELECT
            tb1.id userId,
            tb1.user_name userName,
            tb1.email,
            tb1.phone,
            tb1.create_time createTime,
            tb1.update_time updateTime,
            tb1.state,
            tb2.school,
            tb2.city_name cityName
        FROM tb_user tb1
        LEFT JOIN tb_user_extd tb2 ON tb1.id = tb2.user_id
        WHERE tb1.state='1'
        ORDER BY tb1.id DESC
    </select>
</mapper>

                        
                      

3、单元测试

编写 UserMapper 接口测试，很多默认实现的方法参考 BaseMapper 接口即可，或者参考 IService 接口和 ServiceImpl 实现类，提供了更加丰富的扩展方法； 。

                        
                          public class UserMapperTest {

    @Resource
    private UserMapper userMapper ;

    @Test
    public void testInsert (){
        List<User> userBatch = Arrays.asList(
                new User(null,"Zhang三","Zhang@qq.com","18623459687",new Date(),new Date(),1));
        userBatch.forEach(userMapper::insert);
    }

    @Test
    public void testUpdate (){
        User user = userMapper.selectById(1);
        user.setState(2);
        userMapper.updateById(user);
    }
    
    @Test
    public void testDelete (){
        userMapper.deleteById(7);
    }
    
    @Test
    public void testQuery (){
        List<User> userColumnsList = new LambdaQueryChainWrapper<>(userMapper)
                .select(User::getUserName,User::getPhone,User::getEmail)
                .like(User::getPhone,"189").orderByDesc(User::getId).last("limit 2").list();
        userColumnsList.forEach(System.out::println);
    }

    @Test
    public void testPage (){
        // 1、默认分页查询
        IPage<User> userPage = new Page<>(2,2) ;
        IPage<User> userPageList = userMapper.selectPage(userPage,new QueryWrapper<>());
        userPageList.getRecords().forEach(System.out::println);

        // 2、自定义查询分页
        IPage<UserModel> userModelPage = userMapper.queryUserPage(userPage);
        userModelPage.getRecords().forEach(System.out::println);
    }
}

                        
                      

6、参考源码

                        
                          文档仓库：
https://gitee.com/cicadasmile/butte-java-note

源码仓库：
https://gitee.com/cicadasmile/butte-spring-parent

                        
                      

最后此篇关于SpringBoot3数据库集成的文章就讲到这里了,如果你想了解更多关于SpringBoot3数据库集成的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。