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

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));
}
}