Springboot——数据访问

一、SQL 1. 数据源的自动配置

数据源重在连接，配置连接属性，而连接池是数据源内实现的，也是为了高效连接而存在

1.1 导入JDBC场景

首先导入JDBC场景


    org.springframework.boot
    spring-boot-starter-data-jdbc

会根据依赖自动导入数据源、jdbc以及事务

导入数据库驱动

选择要导入的数据库驱动，版本统一

直接依赖引入具体版本（maven的就近依赖原则）



    mysql
    mysql-connector-java
    8.0.26

1.2 分析自动配置

DataSourceAutoConfiguration ：数据源的自动配置。
- 修改数据源相关的配置：spring.datasource
- 数据库连接池的配置：如果容器中没有数据源，就默认给你放一个。
- 底层配置好的连接池是：HikariDataSource
DataSourceTransactionManagerAutoConfiguration：事务管理器的自动配置
JdbcTemplateAutoConfiguration： JdbcTemplate的自动配置，可以来对数据库进行CRUD
- 可以修改前缀为spring.jdbc的配置项来修改JdbcTemplate
- @Bean @Primary JdbcTemplate：Spring容器中有这个JdbcTemplate组件，使用@Autowired
JndiDataSourceAutoConfiguration： JNDI的自动配置
XADataSourceAutoConfiguration：分布式事务相关的

1.3 修改配置项

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/fkddatabase
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver

1.4 测试

@Slf4j
@SpringBootTest
class BootAdminApplicationTests {
    //因为容器中注入了JdbcTemplate组件，所以可以自动注入
    @Autowired
    JdbcTemplate jdbcTemplate;

    @Test
    void contextLoads() {
        Long aLong = jdbcTemplate.queryForObject("select count(*) from emp", Long.class);
        log.info("总记录数是:{}", aLong);
    }
}

2. 使用Druid数据源 2.1 druid官方github地址

Druid是数据库连接池，它能够提供强大的监控和扩展功能

Druid官方github地址

Spring Boot整合第三方技术的两种方式：

自定义（自定义configuration类，参考配置文档@Bean组件）
找starter场景

2.2 使用官方starter的方式

官方文档 - Druid Spring Boot Starter

引入依赖：


    com.alibaba
    druid-spring-boot-starter
    1.1.17

分析自动配置（DruidDataSourceAutoConfigure）：

扩展配置项 spring.datasource.druid
自动配置类DruidDataSourceAutoConfigure
DruidSpringAopConfiguration.class, 监控SpringBean的；配置项：spring.datasource.druid.aop-patterns
DruidStatViewServletConfiguration.class, 监控页的配置。spring.datasource.druid.stat-view-servlet默认开启
DruidWebStatFilterConfiguration.class，web监控配置。spring.datasource.druid.web-stat-filter默认开启
DruidFilterConfiguration.class：所有Druid的filter的配置

private static final String FILTER_STAT_PREFIX = "spring.datasource.druid.filter.stat";
private static final String FILTER_CONFIG_PREFIX = "spring.datasource.druid.filter.config";
private static final String FILTER_ENCODING_PREFIX = "spring.datasource.druid.filter.encoding";
private static final String FILTER_SLF4J_PREFIX = "spring.datasource.druid.filter.slf4j";
private static final String FILTER_LOG4J_PREFIX = "spring.datasource.druid.filter.log4j";
private static final String FILTER_LOG4J2_PREFIX = "spring.datasource.druid.filter.log4j2";
private static final String FILTER_COMMONS_LOG_PREFIX = "spring.datasource.druid.filter.commons-log";
private static final String FILTER_WALL_PREFIX = "spring.datasource.druid.filter.wall";

配置示例：

具体配置项参照官方文档
DruidDataSource配置属性列表

spring:
  datasource:
    url: jdbc:mysql://localhost:3306/fkddatabase
    username: root
    password: 123456
    driver-class-name: com.mysql.cj.jdbc.Driver

    druid:
      aop-patterns: com.zju.admin.*  #监控SpringBean
      filters: stat,wall     # 底层开启功能，stat（sql监控），wall（防火墙）

      stat-view-servlet:   # 配置监控页功能
        enabled: true
        login-username: admin
        login-password: 123456
        resetEnable: false

      web-stat-filter:  # 监控web
        enabled: true
        urlPattern: 
    public Emp getEmp(@Param("name") String name);
}

sql映射文件





    
    
        select * from `result` where ename=#{name};

4. Service和Controller层

@Service
public class ResultService {

