springboot 整合tx-mybaits 实现crud操作

一操作案例

1.1 工程结构

1.2 pom文件的配置

 <!--spring boot的依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.2</version></dependency><!--mysql的依赖 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><!--spring boot的依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!--  常规依赖 --><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.4</version></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-core</artifactId></dependency><dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId></dependency><dependency><groupId>com.fasterxml.jackson.datatype</groupId><artifactId>jackson-datatype-joda</artifactId><version>2.9.6</version></dependency><dependency><groupId>com.fasterxml.jackson.module</groupId><artifactId>jackson-module-parameter-names</artifactId></dependency><!-- 分页插件 --><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-starter</artifactId><version>1.4.1</version></dependency><!-- alibaba的druid数据库连接池 --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.9</version></dependency><!--SpringBoot与Redis整合依赖--><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><!--jedis--><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.3.1</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version><optional>true</optional></dependency><!--lettuce--><!--<dependency><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId><version>6.2.1.RELEASE</version></dependency>--><!--swagger2--><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger2</artifactId><version>2.9.2</version></dependency><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger-ui</artifactId><version>2.9.2</version></dependency><!-- redisson 分布式锁--><dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.11.2</version></dependency><!--guava Google 开源的 Guava 中自带的布隆过滤器--><dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>23.0</version></dependency><!--persistence--><dependency><groupId>javax.persistence</groupId><artifactId>persistence-api</artifactId><version>1.0.2</version></dependency><!--通用Mapper--><dependency><groupId>tk.mybatis</groupId><artifactId>mapper</artifactId><version>4.1.5</version></dependency>

主要依赖

1.3 dao层

@org.apache.ibatis.annotations.Mapper
public interface CustomerDao  extends Mapper<Customer> {
}

1.4 service层

1.接口

public interface CustormerService {public void addCustomerData(Customer customer);
}

2.实现类

@Service
public class CustomerServiceImpl  implements CustormerService {public static final String CACHA_KEY_CUSTOMER = "customer:";@Autowiredprivate CustomerDao customerDao;@Autowiredprivate RedisTemplate redisTemplate;public void addCustomerData(Customer customer){//1.先插入mysql中int k= customerDao.insertSelective(customer);if(k>0){//2.从mysql中查询一次Customer result=customerDao.selectByPrimaryKey(customer.getId());//3.新增到redis中String key=CACHA_KEY_CUSTOMER+customer.getId();redisTemplate.opsForValue().set(key,result);}}
}

1.5 controller层

@RestController
@Slf4j
public class CustomerController {@Resourceprivate CustormerService customerSerivce;@ApiOperation("数据库初始化2条Customer记录插入")@RequestMapping(value = "/customer/add",method = RequestMethod.GET)public void addCustomer(){for (int i = 1; i < 3; i++) {Customer customer = new Customer();customer.setId(i);customer.setCname("customer"+i);customer.setAge(new Random().nextInt(30)+1);customer.setPhone("1381111XXXX");customer.setSex((byte) new Random().nextInt(2));customer.setBirth(Date.from(LocalDateTime.now().atZone(ZoneId.systemDefault()).toInstant()));customerSerivce.addCustomerData(customer);}}
}

1.6 启动类

1.7 测试类

1.初始化数据库

CREATE TABLE `t_customer` (`id` bigint(11) NOT NULL,`cname` varchar(255) DEFAULT NULL,`age` int(11) DEFAULT NULL,`phone` varchar(255) DEFAULT NULL,`sex` varchar(255) DEFAULT NULL,`birth` timestamp NULL DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2.页面访问

3.查看数据库：

4.查看redis

二实现查询操作

2.1 service

    @Overridepublic Customer findDataByNoFilter(Integer id) {//1.先查询redisString key=CACHA_KEY_CUSTOMER+id;Customer customer=(Customer) redisTemplate.opsForValue().get(key);if(customer==null){System.out.println("刚开始redis不存在。。。。。。");//2.redis为空，查询mysqlcustomer=customerDao.selectByPrimaryKey(id);if(customer!=null){//3.mysql中数据存在， 把mysq查询出来的数据回写redis，保持一致性redisTemplate.opsForValue().set(key,customer);}}return customer;}
}

2.2 controller

    @ApiOperation("单个customer查询操作，按照customerid查询")@RequestMapping(value = "/customer/{id}",method = RequestMethod.GET)public Customer findCustomerById(@PathVariable Integer id){return customerSerivce.findDataByNoFilter(id);}