00:00
好,那咱们做一个测试,这样啊,我先呢,把这个集群得打开啊,起码得打开这个。Phoenix对吧。那开Phoenix要开ZKDFS对吧。诶。没点上吗。这一下子又打开了两个。好ZK啊,先看DFS吧。因为HDFS要退出这个安全模式,对吧,所以呢,我们可以掀开它,让它自己在那等着。
01:03
好,然后呢,我们不要着急啊。得等到ID退出安全模式之后,我们才能开这个h base对吧,现在还有19秒啊。14啊,稍等一下就行了啊。十几秒,真的你去数他搞感觉好像很慢对吧,但是你要不数他好像还还行。两秒。好,那我们启动。啊,然后呢,到这个。Phoenix。进来。
02:01
感叹号table啊,目前呢,我们表比较少对吧的新from。这个库点。我记得这张表里面有多条数据吧,诶两条数据十三十四北京上海两条对吧,好,那我们测试的就用。呃,来在这边呢,写一个PSVM的一个方法。呃,那首先呢,咱们用连接之前写的德鲁伊的连接池来获取连接对吧。床垫。获取一个连接。这异常呢,抛一下啊,直接抛个大的,因为等会儿呢,我们调用还得有异常对吧?好连接有了,将下来呢,调用这个query list,诶连接放进来,S语句放进来。啊,那我们呢,也没写那个什么东西,我们就用杰森可以吧,啊,类型用杰森,最后呢,我们先写force不转换,就是你是什么样子,那就直接是什么样的就好了,二加倍得到一个query list对吧,那我们就可以做一个打印,当然了,在这边我们可以做一个。
03:20
打印,然后呢,把这个链接给它关了好吧。好,那这块呢,咱们就搞定,然后呢,我们来测一下啊,看能不能查询对吧,点运行。呃,两个数据呢,都查到了,而且呢,这我写的是false。所以呢,他也并没有给我们做一个。转换对吧,那你改成处看一下啊。人住。看啊看一下,主要看他吧,因为他是ID无所谓了吧,对吧,那就变成小写了呗,对吧,主要是他啊。行。
04:06
看叫TM。对吧,变成了这个驼峰命名。啊,就刚才下滑线命名的,现在驼峰命名没有问题吧,对吧,是这样的一个情况,OK,好,那这块呢,咱们就。搞定测完了对吧,好,但是呢,我们测完之后呢,我们得把这个稍微的呃,做一个加工,为什么呢?因为你看啊。我们未来。查询的内容。我们在这边是不是要查这么六次啊,但实际上你看啊,如果说我们这样去查select新from a,那库表,我们其实也就是表不一样对吧?好,那未来呢,应该多加一个东西,那就是will。ID等于。比如说我们刚才有13对吧,有十三十四来啊。你也可以这样查嘛,你搜个语句随便啊,你想怎么写怎么写,对吧,直接这样。
05:04
是不是你都可以去写好,那这个呢,其实就是我们要写在这儿的查询语句对吧,但是呢,你每个都这样写不太方便,那实际上你想啊,我们六张表是不是就是表明跟这个东西不一样,那我能不能把这个封装一下呀。对吧,那肯定会更方便一点,对不对啊,更方便一点,那我们就把它封装一下啊,封装成一个参数,只传连接穿插穿插进去就好了,OK吧,好,那在这边啊,我们来封装一下,还是属于我们的工具类吧,在这边。叫dim u。Public static对吧,那这个返回值呢,我们就可以直接写介,不用写泛型了,因为跟业务相关了,对吧,跟我们业务相关的啊,那叫query,或者说叫get dim。
06:00
负二对吧,那第一个连接正常传进来没有问题啊呃,那第二个。写呢,我们的表明string。Table name对吧,第三个string啊主键。啊,或者你叫ID或者叫K也可以对吧,好,那这边呢,第一步拼接circle。呃,咱们的so呢,展电。对吧。叫query。Circle。好,那这里面呢,得要改写啊,对吧,首先这个是表明。得改对吧,库名呢也得改一下吧,库名得改一下啊呃,两个双引号线啊,然后呢两个加号,库名呢,咱们是有常量的点啊scam对吧?好,那表明呢也得改啊,那两个双引号,然后呢两个加号。
07:02
Table name13呢也得改,还是一样的,两个双引号,两个加号,把这个K呢弹进来对吧,因为我们写好的啊,也写好了,那这样就搞定了,对吧?呃,接下来呢,查询。用的是JDBC。Connection。Query。接上object。以及false可以吧,我们就写false就行了啊,好看加V得到一个。List。呃,那下来返回结果那。Query list.get0。对吧,啊,这的零,那我们要第一条嘛,只有一条对吧,不要idd为主键,那你查出来只有一条,所以我们直接排零就好了,那这样更方便一点,对吧,那我们把这个呢,也进行一个测试啊,因为它就比较简单,我们就快速一一并来做一下啊呃,首先连接那肯定还是要有的,对吧,把这个拿过来,这是我们的连接啊。
08:19
好,它有异常,那我们还是抛一下啊测试嘛。依然后续我们再处理啊呃,然后呢,就是get them in for对吧,连接然后呢,表明。被mark,然后呢,一个ID1034是不是都可以对吧,我们就直接对它做一个什么反应。好,最后呢,把这个连接关掉啊,其实这个连接池也要关一下啊,但这个倒还好了,对吧,因为我们慢方法退出了,它其实也自动就断开了啊,它是防止的是你任务其他的挂掉,但是还有一些东西在运行,导致这个连接没关,那有问题对吧。
09:03
走一下,看这个能不能查啊。这样就更方便了,那未来我们调用的时候是不是很方便啊,对吧,连接写在open方法里边了,那么。这多方便啊,传一个。表明成一个主键,诶照样也能查得到,但是呢,我们用的force,这个无所谓,因为我们已经写的是杰森object,并没有写什么。招聘对吧,并没有写招聘,OK,那这块呢,就搞定啊好。
我来说两句