00:00
好,同学们,现在呢,我们再给大家讲一下,就是如何把一个抛教练呢,直接写到in DB里面。啊,我们知道把这个数据呢,封装为B,或者封装为一个破旧类,这是我们这个Java编程里面常用的一种处理手段。呃,那么这里呢,我们先把这个行协议呢,呃,想办法转化成我们的一个破旧类。在这里呢,我先截个图,然后呢,啊,在这里我新建一个类。哎,就叫DEMO吧,Do Mo,然后pogo好,那么这这个呢,就是我的一个新的这个类,那在这个类里面呢,我们现在呢,要去洗点东西,呃,把这几个属性呢都给它加上。比如说这个我们看啊,需要写什么。呃,比如说要有一个呃,字符串类型的啊,叫做location,表示我们当前呢这个测量的地址,另外呢,还有可能需要一个东西。
01:01
呃,表示我们当前的测量名称。然后呢,还需要一个叫做value的,它得是double类型。这个呢,就表示我们当前的呃,这个字段啊,这是字段,所以说呃,资料名称,然后标签字段都有了,最后呢,我们可以再放一个instant。啊,来表示我们的时间戳。呃,那么我们想呢,这个行协议呢,可能要是封装成抛酵类的话呢,也就这么写了啊,那么现在怎么把这个行协议呢,给他写过来。呃,首先呢,给大家讲几个注解啊,我们其实这个Fla DB呢,它是通过啊,我们这个Java的客户端呢,它其实通过注解的方式啊,来指明我们各个字段,来指明这个抛令里面各个字段都是什么含义,它都是啊起到什么作用。那么在这个Java的客户端里面呢,其实我们是通过一个叫做column的注解呢,啊去分别这个东西呢,它是指标名称啊测量名称,还是说是tag,是标签,还是说是字段,还是说是时间戳,呃,我们可以看到这里面呢,呃,第一个实现就是name,这个其实是指定一个字段集,我把它截图放大一下。
02:14
啊,第一个呢,就默认情况下呢,你其实它是。呃,它其实是用来指定哪一个啊,这个内呢是说啊,我们当前这个字段的名称是什么?呃,如果说呢,你还可以指定,如果说它这个你这个属性呢,它是一个标签啊,那么你可以给一个tag等于true。然后包括你指定这个属性呢,是一个指标名称,或者说是时间戳啊,那么接下来给大家操作一遍就能明白了。呃,这个地方呢,它是,呃,比如说我们希望这个属性呢,这个成员啊,它去表示我们的呃测量名称,那么就打一个空格,打一个打个小括号啊,这里呢,就写measure等于。好,那么我们的in DB呢,待会去写入它的时候啊,就会把这个类里面的啊,这一个属性当做一个指标名称去判别,呃,那么底下呢,这个地方location我们说是tag,你就写,然后。
03:05
Tag等于戳,呃,那么这个呢,是我们的字段啊,字段的话你直接给一个艾特column就可以了,呃,那么这边呢,是我们的时间戳,就是艾特column,然后就可以给一个这个sta等于处啊,那么这样的话呢,就是分别标定了我们的四个成员都是什么东西。现在呢,我去给他一个全餐的构造器。呃,直接在这个用idea自动补全,帮我们做一个前三的构造器。好,那么现在呢,我们就去写代码,呃,现在我先把之前的,呃,这给大家写个注释啊,这比如说这个地方就是零啊,使用inx DD行协议写入。呃,另外呢,就是。这一块呢,这个上一次的上一个案例代码呢,也给大家注射掉。
04:01
啊,再给大家补个注释,这一段呢是使用。Point写入啊,现在呢,我们就使用这个泡椒率来写入。行,那么现在呢,我们已经给这个戴墨泡脚,然后一个给了他一个啊这个什么了,给了他一个这个全蛋构造器了啊,直接来拗它,呃,那么拗完拗的时候呢,就按照这个全三构造器的这个参数依次给值啊这里呢,我们把它的这个之前的行协议呢拿来看一下。呃,这里面首先是我们的测量名称,呃,测量名称呢,就是之前的温度啊,Per per,呃之后呢,Location,那这里呢,我写east就表示东方e EST,呃之后呢,这个地方要需要传我们的这个呃数值了,我这里呢写的是个double类型的value,那么现在呢,我们就传一个浮减数。
05:04
比如四四万之后还差一个,就是我们当前的时间这里点把它做一个变量。呃,现在呢,我们去这个就去执行这个写入操作,那么现在我们可以拿着这个,呃,之前的right API blocking这个变量直接点right。We measure。呃,那么这里呢,我们就看一下right measurement的这种实现,呃,我们关注的呢,是第一种实现,它的第一个参数呢,要求指定一下这个,呃,你写入的数据的时间戳精度,然后第二个数据呢,要求的是啊,你直接传入一个继承了这个object的一个类啊,那我们知道Java里呢,所有的类呢,它都继承object object,那么这样的话呢,我们直接。呃,首先是传一个呃写的精度,我们说这个时间戳精度呢,就直接写成毫秒啊,另外呢,就是去写一个我们的这个对象啊,对象呢已经弄好了,直接把这个对象呢扔进来。
06:07
好,现在呢,我们去跑一下这个代码,看看会变成什么样子。啊,说我这个不规范哈,好,那么运行一下。啊,可以看到呢,这个呃,程序呢,正常退出啊,没有遇到异常,现在呢,去我们的这个web UI上查询一下啊,可以看到呢,我们现在measurement,呃,Measurement底下呢,呃,Temperature底下有一个east,这是我们刚才写的这个,呃,一个数据submit提交,可以看到呢,我这现在这里面有一个数据点,然后看原始数据的话呢,是44.4,就是我刚才插入的这个破类,呃现在呢,我们再去弄一个新的,把这个呃把这个值给他改一下,看看能不能起到效果,比如说我改成55.5。呃,再运行一下这个程序。
07:04
好,那么现在呢,我们去刷新一下这个查询,可以看到呢,我们现在,呃,在一测这个序列里面有了我们的第二个数据点。啊,现在数据是两条啊,那么这就是使用抛照类呢去插入的方式,这里再给大家说一下,就是我们的注解,呃,如果说呢,你不想在这个呃成员变量里面呢,去写这个指标名称,我们还可以把这个删掉,把它删掉之后呢。来注意注意啊,这个构造器也需要重新去写一下。啊,我希望呢,这个类里面只封装这个一些标签和字段的这个属性啊,我们可以把。这个策划名称直接有一个叫做measurement的注解。然后呢,传递一个内参数,呃,这就是我们直接说以后这个类呢,直接呃,在这个类的注解上呢,去加这个测量名称啊,现在呢,我直接敲这个测量名称PE。
08:00
RT,好。呃,现在呢,我们再去把这个数改一下,比如改成呃,改成22.2吧,把这个构造器呢,第一个参数我们现在已经给删掉了,好再去插入一下数据看看效果。把这个程序跑起来。啊,那么这个程序呢,还是没有异常正常退出,接下来呢,我们看一下这个查询,把它刷新一下啊可以看到呢,我现在这个线呢,拐了一下子。在这边呢,有了有了我们第三个数据点,然后你一看原始数据。哎,现在呢,我们的22.2也进来了,那么这就是三条数据。好,那么关于这个同步写入的这个三种方式呢,现在都已经给大家介绍完了。
我来说两句