Mybatis Cache（一）MybatisCache+Redis

前面提到了，使用mybatis cache，一般是结合redis使用。

一、demo

1、数据表
create table demo.t_address
(id           int auto_incrementprimary key,address_name varchar(200) null,address_code varchar(20)  null,address_type int          null
);

项目结构：

2、pom
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>org.example</groupId><artifactId>plus-mybatis-cache</artifactId><version>1.0-SNAPSHOT</version><properties><maven.compiler.source>17</maven.compiler.source><maven.compiler.target>17</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.2.4</version><relativePath/></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--尽量不要同时导入mybatis 和 mybatis_plus，避免版本差异--><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-spring-boot3-starter</artifactId><version>3.5.5</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.13</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId></dependency></dependencies>
</project>
3、配置文件
server.port=1112
server.servlet.context-path=/mybatisCacheDemo
#mysql
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3308/demo?useUnicode=true&characterEncoding=utf-8&useSSL=false
spring.datasource.username=root
spring.datasource.password=wtyy
#mybatis
mybatis.mapper-locations=classpath*:mapper/*Mapper.xml
#打印日志
mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
# 开启二级缓存
mybatis-plus.configuration.cache-enabled=true
#redis
spring.data.redis.host=127.0.0.1
spring.data.redis.port=6379
spring.data.redis.password=
spring.data.redis.lettuce.pool.max-active=8
spring.data.redis.lettuce.pool.max-wait=-1
spring.data.redis.lettuce.pool.max-idle=8
spring.data.redis.lettuce.pool.min-idle=0
spring.data.redis.lettuce.pool.enabled=true
spring.data.redis.lettuce.pool.time-between-eviction-runs=30s
4、util
package com.pluscache.demo.util;import org.springframework.aop.support.AopUtils;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;import java.lang.annotation.Annotation;
import java.util.Map;@Component
public class ApplicationContextUtil implements ApplicationContextAware {private static ApplicationContext applicationContext ;@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {ApplicationContextUtil.applicationContext = applicationContext;}public static Object getBean(String name) {return ApplicationContextUtil.applicationContext.getBean(name);}public static <T> T getBean(String name, Class<T> clazz) {return applicationContext.getBean(name, clazz);}public static <T> T getBean(Class<T> clazz) {return applicationContext.getBean(clazz);}public static <T> Map<String, T> getBeansOfType(Class<T> clazz) {return applicationContext.getBeansOfType(clazz);}public static ApplicationContext getApplicationContext() {return applicationContext;}public static <T extends Annotation> T getAnnotation(Object bean, Class<T> annotationClass) {T annotation = bean.getClass().getAnnotation(annotationClass);if (annotation == null) {annotation = AopUtils.getTargetClass(bean).getAnnotation(annotationClass);}return annotation;}}
5、config
package com.pluscache.demo.config;import com.pluscache.demo.util.ApplicationContextUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.cache.Cache;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;
import org.springframework.stereotype.Component;@Slf4j
//@Component
public class MybatisRedisCache implements Cache {/* * id是必须的带上的，这里的id会指定当前放入缓存的mapper的namespace* 如这里的id就是com.sample.dao.IEmployeeDao*/private final String id;private  RedisTemplate redisTemplate;public MybatisRedisCache(final String id) {//获取redis实例//redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");//指定key的序列化方式//redisTemplate.setKeySerializer(new StringRedisSerializer());//redisTemplate.setHashKeySerializer(new StringRedisSerializer());this.id = id;}@Overridepublic String getId() {return id;}@Overridepublic void putObject(Object key, Object value) {this.getRedisTemplate();redisTemplate.opsForHash().put(id.toString(),key.toString(),value);}private void getRedisTemplate() {if (redisTemplate == null) {//由于启动期间注入失败，只能运行期间注入，这段代码可以删除redisTemplate = (RedisTemplate) ApplicationContextUtil.getBean("redisTemplate");}}@Overridepublic Object getObject(Object key) {this.getRedisTemplate();return redisTemplate.opsForHash().get(id.toString(),key.toString());}@Overridepublic Object removeObject(Object key) {return null;}@Overridepublic void clear() {this.getRedisTemplate();redisTemplate.delete(id.toString());}@Overridepublic int getSize() {this.getRedisTemplate();return redisTemplate.opsForHash().size(id.toString()).intValue();}
}
6、dto
package com.pluscache.demo.dto;import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;import java.io.Serializable;@Data
@TableName("t_address")
public class AddressDTO implements Serializable {private Integer id;private String addressName;private String addressCode;public Integer addressType;
}
7、dao
（1）repository

   可以省略，移到service中

