【Spring-boot-route(九)整合JPA操作数据库+(十)多数据源切换】

时间:2023-02-10 12:09:53

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 测试多数据源

【Spring-boot-route(九)整合JPA操作数据库+(十)多数据源切换】

这里分享一道面试题:@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中采用的就是这种方式。