00:00
呃,那接下来呢,我们诶到这个配置表这来对吧,弗Li CDC先不用管啊,等会我们来读取的,然后呢,我们就到配置表的设计对吧,在这source table啊,数据源的表明,Think table Phoenix的表明,Think columns peni表的字段对吧,逐渐extend。额外的配置配置语句对吧?啊,额外的配置语句啊,然后接下来呢,我们就创建一个新的数据库执行它。啊,执行这个内容,这个建表语句,这这个single就类似于这样的东西,你看在括号后面还有一些engine对吧,引擎等于in DB default s等于udf,杠八就刚才我们说的。对吧,你可以额外的信息,那菲利X也一样,也可能会有这个额外的信息啊,那这个表呢,你最好不要建在这儿。不要建在这个库里边,为什么呢?因为这个东西啊,这个东西它呢是业务数据库。
01:01
对吧,而我们现在这张表是不是应该属于我们大数据的。操作的一个数据库的一个表啊。对吧,所以呢,你不要在业务库里边就创建这张表,而另外的,而且在生长环境当中,我们现在没办法只有这个哈1021个MYSQL服务,对吧,那实际上在生产环境当中,你都不会在这个哈杜102,因为这个是属于业务的MYSQL服务,哎,我们自己有一个大数据的MYSQL服务,能理解吗?对吧,那为了区分这个点呢,所以我呢另外建一个库,能理解我说的意思吗。对吧,你不要在这里面创建啊,那有的时候我就要在这里创建,能不能读呢?能用,但你生产环境当中肯定不会这样做,对吧?你都不是说换库那么简单了,你都是要换服务的,你不能用业务的服务,对吧?人家也不会给你权限,让你随便去建表做这些事儿的,对吧。
02:04
好,那我们呢,就直接在这就行了啊。新建一个数据库。啊,然后呢,咱们叫末。看。211126-con对吧,配置信息啊来点还是一样的U6杠八。保存。啊,然后呢,在这里边我们去建一张表,把这个拿过来啊,就直接直接把这个搂过来就行了,但是你通过这个方式建表也行啊,这无所谓对吧,而且呢,我跟这个表名不一样哈,因为我这个都带了班级号,因为如果说我取这个名字,我每个班都要去删。对吧,啊,那我就带一个班级号,那我不用每一次上课之前都非得把上个班的删掉啊,就没必要做这事,我可以保留两个班的,对吧,好看RC拿过来。往那一放对吧,然后呢运行。
03:04
刷新。哎,那这样的话,我们就多了一张表,叫table process。对吧,Table process,哎,这是我们的,而且呢,我们的主键source table,这是刚才有同学提到的,对吧?来源表作为我们的主键字段primary key啊,当然这个呢,你可以写在这后面,你在最后也写也可以,因为它最后有什么好处呢?就是说你可以写多个联合组件。对吧,啊,你如果说你单个的你也可以写在这把primary key就跟在这个字段后面是没有问题的,OK吧,好,这是我们的见表,呃,光到见表还没有结束。还没有结束,我们还得做一些事情,做什么事呢?因为我们等会儿是要用什么,是要用弗Li c VC读取这个配置信息。那么我们就要。让他。这张表能够产生blog,得开启当前这个库的一个blog是不是没问题吧,好,那我们就开启啊,呃,这个消费者我们就不要了,这是我们拿那个样例数据对吧,好搜度。
04:11
OEDC叫卖点Co,哎回车,然后呢,我们现在有两个库了,有两个库了,对吧,那就YY。P啊,复制粘贴对吧,好,然后呢,这个地方改成conflict conflict注意你有两个库,你这个就写两个,你有三个你就写三个,当然你也可以不写。那不写就怎么样呢?如果说你这个非特信息不写就相当于你哈102所有的库都开启了,B帽听懂。假如说我要给。我要给什么,我要给这个哈,102。所有的。
05:00
库都开启blog,哎,你呢,不用一个一个的全写上,你就一个都不写。啊,你就一个都不写,一个都不写的话,那就相当于是给所有的都开了。OK啊,那如果说你只开两个,那你就写两个就行了啊,我们叫这个名字啊,那切记这个东西一定要根据自己的来。你创建什么名字我不管。你别给我搞错了,因为之前在上课的时候,经常有同学干什么事呢?哎,这写的是下划线对吧,在这儿给我写中杠啊,或者说呢,这明明写的是中杠,然后到这儿非得给我写下划线。你不要这样玩行不行?对吧,你在写之前你看一眼,你看一眼,求你了,好吧,啊,不要出这种错误。啊好保存退出,然后接下来重启买这个服务。System control对吧,MYD。
06:17
好,这边已经重启成功了,呃,重启成功呢,你不要着急,咱们得做一个校验对吧,咱们得做一个校验,看这个内容有没有生效啊,还是CD到什么呢?到one我特意切了一个入的用户啊,对吧,One Li,然后呢叫my circle这个目录底下啊好,那我们来看啊一下。我把这个呢给你保留一下。啊,因为我这个比较多,等会往上面翻不好,它是重新生成的,它是头信息154,诶右键154,只要你重启它这个文件,那就是154对吧,我这边已经很久了,所以400了对吧,到400了日志比较多啊,因为我这个集群用了很久很久了,说实话。
07:04
开启两个库的log mal会同时这两个库的变化会啊。你Excel又没有配置这个数据库,只要是blog它都能读啊,你又没有做库的过滤。对吧,啊,那当然都读了,你可以做一个库的过滤,对吧?也行啊,当然没关系,因为你读了两个库,最后呢,我们在这边还有表明的过滤嘛,对吧,咱们还有表明的过滤,大家想是不是对吧?其他的库我不要,我读过来做过滤也可以啊,你加在。如果说你害怕这里面出现同样的名字,在这儿我加一个库明的过滤可不可以啊?对吧,这是可以的啊好。那我们干什么事呢?我们得测一下我开启了两个库的blog,那么是不是这两个库都生效呢?对吧?好,那第一我呢,先在新的开启的这个库里边,我来一个A对吧,好BB。
08:01
啊,CC这个呢,我们测试无所谓啊,然后ad对吧,这个呢xxx。保存。这卡住了好保存进去,保存进去以后呢,注意看啊,刚才是幺五四四百幺五四对吧,这样我粘出来了啊好。重新看一下。现在看。400这个文件变成了479对吧,说明我们新的。说明咱们新的。添加的blog可以生效,那那是不是说,诶那是不是说我们刚才改的这个东西,呃,他是不是下面会把上面覆盖掉呢?对吧,你写了两遍,是不是把这个覆盖掉,所以你生效了,它不生效了呢?对不是的啊,来看我们在被的bug里边,我比如说把这条数据删掉可以吧,因为这个是多余的啊删掉。删一条记录好,那么我到这来。
09:02
来看注意啊,刚才是479对吧,来玩一下。现在变成多少了?400这个文件变成了791,说明两个库。同时开启并logg,它可以同时生效,OK吧,所以大家呢,把这个做完之后,一定要做一个测试,如果你不做测试,那你将会面临什么问题呢?你有可能没有开启成功,对吧,那未来。你一测试发现,诶,我这儿怎么没有数据。那你blog都有问题,你必然不会有数据,对吧,你但凡任何一个流,主流也好,还是配置流也好,任何一个流没有读到blog,没有读到数据,那。最终结果都不会有数据写到菲尼克斯,也不会有数据打印,对吧,我们刚开始呢,不写到菲尼克X,我们先做打印。对吧,不着急写出去,先做打印,那你必然看不到这个结果。OK吧,这是我们关于这个配置信息表,它的一个准备工作,你一定要做好。
10:06
那我们做了这个测试对吧,随便挑一张表就行了啊。
我来说两句