package com.pluscache.demo.repository;import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.pluscache.demo.dto.AddressDTO;
import com.pluscache.demo.mapper.AddressMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;import java.util.List;@Repository
@Slf4j
public class AddressRepository {@Autowiredprivate AddressMapper addressMapper;//plus新增public void insert(AddressDTO addressDTO) {addressMapper.insert(addressDTO);}//手动SQL新增public void save(AddressDTO addressDTO) {addressMapper.save(addressDTO);}public AddressDTO getById(Integer id) {LambdaQueryWrapper<AddressDTO> queryWrapper = new LambdaQueryWrapper<>();queryWrapper.eq(AddressDTO::getId, id);return addressMapper.selectOne(queryWrapper);}public List<AddressDTO> listByType(Integer type) {LambdaQueryWrapper<AddressDTO> queryWrapper = new LambdaQueryWrapper<>();queryWrapper.eq(AddressDTO::getAddressType, type);return addressMapper.selectList(queryWrapper);}public List<AddressDTO> listByTypeRecord(Integer type) {return addressMapper.listByTypeRecord(type);}
}
（2）mapper

   在这里做的缓存

package com.pluscache.demo.mapper;import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.pluscache.demo.config.MybatisRedisCache;
import com.pluscache.demo.dto.AddressDTO;
import org.apache.ibatis.annotations.CacheNamespace;
import org.apache.ibatis.annotations.Param;import java.util.List;@CacheNamespace(implementation = MybatisRedisCache.class, eviction = MybatisRedisCache.class)
public interface AddressMapper extends BaseMapper<AddressDTO> {void save(@Param("record") AddressDTO addressDTO);List<AddressDTO> listByTypeRecord(@Param("type") Integer type);
}
（3）xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.pluscache.demo.mapper.AddressMapper"><cache-ref namespace="com.pluscache.demo.mapper.AddressMapper"/><insert id="save">insert into t_address(address_name,address_code,address_type) values (#{record.addressName},#{record.addressCode},#{record.addressType})</insert><select id="listByTypeRecord" resultType="com.pluscache.demo.dto.AddressDTO">select address_name,address_code from t_address where address_type =#{type}</select></mapper>
8、service
package com.pluscache.demo.service.impl;import com.pluscache.demo.dto.AddressDTO;
import com.pluscache.demo.repository.AddressRepository;
import com.pluscache.demo.service.AddressService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;import java.util.List;@Service("addressService")
public class AddressServiceImpl implements AddressService {@Autowiredprivate AddressRepository addressRepository;@Overridepublic void insert(AddressDTO addressDTO) {addressRepository.insert(addressDTO);}@Overridepublic void save(AddressDTO addressDTO) {addressRepository.save(addressDTO);}@Overridepublic AddressDTO getById(Integer id) {return addressRepository.getById(id);}@Overridepublic List<AddressDTO> listByType(Integer type) {return addressRepository.listByType(type);}@Overridepublic List<AddressDTO> listByTypeRecord(Integer type) {return addressRepository.listByTypeRecord(type);}
}
9、controller
package com.pluscache.demo.controller;import com.pluscache.demo.dto.AddressDTO;
import com.pluscache.demo.service.AddressService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;@RestController
@RequestMapping("/address")
public class AddressController {@Autowiredprivate AddressService addressService;@RequestMapping("/insert")public void insert(AddressDTO addressDTO) {addressService.insert(addressDTO);}@RequestMapping("/save")public void save(AddressDTO addressDTO) {addressService.save(addressDTO);}@RequestMapping("/getById")public AddressDTO getById(Integer id) {return addressService.getById(id);}@RequestMapping("/listByType")public List<AddressDTO> listByType(Integer type) {return addressService.listByType(type);}@RequestMapping("/listByTypeRecord")public List<AddressDTO> listByTypeRecord(Integer type) {return addressService.listByTypeRecord(type);}}
10、启动类
package com.pluscache.demo;import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@MapperScan("com.pluscache.demo.mapper")
@SpringBootApplication
public class MybatisPlusApplication {public static void main(String[] args) {SpringApplication.run(MybatisPlusApplication.class, args);}
}
11、测试 

