SpringBoot - 使用Phoenix操作HBase教程2(使用JdbcTemplate)
前文演示了借助 Apache Phoenix,我们使用标准 SQL 和 JDBC 接口来操作 HBase。而 JdbcTemplate 是 Spring 提供的一套 JDBC 模版框架,Spring Boot 项目自然也可以使用它来操作 HBase 数据库,下面通过样例进行演示。
(3)最后在 application.properties 中配置数据库连接信息:
二、使用 JdbcTemplate
1,准备工作
(1)同前文一样,服务器除了要安装 HBase 外,还需要安装 Phoenix,具体参考我之前写的文章:
(2)接着编辑项目的 pom.xml 文件,除了添加 Phoenix 相关依赖外,还添加 spring-boot-starter-jdbc 依赖(高亮部分):
<dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <!-- 去掉springboot默认日志配置 --> <exclusions> <exclusion> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-logging</artifactId> </exclusion> </exclusions> </dependency> <!-- 引入log4j2依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-log4j2</artifactId> </dependency> <!-- 引入lombok依赖 --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.6</version> </dependency> <!-- spring-jdbc --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId> </dependency> <!-- phoenix相关依赖配置 --> <dependency> <groupId>org.apache.phoenix</groupId> <artifactId>phoenix-core</artifactId> <version>5.0.0-HBase-2.0</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>joda-time</groupId> <artifactId>joda-time</artifactId> </exclusion> <exclusion> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-common</artifactId> <version>2.9.2</version> <exclusions> <exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> </exclusion> <exclusion> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>joda-time</groupId> <artifactId>joda-time</artifactId> <version>2.3</version> </dependency> </dependencies>
(3)最后在 application.properties 中配置数据库连接信息:
spring.datasource.driverClassName=org.apache.phoenix.jdbc.PhoenixDriver spring.datasource.url=jdbc:phoenix:192.168.60.133:2181
2,编写代码
(1)首先创建一个 Student 实体类:
(2)启动项目,使用浏览器访问 /test 接口可以看到控制台输出如下,说明数据库操作成功:
@Setter @Getter @NoArgsConstructor @ToString public class Student { private String id; private String name; private String age; }
(2)接着通过 JdbcTemplate 来对表以及表数据进行增删改查操作:
1,表名为什么加引号?
- 在 phoenix 中,默认情况下,库名,表名,字段名等会自动转换为大写,若要小写,使用双引号,如"student"。
- 答案是不需要缓存 Phoenix JDBC 连接池。由于 HBase 的特殊性,Phoenix 连接对象有别于其他常规的 JDBC 连接。Phoenix 连接被设计为 thin 对象,创建它的代价很小。如果使用连接池来重用 HBase 连接,前一个用户的非正常退出可能会导致连接处于错误状态。因此最好每次创建一个新的连接。
- 如果实在需要使用连接池,可以对 Phoenix 连接做简单的代理,每次需要从池中获取连接的时候初始化一个就好,而将连接归还到连接池之后就把它关闭掉。
@RestController public class HelloController { @Autowired JdbcTemplate jdbcTemplate; @GetMapping("/test") public void test() { // 创建表 System.out.println("\n--- 开始创建 student 表 ---"); String sql = "CREATE TABLE IF NOT EXISTS \"student\"(" + "id VARCHAR primary key," + "name VARCHAR," + "age VARCHAR)"; jdbcTemplate.execute(sql); // 插入数据 System.out.println("\n--- 开始插入数据 ---"); jdbcTemplate.update("upsert into \"student\" values('1001','大刘','20')"); jdbcTemplate.update("upsert into \"student\" values('1002','小星','22')"); jdbcTemplate.update("upsert into \"student\" values(?, ?, ?)", "1003", "hangge", "100"); // 删除数据 System.out.println("\n--- 开始删除数据 ---"); jdbcTemplate.update("DELETE FROM \"student\" WHERE id=?", "1002"); // 查询数据 System.out.println("\n--- 开始查询数据 ---"); List<Student> list = jdbcTemplate.query("SELECT * FROM \"student\"", new BeanPropertyRowMapper<>(Student.class)); System.out.println(list); //删除表 System.out.println("\n--- 开始删除 student 表 ---"); jdbcTemplate.execute("drop table \"student\""); } }
(2)启动项目,使用浏览器访问 /test 接口可以看到控制台输出如下,说明数据库操作成功:
如果 Phoenix 开启了 SCHEMA,建议将其关闭,否则连接时会报如下错误:
- ava.sql.SQLException: ERROR 726 (43M10): Inconsistent namespace mapping properties. Cannot initiate connection as SYSTEM:CATALOG is found but client does not have phoenix.schema.isNamespaceMappingEnabled enabled