SpringBoot整合Mybatis以及Phoenix

迈不过友情╰ 2022-09-01 09:20 433阅读 0赞

## Phenix介绍 ##

Phoenix是由saleforce.com开源的一个项目，后又捐给了Apache基金会。 它相当于一个Java中间件，提供jdbc连接，操作hbase数据表。 Phoenix是一个HBase的开源SQL引擎。 你可以使用标准的JDBC API代替HBase客户端API来创建表，插入数据，查询你的HBase数据。

## 前期准备 ##

jdk >= 1.8  
HBase 2.3.5  
Hadoop 3.2.2  
Phoenix 2.3-5.1.1-bin  
SpringBoot 2.2.5.RELEASE  
Mybatis  
Druid

## 注意事项 ##

1.安装phoenix时，需要与hbase版本保持一致  
2.根据对照表，进行hbase与hadoop安装

## 开始构建springboot ##

通过maven提供的quickstart-springboot脚手架直接构建

## 添加依赖 ##

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <groupId>cn.xxx.xxx</groupId>
            <artifactId>xxx-xxx-service-group</artifactId>
            <version>1.0-SNAPSHOT</version>
            <relativePath>../pom.xml</relativePath>
        </parent>
        <modelVersion>4.0.0</modelVersion>
        <artifactId>test-service</artifactId>
    
        <name>xxx/name>
        <description>xxx模块</description>
        <version>1.0-SNAPSHOT</version>
    
    	<dependencies>
    		
    		
    		<dependency>
    			<groupId>org.apache.hbase</groupId>
    			<artifactId>hbase-client</artifactId>
    			<version>2.4.4</version>
    			<exclusions>
    				<exclusion>  
    					<groupId>org.slf4j</groupId>
    					<artifactId>slf4j-api</artifactId>
    				</exclusion>
    				<exclusion>
    					<groupId>org.slf4j</groupId>
    					<artifactId>jcl-over-slf4j</artifactId>
    				</exclusion>
    				<exclusion>
    					<groupId>org.slf4j</groupId>
    					<artifactId>jul-to-slf4j</artifactId>
    				</exclusion>
    				<exclusion>
    					<groupId>org.slf4j</groupId>
    					<artifactId>slf4j-log4j12</artifactId>
    				</exclusion>
    			</exclusions>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.apache.phoenix</groupId>
    			<artifactId>phoenix-core</artifactId>
    			<version>5.1.1</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>
    				<exclusion>
    					<groupId>com.google.protobuf</groupId>
    					<artifactId>protobuf-java</artifactId>
    				</exclusion>
    			</exclusions>
    		</dependency>
    		
    		<dependency>
    			<groupId>org.apache.phoenix</groupId>
    			<artifactId>phoenix-hbase-compat-2.2.5</artifactId>
    			<version>5.1.2</version>
    		</dependency>
    		<dependency>
    			<groupId>com.google.protobuf</groupId>
    			<artifactId>protobuf-java</artifactId>
    			<version>2.6.0</version>
    		</dependency>
    
    	</dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    </project>

## 添加配置项 ##

## 数据源配置 ##

companyapp.datasources.hbaseDataSource.url = jdbc:phoenix:{zookeeperIP}:2181
    companyapp.datasources.hbaseDataSource.username =
    companyapp.datasources.hbaseDataSource.password =
    companyapp.datasources.hbaseDataSource.driverClassName = org.apache.phoenix.jdbc.PhoenixDriver
    companyapp.datasources.hbaseDataSource.min-idle = 0
    companyapp.datasources.hbaseDataSource.initial-size = 5
    companyapp.datasources.hbaseDataSource.max-active = 40
    companyapp.datasources.hbaseDataSource.max-wait = 60000
    companyapp.datasources.hbaseDataSource.name = hbaseDataSource

## mybatis ##

companyapp.mybatis.hbaseAticleSource.mapper-package = cn.xxxxx.service.dao.hbase.article
    companyapp.mybatis.hbaseAticleSource.datasource = hbaseDataSource

## Mybatis配置 ##

