00:00
呃,接下来呢,我们就要写这个代码,写这个代码之前呢,我们得导入这个依赖啊,嗯,看一下导入这个。依赖弗林CDC,我看一下这边之前有没有倒。嗯,茯苓CPC没倒对吧,没倒的话这边没放,那就在我看一下啊,应该这边是。有的啊,在这啊,大家根据MYSQL配置表进行。动态分流对吧,好,那这里边呢,我把它拿过来,然后咱们一块儿来看一看啊。这属于弗Li相关的,那我们就放到这啊,放到fli相关的这一块啊,注意啊,这个依赖在这个位置。代码实现这对吧,在这啊,你到时候在这个地方去拿一下啊嗯,诶这个东西我们今天导过了吧,是吧,Phoenix导过了啊,这个你们干掉啊,干掉之后呢,我这也得干掉,你看这标黄了,那他说什么,他说当前这个文件里边被定义了两次。
01:12
多重定义对吧,啊,多重定义了,好,那这个就干掉啊,因为我们之前已经放过了,对吧,好,嗯,这个搞定。呃,然后这个我再改一下吧,这个这样写不好啊,因为这个地方已经定义了2.12了。我把这个改一下,稍微改一下啊。统一命名嘛,对吧,第二个就是这个森,诶它呢,01:13点零啊,因为这个就是01:13点零,对吧,咱们这样写一下,这样更好一点啊好,那我们导进来的依赖有三个,第一个。JDBC的一个连接器对吧,把它导进来啊,第二个我们的。MYCDC的一个连接器。对吧,嗯,那第三个。这个啊,不引入它呢,它会报一个错误对吧?Class not found啊,这是新的2.1版本弗Li CDC里边的一个点啊,所以必须要导入这个。
02:09
Table API的一个调节器啊,当然你不导这个调节器,导一个blink也可以。对吧,因为blink当中呢,他自己带了这个调节器,好,他本身就带了这个调节器,OK,好这个搞定啊,嗯,搞定好以后呢,接下来我们来写这个内容啊,这个怎么写呢,就是my circle。S。哎,你要注意到这个依赖下的对吧,My circle source啊,这个过时的就不要用了啊呃,点build对吧,最后呢,点build构建啊,中间添加参数,当然这块呢,我们要写上它的一个类型,那我们刚读过来数据,我们就用string表示,这里边就填我们的参数了,对吧?好比如说点。呃,我们要给一个how nameme啊,主机名那个端口号port啊,呃,User nameme。
03:11
Password。好连接参数对吧,连接参数要给,呃,接下来呢,我们要写的是database。你要导哪个数据库对吧,然后table list,你要导哪张表啊,同时还有什么东西啊。嗯,你的。从哪开始读对吧,参数是什么?然后呢,反序列化,因为你读的是一个blog blo,所谓blog呢,是一个二进制文件对吧,单lo啊呃,那这个地方呢,你的反序列化,你用什么东西。对吧,那我们给的就是一些基本的。内容吧啊,给他基本内容好,那主机那我们写一个哈杜102,然后嗯,MYSO的端口号3306吧,呃,User name,我这边用root啊,然后呢,密码我是六个零,你写自己的就行了,这个无所谓啊,Table list啊,Database list,咱们的库名,我这库名啊,注意像这种东西你一定要写自己的对吧,因为我们的主机名这些东西可能不一样,你不要。
04:17
就照着写啊,不要这样好,Database我呢叫J梦杠211126对吧,我用的中杠啊杠con这对吧,我的库名叫它,然后表明我拿一下把这个一定要这样写啊点我叫table_process。我叫table process,注意看啊这边。我这不叫table。对吧,当然这个大家一样,因为你建表语句从文档中摘嘛,对吧?呃,启动方式,大家告诉我,我应该从哪开始读。就start options。我们是历史数据都要呢,还是说我只读最新的还是怎么样?
05:06
嗯。这个standup options,我们应该就是配置信息表应该怎么读啊。嗯。对,这个必然全部都要吧,对吧,好,那stop options,我们写一下options.initial对吧,初始化了啊好,那这个地方呢,官方自带有那个接省这种方式啊,用一个。呃,Jason de division第civilization的一个scal对吧?啊,Jason格式,至于它的格式呢,最后呢,我们也可以去拿一下,我们写一个测试类,把这个呢,你读到这个数据,我们看一下它的格式是什么样子,对吧?好,那这个呢,我们就得到了一个叫my circle source。接下来以V点。At s对吧,好,这里边呢,呃,要给定。嗯。
06:01
S function啊,那这个呢,我们还不能去S,我们应该是。我们应该用另外一种方式,对吧,看一下a south,它要一个。应该是from。From source对吧?From source啊,他呢,它这个东西新版本改了,以前呢还是source对吧,现在改了啊,所以刚才没找到,那这里面呢,第一个so function叫my circle source啊第二个给定word mark,但是我们也没有我mark对吧已都没有时间,时间那我的world mark.no worldmark对吧?啊最后一个名称,那我们就给一个叫my circle sourcece,好CTRL加V得到一个。配置信息流对吧,呃,MYSOD对吧,这样我们的配置信息流就搞定啊,就写完了OK吧,好把这个。
我来说两句