    @Autowired
    ResultMapper resultMapper;

    public Emp getEmpByName(String name){
        return resultMapper.getEmp(name);
    }
}

@Controller
public class IndexController {
    
    @Autowired
    ResultService resultService;

    @ResponseBody
    @RequestMapping("/emp/{empName}")
    public Emp getByName(@PathVariable("empName") String name){
        Emp emp = resultService.getEmpByName(name);
        return emp;
    }
}

总结：

导入mybatis官方starter
编写mapper接口。标准@Mapper注解
编写sql映射文件并绑定mapper接口
在application.yaml中指定Mapper配置文件的位置，以及指定全局配置文件的信息

3.2 注解模式

1.可以通过Spring Initializr添加MyBatis的Starter

2. 省去XXXmapper.xml，在接口上加注解

@Select("select * from `result` where sal>#{sal}")
public List getEmpBySal(@Param("sal") Double sal);

3.3 混合模式

实际开发中简单的CRUD可以写在注解上，复杂的业务用xml文件配置方式

ResultMapper

@Mapper
public interface ResultMapper {
    
    public Emp getEmp(@Param("name") String name);

    
    @Select("select * from `result` where sal>#{sal}")
    public List getEmpBySal(@Param("sal") Double sal);

    
    @Insert("insert into `result`(`ename`,`sal`) values(#{ename},#{sal}) ")
    @Options(useGeneratedKeys = true, keyProperty = "id")
    public void insertEmp(Emp emp);
}

ResultMapper.xml





    
    
        select * from `result` where ename=#{name}

3.4 最佳实战

引入mybatis-starter
配置application.yaml中，指定mapper-location位置即可

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/fkddatabase
    username: root
    password: 123456
# 配置mybatis规则
mybatis:
  mapper-locations: classpath:mybatis/mapper*.xml，这表示任意包的类路径下的所有mapper文件夹下任意路径下的所有xml都是sql映射文件。 建议以后sql映射文件放在 mapper下。

容器中也自动配置好了SqlSessionTemplate。
@Mapper 标注的接口也会被自动扫描，建议直接 @MapperScan("com.zju.admin.mapper")批量扫描

2. 配置数据源

在 application.yml 配置文件中添加mysql 数据库的相关配置

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/fkddatabase
    username: root
    password: 123456

在 Spring Boot 启动类中添加 @MapperScan 注解，扫描 Mapper 文件夹：

@MapperScan("com.zju.admin.mapper")
@SpringBootApplication
public class BootAdminApplication {

    public static void main(String[] args) {
        SpringApplication.run(BootAdminApplication.class, args);
    }
}

编写对应POJO
- Mybatis-plus通过数据库pojo名小写得到数据库表名，从而建立对应关系(User类——user表)
- 可通过@TableName指定

@AllArgsConstructor
@NoArgsConstructor
@Data
@TableName("tb_user")
public class User {
    //两个临时属性，不对应表中的内容
    @TableField(exist = false)
    private String userName;
    @TableField(exist = false)
    private String password;

    private Long id;
    private String name;
    private Integer age;
    private String email;
}

查询的字段名要与属性名对应
- 通过查询起别名方式
- 通过resultMap建立自定义映射关系

3. 编写业务接口

UserMapper

public interface UserMapper extends BaseMapper {
}

当复杂业务时考虑在resources/mapper下编写业务对应的sql映射xml文件

使用MyBatis Plus提供的IService，ServiceImpl，减轻Service层开发工作:

UserService

public interface UserService extends IService {
}

UserServiceImpl

@Service
public class UserServiceImpl extends ServiceImpl implements UserService{
}

4.2 CRUD

1. 添加分页插件

@Configuration
public class MybatisPlusConfig {

    
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.H2));
        return interceptor;
    }
}

2. 分页数据展示即删除用户

控制层

@GetMapping("/dynamic_table")
public String dynamic_table(Model model, @RequestParam(value = "pn", defaultValue = "1") Long pn){

    //分页查询数据
    Page userPage = new Page<>(pn, 2);

    //分页查询结果
    Page page = userService.page(userPage, null);
    model.addAttribute("page",page);

    return "table/dynamic_table";
}

@GetMapping("/user/delete/{id}")
public String deleteUser(@PathVariable("id") Long id,
                         @RequestParam(value = "pn", defaultValue = "1") Long pn,
                         RedirectAttributes redirectAttributes){
    userService.removeById(id);
    //重定向携带参数
    redirectAttributes.addAttribute("pn", pn);
    return "redirect:/dynamic_table";
}

