java高级

java数据库

配置连接数据库信息

spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.url=jdbc:mysql://192.168.31.162:3306/javagaoji
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
#更改数据源druid
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
?

pom文件

        
        
        <dependency>
            <groupId>com.alibabagroupId>
            <artifactId>druidartifactId>
            <version>1.1.20version>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-jdbcartifactId>
        dependency>
        <dependency>
            <groupId>org.mybatis.spring.bootgroupId>
            <artifactId>mybatis-spring-boot-starterartifactId>
            <version>2.1.3version>
        dependency>
        <dependency>
            <groupId>mysqlgroupId>
            <artifactId>mysql-connector-javaartifactId>
            <scope>runtimescope>
        dependency>

实体类

package com.huahua.springbootgaoji.bean;
?
?
import java.sql.Date;
?
/**
 * @author wangtianxv
 * @create 2020-09-30 9:41
 */
?
public class User {
?
    public Integer id;
    public String name;
    public Integer age;
    public String sex;
?
    public Date birthday;
    public double price;
?
    public User() {
    }
?
    public String getSex() {
        return sex;
    }
?
    public void setSex(String sex) {
        this.sex = sex;
    }
?
    public Date getBirthday() {
        return birthday;
    }
?
    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }
?
    public double getPrice() {
        return price;
    }
?
    public void setPrice(double price) {
        this.price = price;
    }
?
    public User(Integer id, String name, Integer age, String sex, Date birthday, double price) {
        this.id = id;
        this.name = name;
        this.age = age;
        this.sex = sex;
        this.birthday = birthday;
        this.price = price;
    }
?
    public User(Integer id, String name, Integer age) {
        this.id = id;
        this.name = name;
        this.age = age;
    }
?
    public Integer getId() {
        return id;
    }
?
    public void setId(Integer id) {
        this.id = id;
    }
?
    public String getName() {
        return name;
    }
?
    public void setName(String name) {
        this.name = name;
    }
?
    public Integer getAge() {
        return age;
    }
?
    public void setAge(Integer age) {
        this.age = age;
    }
}
?
?

mapper

package com.huahua.springbootgaoji.mapper;
?
import com.huahua.springbootgaoji.bean.User;
import org.apache.ibatis.annotations.*;
import org.springframework.stereotype.Component;
?
/**
 * @author wangtianxv
 * @create 2020-09-30 9:47
 */
@Component
@Mapper
public interface UserMapper {
?
    @Select("select * from user where id=#{id}")
    public User getAllUser(Integer id);
?
    @Options(useGeneratedKeys = true,keyProperty = "id")//确定主键
    @Insert("insert into user(name) values(#{name})")
    public int insertUser(User user);
?
    @Delete("delete from user where id=#{id}")
    public Integer deleteUser(Integer id);
?
    @Update("update user set name=#{name} where id=#{id}")
    public int updateUser(User user);
}
?

service

package com.huahua.springbootgaoji.service;
?
import com.huahua.springbootgaoji.bean.User;
import com.huahua.springbootgaoji.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
?
/**
 * @author wangtianxv
 * @create 2020-09-30 14:23
 */
@Service
public class UserService {
?
    @Autowired
    UserMapper userMapper;
?
    public User getAllUser(@PathVariable("id") Integer id){
        User allUser = userMapper.getAllUser(id);
        System.out.println("查询"+id+"员工");
        return allUser;
    }
?
    public  User insertUser( User user){
        userMapper.insertUser(user);
        System.out.println("添加员工");
        return user;
    }
?
    public Integer delUser(@PathVariable("id")  Integer id){
        System.out.println("删除"+id+"员工");
        userMapper.deleteUser(id);
        return id;
    }
?
    public User updepartment(User user){
        userMapper.updateUser(user);
        System.out.println("修改"+user.getId()+"员工");
        User allUser = userMapper.getAllUser(user.getId());
        return allUser;
    }
}
?

controller

package com.huahua.springbootgaoji.controller;
?
import com.huahua.springbootgaoji.bean.User;
import com.huahua.springbootgaoji.mapper.UserMapper;
import com.huahua.springbootgaoji.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
?
import javax.websocket.server.PathParam;
import java.text.SimpleDateFormat;
?
/**
 * @author wangtianxv
 * @create 2020-09-30 9:25
 */
@RestController
public class HelloController {
?
    @Autowired
    UserService userService;
?
    @GetMapping("/user/{id}")
    public User getAllUser(@PathVariable("id") Integer id ){
        User allUser = userService.getAllUser(id);
        return allUser;
    }
?
    @GetMapping("/inuser")
    public  User insertUser( User user){
        userService.insertUser(user);
        return user;
    }
    @GetMapping("/deluser/{id}")
    public Integer delUser(@PathVariable("id")  Integer id){
        userService.delUser(id);
        return id;
    }
    //    http://localhost:8080/update?id=3&&departmentName=%E2%80%9Csss%E2%80%9D
    @GetMapping("upuser")
    public User updepartment(User user){
        userService.updepartment(user);
        User allUser = userService.getAllUser(user.getId());
        return allUser;
    }
}
?

