00:00
第一个咱们要过滤出这个订单。明细数据那就是table in点叫query,诶它呢来自于咱们的topic DB这个表对吧?好,那不管怎么样呢,咱们在这继续往后写啊,嗯,这边加一个,这是订单预处理掉。呃,强迫症患者,那后面呢,我们就不自己敲了,我直接复制,这样的话两边肯定是一样的,对吧?好,那首先呢,第一个。订单。明细表。好,那我们写一下。好字段呢,先不写from,叫topic。下划线DB。对吧,Where。啊,我的东西呢,我可以从这把这个拿一下改改吧改吧就行了,对吧,把这个拿过来啊。起码这个库是一样的,然后这边呢,我们在订单明细表叫什么叫all the detail吧,这个大家应该还记得对吧,那all the detail all INF for all the activity all the detail。
01:11
看见没对吧,这是我们要的这四张表啊,都在一块儿,在这儿。订单明细订单明细活动订单明细。购物券。OK吧,好,那么接下来呢,咱们这个就叫什么叫。Detail。All the detail,好,呃,而且我们知道明细表呢,它其实只有新增。对吧,他也没有乱七八糟的那些数据啊,那我们就直接。叫凹跳就好了。对吧,也没有其他的过滤条件了啊,那接下来呢,就处理它的一个字段喽,那字段呢,我们还是一样的到这儿来。对吧,到这个地方来啊,嗯,我们找一下F搜一下叫凹的。Detail。哎,就是这张表吧,呃,那咱们要的字段呢,就在这。
02:03
对吧,咱们要的测算就在这好,那我呢,这样。二加shift。Shift对吧。RC啊。呃,那么在这里面。看着飞。往那一放。对吧,这是我们的字段啊,那接下来呢,把这个还是一样的,我们处理一下啊。咱们从明显从data里边去获取这个数据吧。对吧,从data里边去获取这个数据啊,咱们呢,呃,在data里边把这些数据获取出来,比如说这个什么图片的地址,那我们明显不需要,那我就直接给他干什么。
03:00
给他干掉就好了。对吧,像这种明显不需要的,我就给他干掉,其他的呢,那我都可以保留。对吧,我都可以。保留就这意思,就这样东西。OK吧,没有什么其他的了啊,那这个呢,还是比较简单的,我们就处理完了,主要就是提取这个字段,然后呢,去做一个过滤啊,那还有一个东西我们需要注意一下,呃,那你看啊,就是。订单与订单明细,这两张表呢,他俩是状语。对吧,然后接下来呢,跟订单明细活动表,或者跟订单明细这个购物券表,他们呢是level,也就是说。活动跟购物券不一定有这个数据。所以为了未来啊,可以与这个什么呢,与这个。我们的。Base diic这张表能够关联,因为它是个lookup表,它需要我们有这个。
04:02
处理时间的字段有一个PT。对吧,所以你这个PT呢,你可以是。订单明细表里边出,也可以在这个订单表里边出。懂吧,啊,那既然我们先写的订单明细表,那我就写在这儿呗,对吧,我就在订单明细表里边把这个PT字段给他加上。啊,咱们来一个PT。As pro time对吧,这个咱们就拿一下,就省得写错了,在下面呢,咱们应该有一个自己添加的这个PT吧,在哪啊。呃,这个是查询的字段对吧,PT。啊,PT这个这啊在topic DB里边已经给了,对吧?在topic DB里边给了,我们就直接拿过来就行了,拿过来之后呢,这边是一个逗号,一定要把这个逗号加上,最后呢,要补上这个PT字段,对吧?从topic DB里边我们直接获取它就好了,对吧?那到这个为止呢,咱们的订单明细表就。
05:04
搞定了啊,其实这样一看还是蛮简单的,对吧,好把这个拿过来C啊拿过来好以后呢往那一放。然后呢,可能R把这个杠N呢处理成一个。空格。处理成一个空格就好了。对吧,除了成交空格,那这样的话呢,我们就得到了一个。叫凹的。Detail table。对吧,啊,那未来呢,我们可以把这个转换成一个。Table,因为因为我们最后呢,写了一个状语create time of view对吧,然后呢,呃,前面给个名字叫all the。Detail table啊,那all the detail table,咱们这样处理一下,为了方便后续的操作,当然你要想把这个东西做个测试也可以,对吧,也可以啊,那你就打印一下啊,你在这要不想测,那我们回头统一测也行,对吧,如果报错了,我们再单独单独测也行啊,好吧。
06:07
这个第一个订单明细表呢,咱们就搞定了,对吧,有了上午那个基础,其实这个的就更更好理解一点了啊。呃,接下来呢,咱们可以做一个测试,因为我们刚才说了,如果你不测,你最后测了有问题,你还得一张一张表测,那倒不如说我们就在这测了,对吧?啊,那转化为。刘。给你打印。测试啊,那就是table烟点。这个呢,当然可以有追加流。对吧,他也没有什么撤回一说啊,Panda,咱们呢,All the detail table。对吧,好,那最后呢,这个东西你得写一下,这是我们早说的对吧,你得把这个东西呢,你先保留着啊,你万一我们中间要用留的方式来做测试,所以呢,这玩意还是很好用的,对吧。
07:08
好把这个搞定,接下来呢,我们来做一个测试啊呃,他呢也直接消费的是topic DB这个数据。对吧,所以呢,我们的环境我都没有关啊,还是在这儿。Maxwell ZK卡夫卡啊,还是在这的对吧?好,那我们呢,把它提起来,然后去造数据就行了。好,这边呢,应该已经启动了,他没有报错对吧,这样我们so应该写的没问题啊,然后我们再找到这个。All detail这张表吧,All detail,那我们添加一条数据啊,啊,那这边呢,幺三啊,或者说呢,为了防止它分页吧,那我们就直接这样写啊509。
08:01
三吧啊,那我们就模仿上一条来写33这个呢,就A啊。地址反正我们也不要对吧,这个会被过滤掉,无所谓啊,嗯,488。然后呢,SQ number3个时间呢,我就不写了吧,后面我就不写了啊对吧,来源就是到底是由什么渠道来的啊。2403啊保存。好,那我们来看一下这篇数据来打印了,有很多呢。对吧,有很多呢,这个最后是PT啊,是PT子弹对吧,是我们自己给的那个processing time啊呃,488那三个对吧,好没有问题啊,这个呢也就。测了啊,但是update的数据呢,咱们是没有,对于订单明细表根本就没有,对吧,这是我们中间的一个测试啊。好,那接下来呢,我们要过滤出这个订单数据,其实跟上面都一样,只不过说呢,我们想一想这个过滤条件,我们到底要什么东西,对吧?呃,还是一样的,在这边呢,叫。Circle query。
09:02
对吧,查询好,那到这边来啊呃,我们继续select,然后呢空着from,诶这个呢,我们直接搂过来啊,把这个搂过来。对吧,最后呢,肯定有一个PT子弹,这个跑不掉。啊,当然你不要你就第一个有PT了,这个不写可不可以也可以对吧,因为我们最后呢,跟这个被dic表关联,其实我只要有一个PT就够了。对吧,啊,但是原始表当中呢,咱们得有一个好这个改一下就是all the info。For,对吧,好,那。这个。数据。啊。我们对于out in for这张表而言,我们是不是所有的字段都要保留啊,就是它的type要保留啊,就除了啊,除了它数据本身,数据本身的那些字段,比如说out ID这些东西之外,那像我们的。Type一个类型肯定要保留,因为未来下单我就要用类型,我要过滤出来音色的数据。
10:05
对吧,那未来呢,我们要这个。取消订单对吧,咱也需要用到这个类型update,然后呢,还要老的字段有没有改这个。订单的状态对吧,所以呢,像我们除了data里边数据要之外,像tap old这些数据呢,都得保留,对吧,所以呢,它的字段要比这个订单明细要复杂一些,因为订单明细它只有新增,所以呢我们不需要。保留其他的东西了啊,你内心保留的也只有音色的你O保留着它永远都是个空。对吧,这就是不同的表啊好,那这边呢,我们来先不管怎么样把这个数据取出来,先找到我们的out in for,对吧。All info,哎,在这好,那这个字段比较多啊,那我们呢,在生产环境当中一样,你也可以都保留哈。
11:02
当然。我们在这个。文档当中我并没有保留所有的字段,因为我知道有一些字段在后面呢,用不着,所以我就把它删掉了,但是这块不是给他演示嘛,说你在工作的时候,你应该怎么怎么去做,对吧?Countr order啊,Shift啊,Shift加you对吧,CRC。然后呢,往这一放。CTRV啊呃,然后呢,把我们要的东西呢补充上啊,Ctrl alt加shift往下拉。一直到这,自带1234DATE。然后呢?单引号。啊嗯,按住CTRL键往右,然后呢单引号中括号。加一个空格。CRV对吧,然后逗号把这个我们要的这个这原始字段对吧,我们都保留,比如说这里边这个字段明显知道不要,那可以删掉对吧,你未来工作一样,假如说你知道,哎这个东西呢,我肯定不要,那我就把它删掉。
12:01
对吧,啊,但是省份ID我们肯定需要,因为未来省份是我们一个很关键的维度吧,啊,所以其实它还是得保留的啊,得保留啊好,那按照我们所说的,我们还要保留什么东西啊像。类型对吧。Table原封不动拿过来。还有呢?咱们的old。字段原封不动的拿过来对吧,这个字段是哪来的,在我们的topic这个。对吧,呃,这两个呢,用作过滤。啊呃,类型保留对吧,Data呢,我已经把数据明细摘出来了,那就不用管了,然后O的字段要保留,所以我们刚才说的那。这个。这个。你要保留啊,那怎么保留呢?怎么体验保留呢?很简单,在这你把这个数据写在这不就好了吗。对吧,啊,写在这个位置就好了啊,然后逃DB,然后呢。
13:00
这个是我们的库名,这个是表明没有问题吧,啊就这张东西好,那这个呢,又搞定了一张表啊,其实还是蛮简单的一张表对吧,2C啊,拿过来拿过来好以后到这边。来这个啊。往这一放对吧,还是一样的,CTRL加R,把这个杠N呢替换成一个空格CTRTL加V,得到一个all的in for table啊,那同理,咱们呢,把这张表也处理一下,叫table in.create view对吧?呃,咱们呢,就叫all the in for table。Able对吧,在这边呢,咱们同理也可以做一个什么呢,打印测试啊,这个呢,我们就注释掉了。这中间的测试嘛,我们一张表一张表测对吧?啊测完之后呢,我们就可以把有的删删掉啊好这个打开,打开好以后呢,我们就不对这张表了,这两张表这个。对吧,叫out in for table做一个打印测试,OK吧,好,这个呢,我们就一并直接来做一个测试就好了啊,来变形啊。
14:17
呃,这边呢,没有问题啊,接下来呢,咱们找到all info这张表对吧,我们测两个,一个呢是正常的,新增一个呢是修改可以吧。添加5094。5094。啊,那这边呢是张三啊,比如说给一个张三啊,嗯,手机号13712341234啊给一个对吧,5968,我这个就抄上面的总金额对吧?呃,订单状态1004。U zd。嗯,4038吧,随便啊,当然我也不知道他可能没有这个人对吧,张三我编的啊,支付方式可能还没有支付对吧,这是地址,地址的话我就随便给一个啊描述信息。
15:04
嗯,他这个。对吧,这个呢,我们就给一个数字哈。但是后面我就不想给了,我可以不给了吧,对吧,有的东西就不给了,这后面什么金额啊,这个东西不要了,我们就测试随便搞几个字段就行了呗,就大量的文档对吧看。后面都为呢啊,那当然没有问题对吧?啊,更关键在于呢,我们修改一条数据也得给我出来,对吧,比如说我把刚才这条数据呢,做一个修改。去干什么呢?张三改了个名字叫张三三啊。对吧,然后呢,这个状态1004改成了1005,主要就是订单状态可能会发生改变嘛,对吧,其他东西呢,就不变了,好,那保存保存好以后呢,我们来看啊,诶那1004变成1005,张三呢变成张三三,对吧,我们改的就这两个字段。这修改的数据也有了,这是old。对吧,O的里边呢,包含了两条,一条呢,是这个这个啊音色的update的新增修改,那我们要的数据都保留下来了,对吧,咱们要的就是这样的一个效果。
16:06
没没问题吧,好把这个处理掉啊。啊,那么接下来呢,这两张表我就可以一起来做处理了,对吧,Table in点叫circle query啊好,把这个先写好,这边呢,一样的,咱们也得准备一个正文。对吧,先准备好啊,那么接下来呢,我们去写。写那个的。诶,From把这个呢拿过来。嗯,把这个拿过来对吧,好。嗯。那。咱们把这个写好之后,这个表明肯定要改,咱们叫什么叫all the detail来。Detail。Activity对吧,这张表啊,把这个表明呢。
17:00
一替换一替换接下来。子弹,哎,他做的很少,你这个就舒服很多,对吧,看到大家睡的啊。看到没,现在已经非常熟练了,你看啊,我这边操作的是不是异常熟练了呀。就大家呢,可能学一学这种手法就熟练了。德啊,那我们想啊,这张表呢,它。有没有新增啊,新增肯定有对吧,他会不会。改变啊,会不会删除。我们讲一下对吧,这个活动会不会改,一般这种活动不会改啊,那有的人说我活动呢,我从那个满减200减20,我改成满200减30,那其实这是另外一个活动了,能理解吗?所以这张表呢不会改。对吧,他只会新增,那么既然这样的话,咱们是不是可以这样写啊,对吧,你就可以这样去获取这个数据就好了。
18:05
啊,那既然你没有那个什么修改呀,这些东西没有对吧,那。你是这样,好,那我们想这个数据有没有可能会被删除呢?就是我这个活动结束了。对吧,那在活动这个。表当中它会不会删除呢?这个表也不会删除,能明白吗?他。它不是活动,它不是活动表,它是一个什么,它是一个。订单关联活动,那你想想看,我下订单的时候已经关联这个活动了,那你这条数据还会变吗?也不会变,也不会删除吧,对吧,所以咱们过滤条件是不是可以直接这样写写过滤这个。出去就好了,因为他未来呢,只有新增对吧,注意啊这张表你注意什么呢,这个。
19:00
订单明细活动表,你要跟谁区分开啊,跟这个。Activity。这张表未来是不是有新增有删除?对吧,我搞了一个活动,然后这个活动呢。他按的日期已经到了,这个活动我是不是可以把它怎么样。会被删掉,活动已经过期了。对吧,但是有的公司呢,可能,诶,那你这个过期时间这都有,我不删也行,对吧,我不删,那有的公司可能会删,但这个呢,是属于我们的什么。为表。啊,这是一个活动信息的维表。对吧,而在我们这个叫订单明细活动管理表,它呢只会新增。只会新增啊,他只有create time,连operate time都没有,连修改的时间都没有,看见没。对吧,所以呢,咱们要所有的数据呢,你就这样写就好了,你就直接这样去写OK吧,好,那把这个CTRLC。
20:01
拿过来。往那一放。CTRL加R。替换配二对吧,好,那这样的话我们就得到了一个。Activity。Table对吧,我就不写那个什么,呃,All the detail activityd了啊好,Table in create temp view啊,那还是创建临时读啊,叫order activity。Table。好,这边呢,我们也做一个短信测试啊。往这放好,那同理呢,我们把这个也搞定好,把这个搞定好,那接下来到这来。那。啊from这个呢,我们就先不写了,直接从这拿啊,然后表明过滤对吧,来。
21:05
Order。Detail carbon,哎,就是这张表对吧,那卡叫订单明细购物券关联表啊,接下来呢,字段它字段也不多啊。拿过来。Data。好,那其实这张表呢,跟活动表是一样的。对吧,他也只会新增,因为你下订单的时候关联了这个购物券,那就关联了,它就不会变了。对吧,他也不会去删除,因为这属于这个基本的明细啊,所以呢,我们就直接这样写就好了,对吧?好,那这个搞定搞定之后呢,直接。CRC拿过来对吧,往这一放。
22:01
啊,往这一放。呃,卡R做一个替换。CR单位得到一个all carbon。Table对吧,那接下来呢,我们还是一样的table invi create view啊,嗯,然后呢,这个边我们写all the cup table。同理,做一个。打印测试。把这个。拿过来。OK吧,啊把这个拿过来,接下来呢,我们就直接。做我们的测试OK吧,啊把这个侧板呢,我们就下课休息啊,下节课呢,我们就处理这个关联啊,处理这个关联对吧,运行。好,那我们先呢,在这个活动表。
23:02
对吧,添加数据,然后呢,我把这个也打开啊,还有一个卡对吧,这两张表添加数据,诶这个好少啊。添加一个,那1827对吧,五零。九二,比如说我就照抄啊,13610啊,然后呢,二。四。啊SKD12对吧,时间我给个2022。杠零五杠二零啊,然后12点。13。这个用中文了啊,12分12秒。保存。他打印了。这条数据对吧?哎,那我没有区分啊,我应该区分一下对吧,我应该区分一下啊,是哪个流打印的,当然这个大家应该知道啊,因为我们正好有两个流嘛,但是我刚才是复制过来的,这个是箭头,这个也箭头两个完全一样对吧。好,那这这个没关系啊,大家应该能够了解到这个事儿啊。好,那这里边呢,我们添加一个ID,哎,这个公的ID好像很长对吧,我们也搞个特别长的啊。
24:02
嗯,这边呢,4968,比如说啊,这个订单detail ID,那我就不知道了,我随便造了啊,随便造一个,然后呢,他问二。柚子是否使用那这个32号商品吧,比如说是2022杠零五杠二零,然后呢12点。12分12秒对吧。发。来看诶又多了一条数据没有问题吧,中间有个字段没给,所以呢,他是那好,呃,那他这个没区分开是哪个理由,但是大家应该没有问题,只要两个都能打印应该就没问题对吧?好,这是我们将这个。订单明细活动与这个购物券表呢,也都处理了一下,并做了。测试啊,并做了测试,OK吧,好把这个。
我来说两句