Spring-boot-route整合JPA操作数据库+多数据源切换

Posted 2023-02-10

spring-boot-route（九）整合JPA操作数据库

单调的增删改查让越来越多的程序员感到乏味，这时候就出现了很多优秀的框架，完成了对增删改查操作的封装，只需要简单配置，无需书写任何sql，就可以完成增删改查。这里比较推荐的是Spring Data Jpa。

Spring Data JPA是Spring Data家族的一部分，可以轻松实现基于JPA的存储库。 此模块处理对基于JPA的数据访问层的增强支持。 它使构建使用数据访问技术的Spring驱动应用程序变得更加容易。

我们继续使用前两章用的数据库结构来进行演示。

一 引入mysql和spring-data-jpa依赖

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

二 创建实体类

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
public class Student implements Serializable 

    private static final long serialVersionUID = 6712540741269055064L;

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer studentId;
    private Integer age;
    private String name;
    private Integer sex;
    private Date createTime;
    private Integer status;

@GeneratedValue是主键生成策略，Jpa自带的几种主键生成策略如下：

• TABLE： 使用一个特定的数据库表格来保存主键
• SEQUENCE： 根据底层数据库的序列来生成主键，条件是数据库支持序列。这个值要与generator一起使用，generator 指定生成主键使用的生成器（可能是orcale中自己编写的序列）
• IDENTITY： 主键由数据库自动生成（主要是支持自动增长的数据库，如mysql）
• AUTO： 主键由程序控制，也是GenerationType的默认值

主键生成策略扩展

自定义主键生成器：

public class MyGenerator implements IdentifierGenerator 
    
    @Override
    public Serializable generate(SharedSessionContractImplementor sharedSessionContractImplementor, Object o) throws HibernateException 
        return getId();
    
    
    public static long getId()
        return System.currentTimeMillis();
    

然后在实体类做一下配置：

@Data
@NoArgsConstructor
@AllArgsConstructor
@Entity
public class Student implements Serializable 

    private static final long serialVersionUID = 6712540741269055064L;

    @Id
    @GenericGenerator(name="idGenerator",strategy = "com.javatrip.springdatajpa.entity.MyGenerator")
    @GeneratedValue(generator = "idGenerator")
    private Integer studentId;
    private Integer age;
    private String name;
    private Integer sex;
    private Date createTime;
    private Integer status;

三 创建dao接口

dao层接口实现JpaRepository，泛型选择pojo和其主键类型，就会自动实现简单的CRUD等接口，无需手动开发，就能快速进行调用。

public interface StudentRepository extends JpaRepository<Student,Integer> 

    /**
     * 根据年龄，名字模糊查询
     * @return
     */
    Student findByNameLikeAndAge(String name,int age);

Jpa除了实现CRUD方法，还支持字段名模糊查询等各种不用手写sql的操作。

四 测试类测试CRUD

@SpringBootTest
class SpringDataJpaApplicationTests 

    @Autowired
    StudentRepository repository;
    @Test
    void contextLoads() 
        // 查询所有实体
        List<Student> all = repository.findAll();
        // 根据id查询实体类
        Optional<Student> byId = repository.findById(100);
        // 根据id删除数据
        repository.deleteById(100);
        // 插入一条数据
        // 如果数据库存在该实体的主键，则更新，否则插入
        Student student = new Student();
        student.setAge(18);
        student.setName("Java旅途");
        repository.save(student);

        repository.findByNameLikeAndAge("Java",18);
    

spring-data-jpa在外国程序员界非常普遍。相比其他两种方式，它不需要写sql就可以完成非常完善的数据操作，我也是比较推荐使用它作为orm框架。

》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》》

​

​

接下来我们讲解：

【spring-boot-route（十）多数据源切换】

​前面我们已经介绍了三种方式来操作数据库，在实际开发中，往往会出现一个服务连接多个数据库的需求，这时候就需要在项目中进行灵活切换数据源来完成多个数据库操作。这一章中，我们使用jdbcTemplate来学习多数据源的配置。

​

一 准备工作

1.1 建库、建表

我们新建两个库​​db1​​和​​db2​​，数据结构还是用前面演示的，分别在两个库中新建表​​student​​。

CREATE TABLE `student` (
   `student_id` int(30) NOT NULL AUTO_INCREMENT,
   `age` int(1) DEFAULT NULL COMMENT 年龄,
   `name` varchar(45) DEFAULT NULL COMMENT 姓名,
   `sex` int(1) DEFAULT NULL COMMENT 性别：1：男，2：女，0：未知,
   `create_time` datetime DEFAULT NULL COMMENT 创建时间,
   `status` int(1) DEFAULT NULL COMMENT 状态：1：正常，-1：删除,
   PRIMARY KEY (`student_id`)
 ) ENGINE=InnoDB CHARSET=utf8mb4 CHECKSUM=1 DELAY_KEY_WRITE=1 ROW_FORMAT=DYNAMIC COMMENT=学生表

1.2 引入mysql和jdbcTemplate依赖

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.11</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

1.3 写入两个数据源配置

spring:
  datasource:
    db1:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://localhost:3306/db1
      username: root
      password: root
    db2:
      driver-class-name: com.mysql.cj.jdbc.Driver
      jdbc-url: jdbc:mysql://localhost:3306/db2
      username: root
      password: root

二 多数据源配置

@Configuration
public class DataSourceConfig 

    @Primary
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.db1")
    public DataSource db1DataSource()
        return DataSourceBuilder.create().build();
    

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.db2")
    public DataSource db2DataSource()
        return DataSourceBuilder.create().build();
    

• @Primary：表示主的，即出现多个bean的时候如果不指定具体的bean，则会采用这个
• @bean：标注为一个bean，如果不指定name属性，则会使用创建bean方法的名字做为bean的名字
• @ConfigurationProperties：读取配置文件

三 配置JdbcTemplate对象

@Configuration
public class DataSourceConfig 
    
    @Bean
    public JdbcTemplate db1JdbcTemplate(@Qualifier("db1DataSource") DataSource dataSource)
        return new JdbcTemplate(dataSource);
    
    @Primary
    @Bean
    public JdbcTemplate db2JdbcTemplate(@Qualifier("db2DataSource") DataSource dataSource)
        return new JdbcTemplate(dataSource);
    

• @Qualifier：bean类型相同后，指定使用的bean的name

四 测试类

4.1 测试@Primary属性

不指定使用哪个JdbcTemplate对象时，会使用标注了@Primary属性的对象

@SpringBootTest
class SpringBootDatasourceApplicationTests 
    
    @Autowired
    private JdbcTemplate jdbcTemplate;
    
    @Test
    void testPrimary() 
        jdbcTemplate.update("insert into student(name,age) values(?,?)",new Object[]"Java旅途",18);
    

4.2 测试多数据源

这里分享一道面试题：@Autowired 与@Resource有什么区别？

@Autowired是Spring提供的，@Resource是JDK提供的；

@Autowired是根据bean的类型匹配的，@Resource是根据bean的name匹配的；

如果@Autowird想要根据name匹配应该怎么做呢？

1. 配合@Qualifier注解指定bean的name
2. 使用变量名称作为bean的id，@Autowired如果匹配到多个符合条件的对象后，会自动根据变量名称做为bean的id继续匹配。我们在4.2中采用的就是这种方式。