mybatis.configuration.mapUnderscoreToCamelCase = true
    mybatis.mapper-locations = classpath*:mapper/*.xml

## 开始编写代码 ##

**新建xml，位于resource下**

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    <mapper namespace="cn.xxxxx.service.dao.hbase.article.ArticleNewsDao">
    
    	<resultMap type="cn.xxxxx.service.entity.ArticleNewsEntity" id="ArticleNewsEntity">
    		<result property="articleId" column="id"/>
    		<result property="content" column="content"/>
    		<result property="category" column="category"/>
    		<result property="sourceUrl" column="sourceUrl"/>
    		<result property="postDate" column="postDate"/>
    		<result property="addedDate" column="addedDate"/>
    		<result property="attachmentPath" column="attachmentPath"/>
    		<result property="created" column="created"/>
    		<result property="modified" column="modified"/>
    	</resultMap>
    
    	<select id="queryByArticleId" resultMap="ArticleNewsEntity">
    		SELECT * from "article_news" where id = #{articleId}
    	</select>
    
    </mapper>

## 新建DAO ##

package cn.xxxx.service.dao.hbase.article;
    
    import cn.xxxxicleNewsEntity;
    import org.apache.ibatis.annotations.Param;
    
    /**
     * @program: xxxxx-service-group
     * @description: ArticleNewsDao
     * @author: Jason
     * @create: 2021-07-27 13:54
     **/
    public interface ArticleNewsDao {
    
    	/**
    	 * queryByArticleId
    	 * @param articleId
    	 * @return
    	 */
    	ArticleNewsEntity queryByArticleId(@Param("articleId") String articleId);
    
    }

## 新建entity ##

package cn.xxxxx.service.entity;
    
    import java.time.LocalDateTime;
    import lombok.Data;
    
    /**
     * @program: xxxxxroup
     * @description: ArticleNewsEntity
     * @author: Jason
     * @create: 2021-07-27 13:55
     **/
    @Data
    public class ArticleNewsEntity {
    	private String articleId;
    	private String title;
    	private String content;
    	private String category;
    	private String sourceUrl;
    	private LocalDateTime postDate;
    	private LocalDateTime addedDate;
    
    	private String attachmentPath;
    
    	private LocalDateTime created;
    	private LocalDateTime modified;
    
    }

## 构建test controller ##

package cn.xxxxxx.service.controller;
    
    import cn.companyapp.common.utils.DateUtil;
    import cn.companyapp.common.utils.LoggerHelper;
    import cn.companyapp.common.web.CommonApiResponse;
    import cn.companyapp.common.web.CommonApiStatus;
    import cn.xxxxxx.service.dao.hbase.article.ArticleNewsDao;
    import cn.xxxxxx.service.entity.ArticleNewsEntity;
    import cn.xxxxxx.service.repository.es.MonitorAyTradeSearchESDao;
    import cn.xxxxxx.service.request.ArticleNewsInformationGetRequest;
    import cn.xxxxxx.service.response.ArticleNewsInformationGetResponse;
    import java.io.IOException;
    import java.time.LocalDateTime;
    import org.apache.commons.lang3.StringUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.validation.annotation.Validated;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    /**
     * @program: xxxxxx-service-group
     * @description: ArticleController
     * @author: Jason
     * @create: 2021-07-27 11:55
     **/
    @RestController
    @RequestMapping("article/news")
    public class ArticleNewsController {
    	private static final LoggerHelper LOGGER = LoggerHelper.getLogger(ArticleNewsController.class);
    
    	@Autowired
    	private MonitorAyTradeSearchESDao monitorAyTradeSearchESDao;
    
    	@Autowired
    	private ArticleNewsDao articleNewsDao;
    
    	/**
    	 * 获取新闻信息详情(xxxx.article.news.information.get)
    	 * @return CommonApiResponse<UserInfoResponse>
    	 */
    	@RequestMapping(value = "getInformation", method = {RequestMethod.POST})
    	public CommonApiResponse<ArticleNewsEntity> getNewsInfo(
    		@RequestBody @Validated ArticleNewsInformationGetRequest articleNewsInformationGetRequest) throws IOException {
    		ArticleNewsEntity articleNewsEntity = articleNewsDao.queryByArticleId("100001");
    		return CommonApiResponse.success(articleNewsEntity);
    	}
    }

## 运行springboot ##

返回结果

{
      "body": {
        "addedDate": "2021-07-27 14:48:20",
        "articleId": "100001",
        "category": "22",
        "content": "",
        "created": "2021-07-27 14:48:20",
        "modified": "2021-07-27 14:48:20",
        "postDate": "2021-07-27 14:48:20",
        "sourceUrl": ""
      },
      "code": 200,
      "message": "成功",
      "requestId": "af6a181f-1501-400f-9e69-a253c2331f69"
    }

参考：[https://note.youdao.com/ynoteshare1/index.html?id=bd06ffb97ff093641d3f5be302a76bd9&type=note][https_note.youdao.com_ynoteshare1_index.html_id_bd06ffb97ff093641d3f5be302a76bd9_type_note]

更加详细步骤请访问上面链接，感谢大佬提供的笔记  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70]

[https_note.youdao.com_ynoteshare1_index.html_id_bd06ffb97ff093641d3f5be302a76bd9_type_note]: https://note.youdao.com/ynoteshare1/index.html?id=bd06ffb97ff093641d3f5be302a76bd9&type=note
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyNDQ3MzAx_size_16_color_FFFFFF_t_70]: /images/20220829/434925c085b1434b83c9c70351b29464.png