（1）新增数据

    新增了几条数据

（2）

二、缺点

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/14991.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

计算机毕业设计Python+Scrapy+Vue.js机器学习招聘推荐系统 招聘数据可视化 招聘爬虫 招聘数据分析 大数据毕业设计 大数据毕设

计算机毕业设计Python+Scrapy+Vue.js机器学习招聘推荐系统 招聘数据可视化 招聘爬虫 招聘数据分析 大数据毕业设计 大数据毕设

桂林学院 本科生毕业论文&#xff08;设计、创作&#xff09;开题报告 二级学院 理工学院 专业 数据科学与大数据技术&#xff08;专升本&#xff09; 年级 2022级 姓名 徐彬彬 学号 202213018222 指导教师 沈岚岚 职称/学位 高级实验师 第二 导师 职称/学…
阅读更多...
【ZYNQ】AXI-Quad-SPI SDK 开发记录 测试

【ZYNQ】AXI-Quad-SPI SDK 开发记录 测试

前人工作 如前人工作&#xff0c;在Navigate to BSP Settings中找到历例程 file:///F:/Xilinx/Vitis/2019.2/data/embeddedsw/XilinxProcessorIPLib/drivers/spi_v4_5/doc/html/api/example.html使用XSpi_LowLevelExample例子&#xff0c;源代码的AI解析 int XSpi_LowLeve…
阅读更多...
Java使用apache.poi生成word

Java使用apache.poi生成word

加油&#xff0c;打工人&#xff01; 工作需求&#xff0c;将现有的word模板有段落和表格&#xff0c;从数据库中查出数据并填充&#xff0c;word里面也有表格数据&#xff0c;需要将excel表格数据单独处理&#xff0c;然后插入到生成好的word文档中。 下面代码模拟从数据库查出…
阅读更多...
Kubernetes——Kubectl详解

Kubernetes——Kubectl详解

目录 前言 一、陈述式资源管理方法 二、Kubectl命令操作 1.查 1.1kubectl version——查看版本信息 1.2kubectl api-resources——查看资源对象简写 1.3kubectl cluster-info——查看集群信息 1.4配置Kubectl补全 1.5journalctl -u kubelet -f——查看日志 1.6kubec…
阅读更多...
物联网应用开发--STM32与机智云通信（ESP8266 Wi-Fi+手机APP+LED+蜂鸣器+SHT20温湿度传感器）

物联网应用开发--STM32与机智云通信（ESP8266 Wi-Fi+手机APP+LED+蜂鸣器+SHT20温湿度传感器）

实现目标 1、熟悉机智云平台&#xff0c;会下载APP 2、熟悉新云平台创建产品&#xff0c;项目虚拟调试 3、掌握云平台生成MCU代码&#xff0c;并移植。机智云透传固件的下载 4、具体目标&#xff1a;&#xff08;1&#xff09;注册机智云平台&#xff1b;&#xff08;2&…
阅读更多...
148.【Windows DOS命令脚本文件】