run

package com.huahua.springbootgaoji;
?
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.cache.annotation.EnableCaching;
?
@MapperScan("com.huahua.springbootgaoji.mapper")
@SpringBootApplication
@EnableCaching//开启缓存注解
public class SpringbootGaojiApplication {
?
    public static void main(String[] args) {
        SpringApplication.run(SpringbootGaojiApplication.class, args);
    }
?
}
?

缓存

SpringbootGaojiApplication上加入@EnableCaching注解//开启缓存注解

cache

@EnableCaching 主类配置 表示可以使用cache注解缓存

package com.huahua.springbootcache.service;
?
import com.huahua.springbootcache.bean.Employee;
import com.huahua.springbootcache.mapper.EmployeeMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cache.annotation.*;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
?
/**
 * @author huahua
 * @date 2020/9/2 -11:06
 */
@CacheConfig(cacheNames = "emp")//抽取缓存公共配置
@Service
public class EmployeeService {
?
    @Autowired
    EmployeeMapper employeeMapper;
?
    @Autowired
    RedisTemplate<Object,Employee> employeeRedisTemplate;
?
    //查询
    //默认key的值是参数   condition:指定缓存条件  unless:否定缓存（当结果为true，返回值不被缓存）,sync缓存是否使用异步
    //cacheNames = "emp" ,key = "#id",condition = "#id>0",unless = "#id>0",sync = true
    @Cacheable(cacheNames = "emp")
    public Employee getEmpById(Integer id) {
        System.out.println("查询"+id+"号员工");
        Employee emp = employeeMapper.getEmpById(id);
        return emp;
    }
?
    //修改  先运行方法，再把返回值存入缓存中
    @CachePut(value = "emp" , key = "#employee.id")
    public  Employee upEmp(Employee employee){
        System.out.println("upemp"+employee);
            employeeMapper.upEmp(employee);
        return employee;
    }
    //删除 （beforeInvocation = true 清除缓存在方法执行前）
    @CacheEvict(value = "emp",key = "#id" ,beforeInvocation = true /*,allEntries = true 删除所有缓存*/)
    public void delemp(Integer id){
        System.out.println("del"+id);
        employeeMapper.delEmpById(id);
    }
    //指定复杂的缓存规则   put原因  根据lastName查询元素  还是会去数据库查询
//    @Caching(
//            cacheable = {
//                    @Cacheable(value="emp",key = "#lastName")
//            },
//            put = {
//                    @CachePut(value = "emp",key = "#result.id"),
//                    @CachePut(value = "emp",key = "#result.email")
//            }
//    )
    public Employee GetEmpByLastName(String lastName){
        System.out.println("根据lastName查询数据"+lastName);
        Employee employee = employeeMapper.GetEmpByLastName(lastName);
        //redisTemplate.opsForValue().set("emp-01","emp");
        employeeRedisTemplate.opsForValue().set("empwangtainx",employee);
        return employee;
    }
}
?

config redis配置

package com.huahua.springbootcache.config;

import com.huahua.springbootcache.bean.Department;
import com.huahua.springbootcache.bean.Employee;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.cache.RedisCacheWriter;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.*;

import java.net.JarURLConnection;
import java.net.UnknownHostException;
import java.time.Duration;

/**
 * @author huahua
 * @date 2020/9/3 -14:58
 */
//redis缓存对象时，修改默认的序列化对象

@Configuration
@EnableCaching
public class MyRedisConfig {


 

    //过期时间1天
    private Duration timeToLive = Duration.ofDays(1);
    @Bean
    public RedisCacheManager cacheManager(RedisConnectionFactory connectionFactory) {
        //默认1
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(this.timeToLive)
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(keySerializer()))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(valueSerializer()))
                .disableCachingNullValues();
        RedisCacheManager redisCacheManager = RedisCacheManager.builder(connectionFactory)
                .cacheDefaults(config)
                .transactionAware()
                .build();
        System.out.println("log.debug(\"自定义RedisCacheManager加载完成\");");
        return redisCacheManager;
    }
    @Bean(name = "redisTemplate")
    public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory){
        RedisTemplate redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        redisTemplate.setKeySerializer(keySerializer());
        redisTemplate.setHashKeySerializer(keySerializer());
        redisTemplate.setValueSerializer(valueSerializer());
        redisTemplate.setHashValueSerializer(valueSerializer());
        System.out.println("log.debug(\"自定义RedisTemplate加载完成\");");
        return redisTemplate;
    }
    private RedisSerializer keySerializer() {
        return new StringRedisSerializer();
    }
    private RedisSerializer