大数据WEB平台_整合Mybatis框架

什么是mybatis

MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。

为什么使用Mybatis

• 注册驱动；
• 获取数据库连接；
• 拼接sql语句，设置sql参数；
• 执行sql语句；
• sql返回结果；
• 执行语句和数据库连接；

注意：

从上面可以看出来，我们每次都要做大量的相同的操作，并且还要对执行sql语句过程中所出现的各种异常和资源释放进行处理，而真正涉及到业务功能的代码其实很少，这明显影响了效率。

引入MyBatis框架依赖包

xxxxxxxxxx
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>2.2.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-client</artifactId>
            <version>2.4.4</version>
            <exclusions>
                <exclusion>  <!-- declare the exclusion here -->
                    <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>
        <!-- phoenix相关依赖配置 -->
        <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>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>
        <dependency>
            <groupId>joda-time</groupId>
            <artifactId>joda-time</artifactId>
            <version>2.10.14</version>
        </dependency>

编写配置文件

xxxxxxxxxx
spring:
  datasource:
    #zookeeper地址
    url: jdbc:phoenix:node2,node3,node4:2181
    #驱动
    driver-class-name: org.apache.phoenix.jdbc.PhoenixDriver

#指定mybatis映射文件的地址
mybatis:
  mapper-locations: classpath:mapper/*.xml

创建实体类

xxxxxxxxxx
@Data
@ToString
public class UserActive {
    
    private String ROW;
    // 平台统计日活跃用户
    private String DAU ;
    // 统计本周活跃用户
    private String WAU ;
    // 统计30日活跃用户
    private String MAU ;

}

创建dao层

xxxxxxxxxx
public interface ActiveUserDao {

    // 查询活跃用户
    List<ActiveUser> findByAll();

}

创建xml文件

xxxxxxxxxx
<?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="com.itbaizhan.dao.ActiveUserDao">


    <select id="findByAll" resultType="com.itbaizhan.pojo.ActiveUser">

        select * from "active_user"

    </select>



</mapper>

创建控制层

xxxxxxxxxx
@RestController
@RequestMapping("/user")
public class UserController {

    @Autowired
    private ActiveUserDao activeUserDao;

    /**
     * 查询所有活跃用户
     * @return
     */
    @GetMapping("/findByAllActiveUser")
    public ResultMsg findByAllActiveUser() {
        return ResultMsg.ok(activeUserDao.findByAll());
    }

}