【笔记】springboot使用Spring-data-jpa

╰半夏微凉° 2022-11-05 08:48 11阅读 0赞

## Spring-data-jpa ##

Spring-data-jpa依赖于Hibernate。通过整合Hibernate之后，我们以操作Java实体的⽅式最终将数据改变映射到数据库表中。  
添加依赖:

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

在 application.xml 中配置：数据库连接信息（如使⽤嵌⼊式数据库则不需要）、⾃动创建表结构的  
设置，例如使⽤mysql的情况如下：  
spring.datasource.url=jdbc:mysql://localhost:3308/data1  
spring.datasource.username=root  
spring.datasource.password=root  
spring.datasource.driver-class-name=com.mysql.jdbc.Driver  
spring.jpa.properties.hibernate.hbm2ddl.auto=create-drop

spring.jpa.properties.hibernate.hbm2ddl.auto 是hibernate的配置属性，其主要作⽤是：⾃动创建、更新、验证数据库表结构。该参数的⼏种配置如下：  
create ：每次加载hibernate时都会删除上⼀次的⽣成的表，然后根据你的model类再重新来⽣成新表，哪怕两次没有任何改变也要这样执⾏，这就是导致数据库表数据丢失的⼀个重要原因。  
create-drop ：每次加载hibernate时根据model类⽣成表，但是sessionFactory⼀关闭,表就⾃动删除。  
update ：最常⽤的属性，第⼀次加载hibernate时根据model类会⾃动建⽴起表的结构（前提是先建⽴好数据库），以后加载hibernate时根据model类⾃动更新表结构，即使表结构改变了但表中的⾏仍然存在不会删除以前的⾏。要注意的是当部署到服务器后，表结构是不会被⻢上建⽴起来的，是要等应⽤第⼀次运⾏起来后才会。  
validate ：每次加载hibernate时，验证创建数据库表结构，只会和数据库中的表进⾏⽐较，不会创建新表，但是会插⼊新值。

创建实体  
创建⼀个User实体，包含id（主键）、name（姓名）、age（年龄）属性，通过ORM框架其会被映射到数据库表中，由于配置了 hibernate.hbm2ddl.auto ，在应⽤启动的时候框架会⾃动去数据库中创建对应的表。

@Entity
    public class User { 
    @Id
    @GeneratedValue
    private Long id;
    @Column(nullable = false)
    private String name;
    @Column(nullable = false)
    private Integer age;
    // 省略构造函数
    // 省略getter和setter
    }

创建数据访问接⼝  
下⾯针对User实体创建对应的 Repository 接⼝实现对该实体的数据访问，如下代码：

public interface UserRepository extends JpaRepository<User, Long> { 
    User findByName(String name);
    User findByNameAndAge(String name, Integer age);
    @Query("from User u where u.name=:name")
    User findUser(@Param("name") String name);
    }

在Spring-data-jpa中，只需要编写类似上⾯这样的接⼝就可实现数据访问。不再像我们以往编写了接⼝时候还需要⾃⼰编写接⼝实现类，直接减少了我们的⽂件清单。  
在上例中，我们可以看到下⾯两个函数：  
User findByName(String name)  
User findByNameAndAge(String name, Integer age)  
它们分别实现了按name查询User实体和按name和age查询User实体，可以看到我们这⾥没有任何类 SQL语句就完成了两个条件查询⽅法。这就是Spring-data-jpa的⼀⼤特性：通过解析⽅法名创建查询。

## 单元测试 ##

在完成了上⾯的数据访问接⼝之后，按照惯例就是编写对应的单元测试来验证编写的内容是否正确。

