springboot项目新增数据库和es
时间: 2023-09-29 10:09:51 浏览: 71
为了在Spring Boot项目中新增数据库和ES,你需要进行以下步骤:
1. 添加依赖:在pom.xml文件中添加数据库和ES的依赖,比如MySQL和Elasticsearch:
```
<!-- MySQL -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Elasticsearch -->
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
</dependency>
```
2. 配置数据源:在application.properties(或application.yml)文件中配置数据库的连接信息,比如:
```
spring.datasource.url=jdbc:mysql://localhost:3306/test
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
```
3. 配置ES客户端:在配置文件中配置ES客户端的连接信息,比如:
```
spring.data.elasticsearch.cluster-name=my-application
spring.data.elasticsearch.cluster-nodes=localhost:9300
```
4. 创建实体类:创建需要存储到数据库和ES中的实体类,比如:
```
@Entity
@Table(name = "user")
public class User {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;
@Column(name = "name")
private String name;
@Column(name = "age")
private Integer age;
// 省略 getter/setter 方法
}
```
5. 创建Repository:创建用于访问数据库的Repository和ES的Repository,比如:
```
@Repository
public interface UserRepository extends JpaRepository<User, Long> {
}
@Repository
public interface UserEsRepository extends ElasticsearchRepository<User, Long> {
}
```
6. 使用数据源:在代码中使用数据源进行数据库和ES的读写操作,比如:
```
// 保存到数据库
User user = new User();
user.setName("Tom");
user.setAge(18);
userRepository.save(user);
// 保存到ES
User user = new User();
user.setName("Tom");
user.setAge(18);
userEsRepository.save(user);
// 查询数据库
List<User> userList = userRepository.findAll();
// 查询ES
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(QueryBuilders.matchQuery("name", "Tom"))
.build();
List<User> userList = elasticsearchTemplate.queryForList(searchQuery, User.class);
```
以上就是在Spring Boot项目中新增数据库和ES的步骤。
阅读全文