148.【Windows DOS命令脚本文件】

Window待处理脚本 (一)、批处理编程初步体验1.什么是批处理程序&#xff1f;(1).批处理程序的定义(2).如何编辑批处理程序 2.批处理程序可以做什么&#xff1f;(1).匹配规则删除文件(2).新建文件&#xff0c;日志等(3).创建计算机病毒等 3.一个基本的批处理文件(1).带盘符的输出…
阅读更多...
[深入理解DDR5] 2-1 封装与引脚

[深入理解DDR5] 2-1 封装与引脚

3500字&#xff0c;依公知及经验整理&#xff0c;原创保护&#xff0c;禁止转载。 专栏 《深入理解DDR》 1 DDR5 颗粒 X4 X8 X16 这里的 X8 or X16&#xff0c; 可以理解为一个DRAM芯片有几个存储阵列。“X几”。进行列寻址时会同时从几个阵列的同一个坐标位置读出数据bit来&a…
阅读更多...
前端中 dayjs 时间的插件使用(在vue 项目中)

前端中 dayjs 时间的插件使用(在vue 项目中)

Day.js中文网 这是dayjs的中文文档 里面包括了使用方法 下面我来详细介绍一下这个插件的使用 Day.js 可以运行在浏览器和 Node.js 中。 一般咱直接是 npm 安装 npm install dayjs 目前应该使用的是Es6 的语法 import dayjs from dayjs 当前时间 直接调用 dayjs() 将返回…
阅读更多...
【飞桨AI实战】基于PP-OCR和ErnieBot的智能视频问答

【飞桨AI实战】基于PP-OCR和ErnieBot的智能视频问答

前言 本次分享将带领大家从 0 到 1 完成一个基于 OCR 和 LLM 的视频字幕提取和智能视频问答项目&#xff0c;通过 OCR 实现视频字幕提取&#xff0c;采用 ErnieBot 完成对视频字幕内容的理解&#xff0c;并回答相关问题&#xff0c;最后采用 Gradio 搭建应用。本项目旨在帮助初…
阅读更多...
小猫咪的奇幻冒险：一个简单的Python小游戏

小猫咪的奇幻冒险：一个简单的Python小游戏

新书上架~&#x1f447;全国包邮奥~ python实用小工具开发教程http://pythontoolsteach.com/3 欢迎关注我&#x1f446;&#xff0c;收藏下次不迷路┗|&#xff40;O′|┛ 嗷~~ 目录 一、游戏简介与演示 二、游戏开发与运行 1. 环境搭建 2. 代码解析 3. 加速机制 三、游戏…
阅读更多...
Jeecg | 完成配置后，如何启动整个项目？

Jeecg | 完成配置后，如何启动整个项目？

前端启动步骤&#xff1a; 1. 以管理员身份打开控制台&#xff0c;切换到前端项目目录。 2. 输入 pnpm install 3. 输入 pnpm dev 4. 等待前端成功运行。 可以看到此时前端已经成功启动。 后端启动步骤&#xff1a; 1. 启动 mysql 服务器。 管理员身份打开控制台&#…
阅读更多...
得物小程序逆向+qt可视化（不含sku）

得物小程序逆向+qt可视化（不含sku）

声明 本文章中所有内容仅供学习交流使用&#xff0c;不用于其他任何目的&#xff0c;抓包内容、敏感网址、数据接口等均已做脱敏处理&#xff0c;严禁用于商业用途和非法用途&#xff0c;否则由此产生的一切后果均与作者无关&#xff01;wx a15018601872 本文章未…
阅读更多...
Python实现国密GmSSL

Python实现国密GmSSL

