配置 JPA 并初始化数据

2025 年 1 月 9 日 | 阅读时长 3 分钟

在上一节中，我们对汇率的值进行了硬编码。它来自数据库。在本节中，我们将创建一个与内存数据库的连接。

让我们看看如何将微服务连接到 H2 数据库。按照以下步骤将微服务连接到 JPA 内存数据库。

步骤 1： 打开 currency-exchange-service 的 pom.xml 文件，并添加以下两个依赖项。

<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<version>1.4.197</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
<version>2.1.3.RELEASE</version>
</dependency>

添加依赖项后，现在我们需要定义实体。

步骤 2： 打开 ExchangeValue.java 文件并执行以下操作

在类级别添加 @Entity 注解。
使用注解 @Table 定义表名。
通过添加注解 @Id 为实体定义一个 Id。
通过在每个字段上方添加注解 @Column 并指定列名来定义列。

ExchangeValue.java

package com.javatpoint.microservices.currencyexchangeservice;
import java.math.BigDecimal;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Entity
@Table(name="Exchange_Value")
public class ExchangeValue 
{
@Id
@Column(name="id")
private Long id;
@Column(name="currency_from")
private String from;
@Column(name="currency_to")
private String to;
@Column(name="conversion_multiple")
private BigDecimal conversionMultiple;
@Column(name="port")
private int port;
//default conatructor
public ExchangeValue()
{	
}
//generating constructor using fields
public ExchangeValue(Long id, String from, String to, BigDecimal conversionMultiple) 
{
super();
this.id = id;
this.from = from;
this.to = to;
this.conversionMultiple = conversionMultiple;
}
//generating getters and setters
public int getPort() 
{
return port;
}
public void setPort(int port) 
{
this.port = port;
}
public Long getId() 
{
return id;
}
public String getFrom() 
{
return from;
}
public String getTo() 
{
return to;
}
public BigDecimal getConversionMultiple() 
{
return conversionMultiple;
}
}

我们已经创建了实体，现在我们需要将一些数据插入到数据库中。

步骤 3： 创建一个 data.sql 文件，用于将数据插入到数据库中。

右键单击文件夹 src/main/resources -> 新建 -> 文件 -> 提供名称 data.sql -> 完成

步骤 4： 将数据插入到 data.sql 文件中。我们插入了以下数据

data.sql

insert into exchange_value(id,currency_from,currency_to,conversion_multiple,port)
values(10001,'USD', 'INR' ,65,0);
insert into exchange_value(id,currency_from,currency_to,conversion_multiple,port)
values(10002,'EUR', 'INR' ,75,0);
insert into exchange_value(id,currency_from,currency_to,conversion_multiple,port)
values(10003,'AUD', 'INR' ,25,0);

步骤 5： 打开 application.properties 文件并启用 H2 控制台， 配置 URL 和 数据源。默认的 JDBC URL 是 testdb。我们可以指定我们自己的 JDBC URL。

我们指定了 JDBS URL：jdbc:h2:mem:javatpoint

application.properties

spring.application.name=currency-exchange-service
server.port=8000
spring.jpa.show-sql=true
spring.h2.console.enabled=true
spring.datasource.platform=h2
spring.datasource.url=jdbc:h2:mem:javatpoint

步骤 6： 重新启动应用程序。

步骤 7： 打开浏览器并键入 URI https://:8000/currency-exchange/from/USD/to/INR。它返回响应，如下所示