@RunWith(SpringJUnit4ClassRunner.class)
    @SpringApplicationConfiguration(Application.class)
    public class ApplicationTests { 
    @Autowired
    private UserRepository userRepository;
    @Test
    public void test() throws Exception { 
    // 创建10条记录
    userRepository.save(new User("AAA", 10));
    userRepository.save(new User("BBB", 20));
    userRepository.save(new User("CCC", 30));
    userRepository.save(new User("DDD", 40));
    userRepository.save(new User("EEE", 50));
    userRepository.save(new User("FFF", 60));
    userRepository.save(new User("GGG", 70));
    userRepository.save(new User("HHH", 80));
    userRepository.save(new User("III", 90));
    userRepository.save(new User("JJJ", 100));
    // 测试findAll, 查询所有记录
    Assert.assertEquals(10, userRepository.findAll().size());
    // 测试findByName, 查询姓名为FFF的User
    Assert.assertEquals(60, userRepository.findByName("FFF").getAge().longValue());
    // 测试findUser, 查询姓名为FFF的User
    Assert.assertEquals(60, userRepository.findUser("FFF").getAge().longValue());
    // 测试findByNameAndAge, 查询姓名为FFF并且年龄为60的User
    Assert.assertEquals("FFF", userRepository.findByNameAndAge("FFF", 60).getName());
    // 测试删除姓名为AAA的User
    userRepository.delete(userRepository.findByName("AAA"));
    // 测试findAll, 查询所有记录, 验证上⾯的删除是否成功
    Assert.assertEquals(9, userRepository.findAll().size());
    }

## 多数据源配置： ##

创建⼀个Spring配置类，定义两个DataSource⽤来读取 application.properties 中的不同配置。如下例⼦中，主数据源配置为 spring.datasource.primary 开头的配置，第⼆数据源配置为 spring.datasource.secondary 开头的配置。

@Configuration
    public class DataSourceConfig { 
    @Bean(name = "primaryDataSource")
    @Qualifier("primaryDataSource")
    @ConfigurationProperties(prefix="spring.datasource.primary")
    public DataSource primaryDataSource() { 
    return DataSourceBuilder.create().build();
    }
    @Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    @Primary
    @ConfigurationProperties(prefix="spring.datasource.secondary")
    public DataSource secondaryDataSource() { 
    return DataSourceBuilder.create().build();
    }
    }

对应的 application.properties 配置如下：  
spring.datasource.primary.url=jdbc:mysql://localhost:3306/test1  
spring.datasource.primary.username=root  
spring.datasource.primary.password=root  
spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver  
spring.datasource.secondary.url=jdbc:mysql://localhost:3306/test2  
spring.datasource.secondary.username=root  
spring.datasource.secondary.password=root  
spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

## JdbcTemplate⽀持 ##

对JdbcTemplate的⽀持⽐较简单，只需要为其注⼊对应的datasource即可，如下例⼦，在创建JdbcTemplate的时候分别注⼊名为 primaryDataSource 和 secondaryDataSource 的数据源来区分不同的JdbcTemplate。

@Bean(name = "primaryJdbcTemplate")
    public JdbcTemplate primaryJdbcTemplate(
    @Qualifier("primaryDataSource") DataSource dataSource) { 
    return new JdbcTemplate(dataSource);
    }
    @Bean(name = "secondaryJdbcTemplate")
    public JdbcTemplate secondaryJdbcTemplate(
    @Qualifier("secondaryDataSource") DataSource dataSource) { 
    return new JdbcTemplate(dataSource);
    }
    //接下来通过测试⽤例来演示如何使⽤这两个针对不同数据源的JdbcTemplate。
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringApplicationConfiguration(Application.class)
    public class ApplicationTests { 
    @Autowired
    @Qualifier("primaryJdbcTemplate")
    protected JdbcTemplate jdbcTemplate1;
    @Autowired
    @Qualifier("secondaryJdbcTemplate")
    protected JdbcTemplate jdbcTemplate2;
    @Before
    public void setUp() { 
    jdbcTemplate1.update("DELETE FROM USER ");
    jdbcTemplate2.update("DELETE FROM USER ");
    }
    @Test
    public void test() throws Exception { 
    // 往第⼀个数据源中插⼊两条数据
    jdbcTemplate1.update("insert into user(id,name,age) values(?, ?, ?)", 1, "aaa", 20
    );
    jdbcTemplate1.update("insert into user(id,name,age) values(?, ?, ?)", 2, "bbb", 30
    );
    jdbcTemplate2.update("insert into user(id,name,age) values(?, ?, ?)", 1, "aaa", 20
    );
    查⼀下第⼀个数据源中是否有两条数据，验证插⼊是否成功
    Assert.assertEquals("2", jdbcTemplate1.queryForObject("select count(1) from user",
    String.class));
    // 查⼀下第⼀个数据源中是否有两条数据，验证插⼊是否成功
    Assert.assertEquals("1", jdbcTemplate2.queryForObject("select count(1) from user",
    String.class));
    }
    }