Python实现国密GmSSL 前言开始首先安装生成公钥与私钥从用户证书中读取公钥读取公钥生成签名验证签名加密解密 遇到的大坑参考文献 前言 首先我是找得到的gmssl库&#xff0c;经过实操&#xff0c;发现公钥与密钥不能通过pem文件得到&#xff0c;就是缺少导入pem文件的api。这…
阅读更多...
迷你手持小风扇到底哪个牌子最好？揭秘迷你手持手持小风扇排行榜

迷你手持小风扇到底哪个牌子最好？揭秘迷你手持手持小风扇排行榜

在炎炎夏日&#xff0c;迷你手持小风扇成为了我们不可或缺的清凉伴侣。然而&#xff0c;面对市场上琳琅满目的品牌&#xff0c;迷你手持小风扇到底哪个牌子最好&#xff1f;今天&#xff0c;我将揭秘迷你手持小风扇排行榜&#xff0c;带大家一探各大品牌的魅力&#xff0c;让你…
阅读更多...
字节面试：百亿级数据存储，怎么设计？只是分库分表吗？

字节面试：百亿级数据存储，怎么设计？只是分库分表吗？

尼恩&#xff1a;百亿级数据存储架构起源 在40岁老架构师 尼恩的读者交流群(50)中&#xff0c;经常性的指导小伙伴们改造简历。 经过尼恩的改造之后&#xff0c;很多小伙伴拿到了一线互联网企业如得物、阿里、滴滴、极兔、有赞、希音、百度、网易、美团的面试机会&#xff0c…
阅读更多...
【LeetCode】【5】最长回文子串

【LeetCode】【5】最长回文子串

文章目录 [toc]题目描述样例输入输出与解释样例1样例2 提示Python实现动态规划 个人主页&#xff1a;丷从心 系列专栏&#xff1a;LeetCode 刷题指南&#xff1a;LeetCode刷题指南 题目描述 给一个字符串s&#xff0c;找到s中最长的回文子串 样例输入输出与解释 样例1 输入…
阅读更多...
文件上传安全指南：保护免受不受限制的文件上传攻击

文件上传安全指南：保护免受不受限制的文件上传攻击

文件上传安全指南&#xff1a;保护免受不受限制的文件上传攻击 在现代应用程序中&#xff0c;文件上传功能是一个常见且重要的部分。然而&#xff0c;这也为攻击者提供了潜在的攻击向量&#xff0c;尤其是不受限制的文件上传攻击。本文将详细介绍如何通过一系列安全措施来保护…
阅读更多...
安全设计 | Microsoft 威胁建模工具Threat Modeling Tool安装及使用详解（文末附样例）

安全设计 | Microsoft 威胁建模工具Threat Modeling Tool安装及使用详解（文末附样例）

1. 概览 微软威胁建模工具&#xff08;Threat Modeling Tool&#xff09;是 Microsoft 安全开发生命周期 (SDL&#xff0c;Security Develop LifeCycle) 的核心要素。 当潜在安全问题处于无需花费过多成本即可相对容易解决的阶段&#xff0c;软件架构师可以使用威胁建模工具提…
阅读更多...
linux系统防火墙开放端口命令

linux系统防火墙开放端口命令

目录 linux相关命令参考文章1.开放端口1.1 开发单个端口1.2 一次性开放多个端口 2.保存设置3.查看所有开放的端口4.查看防火墙状态 linux相关命令参考文章 管理、设置防火墙规则&#xff08;firewalld&#xff09;: https://download.csdn.net/blog/column/8489557/137911049 i…
阅读更多...
打造AI虚拟伴侣 - 优化方案

打造AI虚拟伴侣 - 优化方案

第一部分：框架优化概述 1、精确定位： 构建一个高度灵活且用户友好的平台，旨在通过无缝集成多种大型语言模型（LLMs）后端，为用户创造沉浸式的角色交互体验。不仅适配电脑端，还特别优化移动端体验，满足二次元AI虚拟伴侣市场的特定需求。 2、核心功能强化： 增强后端兼容…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023