栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Jpa第一话 -- Springboot集成Jpa和Mybatis以及Jpa的最全使用

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Jpa第一话 -- Springboot集成Jpa和Mybatis以及Jpa的最全使用

本文主要记录spring-boot-starter-data-jpa的详细使用。
在做一些小型无并发的项目时,说实话第一个想到的就是Jpa,一个Entity走天下。

1.Spring Jpa的使用

基于spring-boot-starter-parent2.6.8

1.1 引入依赖

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



	mysql
	mysql-connector-java
	runtime

1.2 yaml配置
spring:
  #配置 Jpa
  jpa:
    hibernate:
      #每次启动都校验更新
      ddl-auto: update
      dialect: org.hibernate.dialect.MySQL8Dialect
    #外键关联会公用session 如果有很频繁的外键查询可能会导致连接数下不来 
    #隔几天就会报数据库连接数不够 生产真实事件  
    open-in-view: false
    #打印sql
    show-sql: true  
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.0.100:3306/a_channel?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false
    username: root
    password: 123456
    hikari:
      # 最小连接
      minimum-idle: 5
      # 最大连接数
      maximum-pool-size: 30
      # 获取连接超时时间
      connection-timeout: 5000
      # 空闲连接最大存活的时间
      idle-timeout: 60000
      # 连接最大存活时间
      max-lifetime: 120000
      # 连接有效性检测时间
      validation-timeout: 60000
      # 检测连接是否有效
      connection-test-query: SELECT 1
1.3 BaseEntity通用
@Getter
@Setter
@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
public abstract class BaseEntity extends SignVO implements Serializable {

    //主键数据库自增id
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    public Long id;

	//自动赋值创建时间
    @CreatedDate
    @Column(name = "create_time", updatable = false,
            columnDefinition = "DATETIME(6) NULL DEFAULT CURRENT_TIMESTAMP(6) COMMENT '创建时间'")
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date createTime;

	//自动赋值更新时间
    @LastModifiedDate
    //设置数据库字段默认值
    @Column(name = "update_time",
            columnDefinition = "DATETIME(6) NULL DEFAULT CURRENT_TIMESTAMP(6) ON UPDATE CURRENT_TIMESTAMP(6) COMMENT '更新时间'")
    //JSONField 一个是做加密时FastJson序列化用
    //JsonFormat 一个是不加密时框架JackJson转出用
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date updateTime;

    @Override
    public String toString() {
        return JSONObject.toJSONString(this);
    }
}

通用Entity要注意类上的注解,数据库自增策略要注意

1.4 entity类
@Entity
@Data
@Table(name = "t_agent",
		//组合唯一键
        uniqueConstraints = {
                @UniqueConstraint(name = "channelCodetype", columnNames = {"channelCode", "type"})},
        //索引        
        indexes = {@Index(columnList = "channelCode"), @Index(columnList = "name")})
public class Agent extends BaseEntity {

	//名称
    String name;
    //渠道号
    String channelCode;
    //类型
    Integer type;
    //密钥 
    @Column(unique = true) //唯一键
    String sign;
    //详细介绍
    @Lob //大文本标识
    //大文本且设置编码
    //@Column(columnDefinition = "LONGTEXT NULL DEFAULT NULL COLLATE 'utf8mb4_unicode_ci' COMMENT '支持unicode'")
    String info;
}
1.5 Repository接口
import com.example.demo.entity.Agent;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;

public interface AgentRepository extends JpaRepository, JpaSpecificationExecutor {
	//where channelCode=#{key}的意思
    Agent findByChannelCode(String key);
}
1.6 插入&&更新数据

jpa插入或者更新

@Resource
AgentRepository agentRepository;

Agent agent = new Agent();
agent.setName("test");
agent.setChannelCode("test1");
agent.setSign("1234xxx11123");
agent.setType(1);
agent.setInfo("info info");
agentRepository.save(agent);

更新与插入唯一的区别就是更新多了个主键id的字段

1.7 查询数据
  1. 普通查询
