返回 导航

SpringBoot / Cloud

hangge.com

SpringBoot - 使用Phoenix操作HBase教程2（使用JdbcTemplate）

作者：hangge | 2020-09-15 08:10
    前文演示了借助 Apache Phoenix，我们使用标准 SQL 和 JDBC 接口来操作 HBase。而 JdbcTemplate 是 Spring 提供的一套 JDBC 模版框架，Spring Boot 项目自然也可以使用它来操作 HBase 数据库，下面通过样例进行演示。

二、使用 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 实体类：
@Setter
@Getter
@NoArgsConstructor
@ToString
public class Student {
    private String id;
    private String name;
    private String age;
}

（2）接着通过 JdbcTemplate 来对表以及表数据进行增删改查操作：
1，表名为什么加引号？
  • 在 phoenix 中，默认情况下，库名，表名，字段名等会自动转换为大写，若要小写，使用双引号，如"student"。
2，是否需要 Phoenix JDBC 连接池？
  • 答案是不需要缓存 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
具体关闭方法参考我之前写的另一篇文章：
评论

全部评论（0）

回到顶部