PowerMock测试 mock hbase连接

2024-05-04 05:38

本文主要是介绍PowerMock测试 mock hbase连接,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

junit测试中,当无法连接hbase集群,使用PowerMock测试 mock hbase连接,mock类如下:

    /** * QueryCanTask Tester. * * @author <Authors name> * @since 12/18/2017* @version 1.0 */@RunWith(PowerMockRunner.class)@PowerMockRunnerDelegate(SpringJUnit4ClassRunner.class) //委派给SpringJUnit4ClassRunner@PowerMockIgnore("javax.management.*")@PrepareForTest({ HBaseConfiguration.class, ConnectionFactory.class, Configuration.class,Table.class, ResultScanner.class})//@SuppressStaticInitializationFor("com.xxxx")//阻止静态代码块运行
@ContextConfiguration(locations = { "classpath:applicationContext/*.xml" })
public class QueryCanTaskTest
{  private Configuration configuration = PowerMockito.mock(Configuration.class);private Connection connection = PowerMockito.mock(Connection.class);private Table table = PowerMockito.mock(Table.class);@Beforepublic void before() throws Exception{//初始化静态变量new SystemCfgConstants();PowerMockito.when(HBaseConfiguration.create()).thenReturn(configuration);PowerMockito.when(ConnectionFactory.createConnection(configuration)).thenReturn(connection);PowerMockito.when(Connections.getTable(TableInfo.TABLE)).thenReturn(table);PowerMockito.when(Connections.getTable(RawDataTable.tableName)).thenReturn(table);PowerMockito.when(table.getScanner(scan)).thenReturn(yourest);}@Afterpublic void after() throws Exception{}/*** * Method: * */@Testpublic void testQueryList() throws Exception{//TODO test}}

在hbase-site.xml添加如下配置,跳过版本检查

<property><name>hbase.defaults.for.version.skip</name><value>true</value><description>Set to true to skip the 'hbase.defaults.for.version' check.Setting this to true can be useful in contexts other thanthe other side of a maven generation; i.e. running in anide.  You'll want to set this boolean to true to avoidseeing the RuntimException complaint: "hbase-default.xml fileseems to be for and old version of HBase (0.92.1), thisversion is X.X.X-SNAPSHOT"</description></property>

这篇关于PowerMock测试 mock hbase连接的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/958433

相关文章

JavaWeb项目创建、部署、连接数据库保姆级教程(tomcat)

《JavaWeb项目创建、部署、连接数据库保姆级教程(tomcat)》:本文主要介绍如何在IntelliJIDEA2020.1中创建和部署一个JavaWeb项目,包括创建项目、配置Tomcat服务... 目录简介:一、创建项目二、tomcat部署1、将tomcat解压在一个自己找得到路径2、在idea中添加

CPython与PyPy解释器架构的性能测试结果对比

《CPython与PyPy解释器架构的性能测试结果对比》Python解释器的选择对应用程序性能有着决定性影响,CPython以其稳定性和丰富的生态系统著称;而PyPy作为基于JIT(即时编译)技术的替... 目录引言python解释器架构概述CPython架构解析PyPy架构解析架构对比可视化性能基准测试测

通过DBeaver连接GaussDB数据库的实战案例

《通过DBeaver连接GaussDB数据库的实战案例》DBeaver是一个通用的数据库客户端,可以通过配置不同驱动连接各种不同的数据库,:本文主要介绍通过DBeaver连接GaussDB数据库的... 目录​一、前置条件​二、连接步骤​三、常见问题与解决方案​1. 驱动未找到​2. 连接超时​3. 权限不

Navicat连接Mysql8.0.11出现1251错误的解决方案

《Navicat连接Mysql8.0.11出现1251错误的解决方案》在重装电脑并安装最新版MySQL后,Navicat和Sqlyog连接MySQL时遇到的1251和2058错误,通过将MySQL用户... 目录Navicat连接mysql8.0.11出现1251错误原因分析解决问题方法有两种总结Navic

Python连接Spark的7种方法大全

《Python连接Spark的7种方法大全》ApacheSpark是一个强大的分布式计算框架,广泛用于大规模数据处理,通过PySpark,Python开发者能够无缝接入Spark生态系统,本文给大家介... 目录第一章:python与Spark集成概述PySpark 的核心优势基本集成配置步骤启动一个简单的

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》:本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏

Mac电脑如何通过 IntelliJ IDEA 远程连接 MySQL

《Mac电脑如何通过IntelliJIDEA远程连接MySQL》本文详解Mac通过IntelliJIDEA远程连接MySQL的步骤,本文通过图文并茂的形式给大家介绍的非常详细,感兴趣的朋友跟... 目录MAC电脑通过 IntelliJ IDEA 远程连接 mysql 的详细教程一、前缀条件确认二、打开 ID

Go语言连接MySQL数据库执行基本的增删改查

《Go语言连接MySQL数据库执行基本的增删改查》在后端开发中,MySQL是最常用的关系型数据库之一,本文主要为大家详细介绍了如何使用Go连接MySQL数据库并执行基本的增删改查吧... 目录Go语言连接mysql数据库准备工作安装 MySQL 驱动代码实现运行结果注意事项Go语言执行基本的增删改查准备工作

python连接sqlite3简单用法完整例子

《python连接sqlite3简单用法完整例子》SQLite3是一个内置的Python模块,可以通过Python的标准库轻松地使用,无需进行额外安装和配置,:本文主要介绍python连接sqli... 目录1. 连接到数据库2. 创建游标对象3. 创建表4. 插入数据5. 查询数据6. 更新数据7. 删除

在 Spring Boot 中连接 MySQL 数据库的详细步骤

《在SpringBoot中连接MySQL数据库的详细步骤》本文介绍了SpringBoot连接MySQL数据库的流程,添加依赖、配置连接信息、创建实体类与仓库接口,通过自动配置实现数据库操作,... 目录一、添加依赖二、配置数据库连接三、创建实体类四、创建仓库接口五、创建服务类六、创建控制器七、运行应用程序八