Java Spingboot 整合JPA(Springboot-

文末有示例链接

关于数据库连接池
spring-boot 添加jpa依赖后，

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

默认使用HiKariCP连接池，如果要使用tomcat的连接池，需要引入

<dependency>
    <groupId>org.apache.tomcat</groupId>
    <artifactId>tomcat-jdbc</artifactId>
</dependency>

配置：

# 指定连接池类型
spring.datasource.type=org.apache.tomcat.jdbc.pool.DataSource
#spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.driverClassName = com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=true
spring.datasource.username=root
spring.datasource.password=passwd

# JPA hikari 数据库连接池配置
#spring.datasource.hikari.maximum-pool-size=20
#spring.datasource.hikari.minimum-idle=5
# JPA tomcat 数据库连接池配置
spring.datasource.tomcat.initial-size=13
# 各个连接池的特殊化设置，idea里有提示
#spring.datasource.dbcp2.*= # Commons DBCP2 specific settings
#spring.datasource.tomcat.*= # Tomcat datasource specific settings
#spring.datasource.hikari.*= # Hikari specific settings

Tomcat 的 JDBC 连接池介绍

JPA定义的一些最基本的crud操作，在JpaRepository类及其父类中都有定义，
根据方法名就能知道具体是干啥的

自定义的简单查询就是根据方法名来自动生成SQL，主要的语法是
findXXBy,readXXBy,queryXXBy,countXXBy, getXXBy后面跟属性名称，也使用一些加一些关键字And、 Or，与或查询，
基本上SQL体系中的关键词都可以使用，例如：LIKE、 IgnoreCase、 OrderBy。
具体的关键字，使用方法和生产成SQL如下表所示：

分页查询,在实际使用中非常普遍了，spring data jpa已经帮我们实现了分页的功能，在查询的方法中，需要传入参数Pageable
,当查询中有多个参数的时候Pageable建议做为最后一个参数传入

Page<User> findALL(Pageable pageable);

Page<User> findByUserName(String userName,Pageable pageable);

Pageable 是spring封装的分页实现类，使用的时候需要传入页数、每页条数和排序规则

@Test
public void testPageQuery() throws Exception {
    int page=1,size=10;
    Sort sort = new Sort(Direction.DESC, "id");
    Pageable pageable = new PageRequest(page, size, sort);
    userRepository.findALL(pageable);
    userRepository.findByUserName("testName", pageable);
}

限制查询
有时候我们只需要查询前N个元素，或者只取前一个实体。

  User findFirstByOrderByLastnameAsc();

  User findTopByOrderByAgeDesc();

  Page<User> queryFirst10ByLastname(String lastname, Pageable pageable);

  List<User> findFirst10ByLastname(String lastname, Sort sort);

  List<User> findTop10ByLastname(String lastname, Pageable pageable);

自定义SQL查询
其实Spring data 觉大部分的SQL都可以根据方法名定义的方式来实现，
但是由于某些原因我们想使用自定义的SQL来查询，spring data也是完美支持的；
在SQL的查询方法上面使用@Query注解，如涉及到删除和修改在需要加上@Modifying.
也可以根据需要添加 @Transactional 对事物的支持，查询超时的设置等

@Modifying
@Query("update User u set u.userName = ?1 where c.id = ?2")
int modifyByIdAndUserId(String  userName, Long id);

@Transactional
@Modifying
@Query("delete from User where id = ?1")
void deleteByUserId(Long id);

@Transactional(timeout = 10)
@Query("select u from User u where u.emailAddress = ?1")
  User findByEmailAddress(String emailAddress);

多表查询
多表查询在spring data jpa中有两种实现方式，第一种是利用hibernate的级联查询来实现，
第二种是创建一个结果集的接口来接收连表查询后的结果，这里主要第二种方式。
首先需要定义一个结果集的接口类。

public interface HotelSummary {

    City getCity();

    String getName();

    Double getAverageRating();

    default Integer getAverageRatingRounded() {
        return getAverageRating() == null ? null : (int) Math.round(getAverageRating());
    }

}

查询的方法返回类型设置为新创建的接口

@Query("select h.city as city, h.name as name, avg(r.rating) as averageRating "
        - "from Hotel h left outer join h.reviews r where h.city = ?1 group by h")
Page<HotelSummary> findByCity(City city, Pageable pageable);

@Query("select h.name as name, avg(r.rating) as averageRating "
        - "from Hotel h left outer join h.reviews r  group by h")
Page<HotelSummary> findByCity(Pageable pageable);
使用

Page<HotelSummary> hotels = this.hotelRepository.findByCity(new PageRequest(0, 10, Direction.ASC, "name"));
for(HotelSummary summay:hotels){
        System.out.println("Name" +summay.getName());
    }

在运行中Spring会给接口（HotelSummary）自动生产一个代理类来接收返回的结果，代码汇总使用getXX的形式来获取

同源数据库的多源支持,
日常项目中因为使用的分布式开发模式，不同的服务有不同的数据源，常常需要在一个项目中使用多个数据源，
因此需要配置sping data jpa对多数据源的使用，一般分一下为三步：

1 配置多数据源
2 不同源的实体类放入不同包路径
3 声明不同的包路径下使用不同的数据源、事务支持

异构数据库多源支持
比如我们的项目中，即需要对mysql的支持，也需要对mongodb的查询等。
实体类声明@Entity 关系型数据库支持类型、声明@Document 为mongodb支持类型，不同的数据源使用不同的实体就可以了

interface PersonRepository extends Repository<Person, Long> {
 …
}

@Entity
public class Person {
  …
}

interface UserRepository extends Repository<User, Long> {
 …
}

@Document
public class User {
  …
}

但是，如果User用户既使用mysql也使用mongodb呢，也可以做混合使用

interface JpaPersonRepository extends Repository<Person, Long> {
 …
}

interface MongoDBPersonRepository extends Repository<Person, Long> {
 …
}

@Entity
@Document
public class Person {
  …
}

也可以通过对不同的包路径进行声明，比如A包路径下使用mysql,B包路径下使用mongoDB

@EnableJpaRepositories(basePackages = "com.neo.repositories.jpa")
@EnableMongoRepositories(basePackages = "com.neo.repositories.mongo")
interface Configuration { }

• 使用枚举,使用枚举的时候，我们希望数据库中存储的是枚举对应的String类型，而不是枚举的索引值，需要在属性上面添加@Enumerated(EnumType.STRING) 注解

  @Enumerated(EnumType.STRING)
  @Column(nullable = true)
  private UserType type;
  

• 不需要和数据库映射的属性,正常情况下我们在实体类上加入注解@Entity，
  就会让实体类和表相关连如果其中某个属性我们不需要和数据库来关联只是在展示的时候做计算，
  只需要加上@Transient属性既可。

  @Transient
  private String  userName;