页面渲染


    
        
            
                序号
                id
                name
                age
                email
                操作
            
        
        
            
                
                
                [[${user.name}]]
                [[${user.age}]]
                [[${user.email}]]
                删除
            
        
    

    
        
            当前 [[${page.current}]] 页
                总计 [[${page.pages}]] 页 共 [[${page.total}]] 条记录
            
        
        
            
                
                    ← Previous
                    
                        [[${num}]]
                    

                    Next →

序号	id	name	age	email	操作
		[[${user.name}]]	[[${user.age}]]	[[${user.email}]]	删除

二、NoSQL 1. Redis自动配置

添加依赖：


    org.springframework.boot
    spring-boot-starter-data-redis




    redis.clients
    jedis

spring-boot-autoconfigure—data—redis—RedisAutoConfiguration自动配置类，RedisProperties 属性类 --> spring.redis.xxx是对redis的配置
连接工厂LettuceConnectionConfiguration、JedisConnectionConfiguration是准备好的。
自动注入了RedisTemplate，xxxTemplate。
自动注入了StringRedisTemplate，key，value都是String
底层只要我们使用StringRedisTemplate、RedisTemplate就可以操作Redis。

外网Redis环境搭建：

阿里云按量付费Redis，其中选择经典网络。
申请Redis的公网连接地址。
修改白名单，允许0.0.0.0/0访问。

Redis Desktop Manager：可视化Redis管理软件

2. RedisTemplate与Lettuce

测试redis连接：

@SpringBootTest
public class Boot05WebAdminApplicationTests {

    @Autowired
    StringRedisTemplate redisTemplate;

    @Autowired
    RedisConnectionFactory redisConnectionFactory;

    @Test
    void testRedis(){
        ValueOperations operations = redisTemplate.opsForValue();
        operations.set("hello","world");

        String hello = operations.get("hello");
        System.out.println(hello);

        System.out.println(redisConnectionFactory.getClass());
    }
}

3. 切换至jedis

spring:
  redis:
#   url: redis://lfy:Lfy123456@r-bp1nc7reqesxisgxpipd.redis.rds.aliyuncs.com:6379
    host: r-bp1nc7reqesxisgxpipd.redis.rds.aliyuncs.com
    port: 6379
    password: lfy:Lfy123456
    client-type: jedis
    jedis:
      pool:
        max-active: 10
#   lettuce:# 另一个用来连接redis的java框架
#      pool:
#        max-active: 10
#        min-idle: 5

Redis操作与统计小实验:

URL统计拦截器

@Component
public class RedisUrlCountInterceptor implements HandlerInterceptor {

    @Autowired
    StringRedisTemplate redisTemplate;

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String uri = request.getRequestURI();
        //默认每次访问当前uri就会计数+1
        redisTemplate.opsForValue().increment(uri);
        return true;
    }
}

注册URL统计拦截器：

@Configuration
public class AdminWebConfig implements WebMvcConfigurer{

    @Autowired
    RedisUrlCountInterceptor redisUrlCountInterceptor;

	@Override
    public void addInterceptors(InterceptorRegistry registry) {
        //将拦截器注册到容器中.拦截所有请求.放行的请求
        registry.addInterceptor(new LoginInterceptor())
                .addPathPatterns("/**")
                .excludePathPatterns("/","/login","/css/**","/fonts/**","/images/**","/js/**");
        registry.addInterceptor(redisUrlCountInterceptor)
                .addPathPatterns("/**")
                .excludePathPatterns("/","/login","/css/**","/fonts/**","/images/**",
                        "/js/**","/aa/**");
    }
}

Filter、Interceptor 几乎拥有相同的功能，都是拦截作用？

Filter是Servlet定义的原生组件，它的好处是脱离Spring应用也能使用。
Interceptor是Spring定义的接口，可以使用Spring的自动装配等功能。

调用Redis内的统计数据：

@Slf4j
@Controller
public class IndexController {

	@Autowired
    StringRedisTemplate redisTemplate;
    
	@GetMapping("/main.html")
    public String mainPage(HttpSession session,Model model){

        log.info("当前方法是：{}","mainPage");

        ValueOperations opsForValue =
                redisTemplate.opsForValue();

        String s = opsForValue.get("/main.html");
        String s1 = opsForValue.get("/sql");

        model.addAttribute("mainCount",s);
        model.addAttribute("sqlCount",s1);

        return "main";
    }
}

Springboot——数据访问

Java相关栏目本月热门文章