本文由 简悦 SimpRead 转码， 原文地址 blog.csdn.net
在 Spring Boot 中集成 Apache Phoenix 以便执行 SQL 查询和表操作，你可以使用 Phoenix 的 JDBC 驱动。下面是一个简单的示例，展示了如何在 Spring Boot 应用中集成 Phoenix，并执行基本的表操作和查询。
1. 添加依赖
首先，你需要在你的pom.xml文件中添加 Phoenix 和 HBase 的 JDBC 依赖：
xml复制代码
<dependencies> | |
<!-- Phoenix JDBC client --> | |
<dependency> | |
<groupId>org.apache.phoenix</groupId> | |
<artifactId>phoenix-client</artifactId> | |
<version>YOUR_PHOENIX_VERSION</version> | |
</dependency> | |
<!-- HBase client (根据你的HBase版本可能需要添加这个依赖) --> | |
<dependency> | |
<groupId>org.apache.hbase</groupId> | |
<artifactId>hbase-client</artifactId> | |
<version>YOUR_HBASE_VERSION</version> | |
</dependency> | |
<!-- Spring Boot Starter Data JPA (如果你打算使用JPA的话) --> | |
<dependency> | |
<groupId>org.springframework.boot</groupId> | |
<artifactId>spring-boot-starter-data-jpa</artifactId> | |
</dependency> | |
<!-- 其他依赖... --> | |
</dependencies> |
请确保将YOUR_PHOENIX_VERSION和YOUR_HBASE_VERSION替换为适合你 HBase 集群的版本。
2. 配置 Phoenix JDBC 连接
在application.properties或application.yml中配置 Phoenix JDBC 连接信息：
properties复制代码
# application.properties | |
spring.datasource.url=jdbc:phoenix:YOUR_ZOOKEEPER_QUORUM:2181:/hbase | |
spring.datasource.driver-class-name=org.apache.phoenix.jdbc.PhoenixDriver | |
spring.datasource.username=YOUR_USERNAME | |
spring.datasource.password=YOUR_PASSWORD | |
# 如果使用JPA，配置如下 | |
spring.jpa.database-platform=org.hibernate.dialect.HBase5Dialect | |
spring.jpa.show-sql=true | |
spring.jpa.hibernate.ddl-auto=update |
或者，如果你使用 YAML 格式：
yaml复制代码
# application.yml | |
spring: | |
datasource: | |
url: jdbc:phoenix:YOUR_ZOOKEEPER_QUORUM:2181:/hbase | |
driver-class-name: org.apache.phoenix.jdbc.PhoenixDriver | |
username: YOUR_USERNAME | |
password: YOUR_PASSWORD | |
jpa: | |
database-platform: org.hibernate.dialect.HBase5Dialect | |
show-sql: true | |
hibernate: | |
ddl-auto: update |
将YOUR_ZOOKEEPER_QUORUM、YOUR_USERNAME和YOUR_PASSWORD替换为你的 Zookeeper 集群地址、用户名和密码（如果有的话）。
3. 创建表
你可以使用 JdbcTemplate 或 JPA 来创建表。以下是一个使用 JdbcTemplate 的示例：
java复制代码
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.jdbc.core.JdbcTemplate; | |
import org.springframework.stereotype.Component; | |
@Component | |
public class PhoenixTableCreator { | |
private final JdbcTemplate jdbcTemplate; | |
@Autowired | |
public PhoenixTableCreator(JdbcTemplate jdbcTemplate) { | |
this.jdbcTemplate = jdbcTemplate; | |
} | |
public void createTable() { | |
String sql = "CREATE TABLE IF NOT EXISTS my_table (" + | |
"id BIGINT NOT NULL PRIMARY KEY," + | |
"name VARCHAR," + | |
"age INTEGER" + | |
")"; | |
jdbcTemplate.execute(sql); | |
} | |
} |
4. 执行查询
使用 JdbcTemplate 执行查询：
java复制代码
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.jdbc.core.JdbcTemplate; | |
import org.springframework.jdbc.core.RowMapper; | |
import org.springframework.stereotype.Component; | |
import java.sql.ResultSet; | |
import java.sql.SQLException; | |
import java.util.List; | |
@Component | |
public class PhoenixQueryExecutor { | |
private final JdbcTemplate jdbcTemplate; | |
@Autowired | |
public PhoenixQueryExecutor(JdbcTemplate jdbcTemplate) { | |
this.jdbcTemplate = jdbcTemplate; | |
} | |
public List<MyEntity> selectAll() { | |
String sql = "SELECT * FROM my_table"; | |
return jdbcTemplate.query(sql, new RowMapper<MyEntity>() { | |
@Override | |
public MyEntity mapRow(ResultSet rs, int rowNum) throws SQLException { |
java复制代码
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.jdbc.core.JdbcTemplate; | |
import org.springframework.jdbc.core.RowMapper; | |
import org.springframework.stereotype.Component; | |
import java.sql.ResultSet; | |
import java.sql.SQLException; | |
import java.util.List; | |
@Component | |
public class PhoenixQueryExecutor { | |
private final JdbcTemplate jdbcTemplate; | |
@Autowired | |
public PhoenixQueryExecutor(JdbcTemplate jdbcTemplate) { | |
this.jdbcTemplate = jdbcTemplate; | |
} | |
public List<MyEntity> selectAll() { | |
String sql = "SELECT * FROM my_table"; | |
return jdbcTemplate.query(sql, new RowMapper<MyEntity>() { | |
@Override | |
public MyEntity mapRow(ResultSet rs, int rowNum) throws SQLException { | |
MyEntity entity = new MyEntity(); | |
entity.setId(rs.getLong("id")); | |
entity.setName(rs.getString("name")); | |
entity.setAge(rs.getInt("age")); | |
return entity; | |
} | |
}); | |
} | |
// 其他查询方法... | |
} | |
class MyEntity { | |
private Long id; | |
private String name; | |
private Integer age; | |
// Getter and setter methods... | |
} |
在这个例子中，MyEntity类代表从my_table表中检索的实体。selectAll方法执行一个简单的 SELECT 查询，并使用RowMapper将结果集中的每一行映射到MyEntity对象。
5. 执行插入、更新和删除操作
你可以使用 JdbcTemplate 的update方法来执行插入、更新和删除操作：
java复制代码
public void insert(MyEntity entity) { | |
String sql = "UPSERT INTO my_table (id, name, age) VALUES (?, ?, ?)"; | |
jdbcTemplate.update(sql, entity.getId(), entity.getName(), entity.getAge()); | |
} | |
public void update(MyEntity entity) { | |
String sql = "UPSERT INTO my_table (id, name, age) VALUES (?, ?, ?) ON DUPLICATE KEY UPDATE name=?, age=?"; | |
jdbcTemplate.update(sql, entity.getId(), entity.getName(), entity.getAge(), entity.getName(), entity.getAge()); | |
} | |
public void delete(Long id) { | |
String sql = "DELETE FROM my_table WHERE id = ?"; | |
jdbcTemplate.update(sql, id); | |
} |
6. 使用 JPA（可选）
如果你更倾向于使用 JPA 而不是 JdbcTemplate，你可以创建实体类、仓库接口，并使用 Spring Data JPA 的功能。但是，请注意，Phoenix 的 JPA 支持可能有限，并且可能不支持所有 JPA 特性。
注意：
- 确保你的 Phoenix 和 HBase 版本兼容。
- 在生产环境中，你可能需要配置连接池和更复杂的错误处理。
- 根据你的具体需求，你可能还需要配置事务管理。
最后，请确保在运行应用程序之前，你的 HBase 集群和 Phoenix 都是运行正常的，并且 Zookeeper 的地址、用户名和密码（如果有的话）都是正确的。