springboot集成phoenix
时间: 2023-11-21 07:56:36 浏览: 136
以下是Spring Boot集成Phoenix的步骤:
1.添加Phoenix依赖
在pom.xml文件中添加以下依赖:
```xml
<dependency>
<groupId>org.apache.phoenix</groupId>
<artifactId>phoenix-core</artifactId>
<version>4.14.3-HBase-1.4</version>
</dependency>
```
2.配置Phoenix数据源
在application.properties文件中添加以下配置:
```properties
spring.datasource.url=jdbc:phoenix:localhost:2181:/hbase
spring.datasource.driver-class-name=org.apache.phoenix.jdbc.PhoenixDriver
```
3.创建Phoenix数据表
可以使用Phoenix提供的SQL语句来创建数据表,例如:
```sql
CREATE TABLE IF NOT EXISTS TEST (
ID BIGINT NOT NULL PRIMARY KEY,
NAME VARCHAR
);
```
4.使用Phoenix数据源
在代码中使用Phoenix数据源,例如:
```java
@Autowired
private DataSource dataSource;
public void query() throws SQLException {
try (Connection conn = dataSource.getConnection();
PreparedStatement statement = conn.prepareStatement("SELECT * FROM TEST WHERE ID = ?")) {
statement.setLong(1, 1L);
try (ResultSet rs = statement.executeQuery()) {
while (rs.next()) {
System.out.println(rs.getLong("ID") + ", " + rs.getString("NAME"));
}
}
}
}
```
阅读全文