//自带的实现 根据主键id查询
Agent agent1 = agentRepository.findById(1l).orElse(null);
//生成接口查询 需要注意命名规范
Agent agent1 = agentRepository.findByByChannelCode("test").orElse(null);
//多条件查询
List agents = agentRepository.findAll((root, query, cb) -> {
    List predicates = new ArrayList<>();
    predicates.add(cb.equal(root.get("type"), 2));
    return cb.and(predicates.toArray(new Predicate[0]));
});
//分页和排序查询
List agents = agentRepository.findAll((root, query, cb) -> {
    List predicates = new ArrayList<>();
    predicates.add(cb.equal(root.get("type"), 2));
	//使用FIND_IN_SET函数查询
	Expression function = cb.function("FIND_IN_SET", Integer.class,
	        cb.literal(vo.ids()), root.get("appIds"));
	predicates.add(cb.greaterThan(function, 0));
    return cb.and(predicates.toArray(new Predicate[0]));
}, PageRequest.of(0,10, Sort.by(Sort.Direction.DESC,"id")));

需要注意字段一定要一一对应,分页和排序均可单独使用

1.8 Jpa注解使用

插入、更新、删除如果使用注解必须加@Transactional和@Modifying

//:#{#t.type} 取值写法 判空使用的是mysql语法
@Transactional
@Modifying
@Query(value = "UPDATE t_agent set type=:#{#p.type} WHERe channel_code=:#{#p.channelCode}", nativeQuery = true)
void update(@Param("p") Agent agent);

//: 号取值
@Transactional
@Modifying
@Query(value = "UPDATE agent set type=2 WHERe id in(:ids)", nativeQuery = true)
void updateAll(@Param("ids") List ids);

//参数位置取值
@Query(value = "SELECT * from t_agent where channelCode=?1 and type=?2 ", nativeQuery = true)
void select(String channelCode,Integer type);

mysql中的判空可以用if,list判空可以用coalesce(:#{#t.tagIds},null),与if的用法一致

2.Springboot集成Jpa和Mybatis
  1. Jpa的每次save都会先查询一遍,如果插入比较多的服务建议引入mybatis
  2. 真的不建议使用外键,虽然方便查询,但不管是查询还是操作都比较麻烦,Jpa还存在连接不能被回收的问题,Mybatis高端用法中有完美的替代
  3. 尽量不要使用注解sql,避免调试和取参困难

引入依赖



	org.mybatis.spring.boot
	mybatis-spring-boot-starter
	2.2.2



	com.github.pagehelper
	pagehelper-spring-boot-starter
	1.4.2

于是便有了简单查询更新插入用Jpa,复杂查询用Mybatis,用起来简直方便多了

2.1 yaml配置

所有的orm框架都是基于应用层操作去封装的,而连接DataSource则是由不同的连接池实现,这里有的是默认的hikari连接池,如果想配置JPA和Mybatis只需要配置即可

spring:
  #配置 Jpa
  jpa:
    hibernate:
      ddl-auto: update
      dialect: org.hibernate.dialect.MySQL8Dialect
    open-in-view: false
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://192.168.0.100:3306/d_file?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false
    username: root
    password: 123456
    hikari:
      # 最小连接
      minimum-idle: 5
      # 最大连接数
      maximum-pool-size: 30
      # 获取连接超时时间
      connection-timeout: 5000
      # 空闲连接最大存活的时间
      idle-timeout: 60000
      # 连接最大存活时间
      max-lifetime: 120000
      # 连接有效性检测时间
      validation-timeout: 60000
      # 检测连接是否有效
      connection-test-query: SELECT 1
#mybatis
mybatis:
  #mapper xml扫描目录
  mapperLocations: classpath:mapper/**.xml
  executorType: SIMPLE
  configuration:
    # 驼峰式
    map-underscore-to-camel-case: true
    #日志打印
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
2.2 mapper接口记得添加@Mapper注解
@Mapper
public interface FileMapper {}
2.3 mapper xml目录

要和配置对应,不然会报找不到boundsql

直接注解使用,相当于两个orm框架都共用连接池。只需要关心orm框架的配置,不用再去考虑连接池.

Jpa最实用的还是创建表与更新,性能上确实令人唏嘘

以上就是本章的全部内容了。

上一篇:SpringCloud第五话 – Gateway实现负载均衡、熔断、限流
下一篇:Jpa第二话 – Jpa多数据源集成

盛年不重来,一日难再晨

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/1013965.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号