169_尚硅谷_实时电商项目_保存数据到MySQL（精准一次性第二种实现）

呃，那么接下来啊，咱们就来看一看，我呢已经把我们现在它的一个品牌啊L品牌的名字ID，然后呢放在这个一起，然后呢，把我们现在当前的对吧，这个品牌它的一个交易游对吧？然后呢，这个累加值也给求出来了啊把这个品牌交给李价值应该求出来了，对吧？呃，那么注意啊，目前他针对处理的这这李价值是谁，是不是应该咱们一个采集周期里边的呀，对吧？一个采集周期里边的，然后呢，我现在接下来再往下走，那干什么呢？将我们这个数据啊，那保存到我们这个MY搜Q中啊，将的数据保存MY搜QL里边，那么如果把数据保存在搜里边的话，那么这块呢，咱们刚才看了一下什么呢？你是不是得这个操作事物啊，对，而且操作事物咱们用的这个工具类对吧，而且人家告诉你了这个工具类咱们应该对吧，怎么来做怎么来用对吧，那咱们现在呢，就来使用一下这个对吧，那你要想保存到MYSO里边，那你想这个数据。

咱们是不是得一条一条来啊，对吧，那怎么办。在这里，那你肯定得把它当前的流数据保存到MY里面去，怎么办？For RD呗，到for RD，然后接下来当咱现在呢，在这里拿到了一个RDD是吧RDD，然后呢，我又对咱们RD的数据呢，来进行处理，对吧的RDD点我们的F对吧，来对它呢来进行处理，对对它进行处理，呃，那么咱们现在其实这块呢，那你也可以做一些优化对吧，那咱们现在这里可以什么呢？For foundation对吧，以分区为单位进行处理，对，然后切下来，那么咱们如果说以foundation的话，那这里呢，拿到的对吧，咱们看到对吧，这里应该是一个我们这个迭代集合对吧，叫purple I drr对吧，Purple I drr对吧，然后接下来，那么咱们现在呢，在我们这个里边对吧，那么他拿的应该是我们现在什么的，其实是我们这个对吧，这个ID对，然后名字，然后还有一个他的一个的交易额对吧，那么你拿到之后呢，在咱们当前的分区里边，那你。

可以这样干什么的，是不是有一个什么DB对吧？然后接下来，然后咱咱们这里是不是有DBS呀，然后DPS里边是吧，是不是有什么setup对吧？那么这个setup干什么呢？去加载配置文件啊，去多取配置文件，其实这块呢，它不像建连接这样，他其实你只把这个单子拿出来呢，那也行，找们家拿出也可以对吧？然后接下来，那咱们现在呢，把这东西处理好了之后，对吧？哎，那我现在配置文件读了，那么读完配置文件之后呢，那接下来咱们现在是不是得对着有数据进行处理了呀，对，那怎么办呢？PU啊I点我们现在呢，可以把这to例子一下，点我们这个VR对吧，点我括像VR对吧，那么这个时候呢，拿到是我们ta list对吧，Ta list，然后接下来，那么咱们现在呢，拿ta list之后，是不是可以对它做一个便利啊，对吧，它list点我们现在这个for循环，每次遍历啊，他拿到的一个东西，那应该是t midd对name。

对吧，这是咱们这个idea name，然这个呢是我们这个amount对吧，这个是我们的交易，然后接下来，那么你现在呢，是不是要把它保存到我们这个短的数据库里面去啊，那怎么保存呢？这里应该有个DB吧，对，然后切下来，然后现在呢把这里边给导进来，注意啊，导包，然后在它DB里边呢，那应该有一些我们这处理的方法对吧？那么咱们现在来看一看，这里是不是就叫什么local ts呀，然后在它log ts里边呢，那么它需要的个参数对吧，什么对吧，这个empressed对吧，那咱们现在直接把这些东西呢拿过来对吧，就我现在呢，这里边是吧，Pressed对吧，然后接下来有一个什么SESSION10是吧，那这个东西其实几个随便起个标的名啊对吧？然后接下来，那么咱们在这里对吧，那来放一放咱们这个circle对吧，那这个circle它是怎么写的，你看一看在这里CIRCLE1CIRCLEQ2是吧，那来这里边这个circle怎么写的对吧？来回车啊吧一个这个东西你要写什么circle往这里写。

你要写出circle口往这里写对吧，不不俩吗？对吧，再来一个，这是第二个对吧？那么咱们这两个circle分别干什么呢？这个是将我们现在的业务数据，呃，将那业务数据，然后呢，保存到我们这个数据库中啊，那么业务数据主要指的是谁呢？就是我们现在这个品牌啊，这个品牌对吧？呃，什么呢，这个品牌它的一个统计吧啊，它统计业务数据，然另外一个呢，咱们是将我偏移量到将W偏移量。啊，将偏量保存数据库中，保存到咱们这个数据库中，对吧？那么咱们现在这里再往里面这个写的话，那怎么来写，那是不是就是insert，然后into呀，然后进下来这个表名什么什么什么这个东西我就不写了，然后这块呢，那讲偏量保存这里边那这块呢，那是不是应该也是我们说inerl什么都能西都进行对吧？那咱们其实这里这个在我们这买S高版本里面，除了inerl之外是不是还有一个呀，对吧，就咱们在这里在执行的时候同学们对吧？那除了我们的iner之外，那如果说我现在要已经存在着呢，对吧，是不是可以replace呀，对吧，如果存在，那么这个时候呢，我需要进行替换啊，一会我们把这代码拿过来啊，一会我拿过来，就是对于我们偏移量执行的时候，大家想一想，我不是1420TO了，因为1420TO的话，是不是如果已经存在的话，这个东西插不进去了，但是偏移量大家想一想，比如说我原来这个是我这个主题A，然后这个分区的P0，然让它的偏移量的消消费这数G，然后偏量的。

是十，那么下次再做的话还是这块对吧，那么咱现在是不是应该把它改成20了，偏量是发生变化了，偏量发生变化就音色的这个是不是不行啊，所以说呢，在咱们这里有个什么叫re replace啊replace啊吧，就替换一下啊，如果说现在偏量变了啊，这个时候呢，我把它变成啊做一个替换啊做替换呃，然后接下来，那么咱们现在这个插入的时候，比如说啊，我举一个例子，把这个东西举完举举完例子之后，这代码不行，我直接拷虑过来是吧？那么假如说咱们刚才的这个表呢的在这对吧，比如说我们现在呢，是我们的opposite，然后下划线0523，那么接下来你要往这里加入的话，咱们是不是应该是这里面是你字段名，对，比如说你有什么topic，然后有什么group ID啊，有什么group ID，有什么咱position啊，有position啊，然后呢，有什么咱们现在这个outside对吧，然后接下来这里什么，那这value怎么写。

注意啊，这个value呢，那就这样。这样的话，是不是咱们现在这里相当于有几个占位符了，对吧，那如果你要这样写的话，这个占位符，那咱们是不是得给这几个传参数啊，对吧？那么怎么传参呢？这里有一个方法，这个方法呀，叫做棒啊，咱们一看这个棒的方法到底需要传什么参数，这里边。是不是咱们这个any类型后面加星号表示什么呀。

啊，是不是可以表示咱们这个多个参数啊对传多个，那这个多个参数，那就是什么呀，把topic给传过来啊，把大家topic传过来，把那格vid呢给传过来，然后呢，咱们这分区的给拿过来，大家想一想这个分区咱们可以从哪来获取。是不是咱们现在在这里我可以对我们这个opposite咱们的range识来进行一个便历啊，每一次遍历得到一个什么，是不是得到一个我们这个opposite outside range对吧？那么通过咱们这个off outside的range对吧，通过咱们这个off range把这往往上拿一下我这个代码对吧？那么通过咱们现在的这个off outside的range对off outside range，然后它点，然后partition这个方法是可以得到分区，通过咱们这个off outside的咱们range对这个方法，它里边说有一个叫什么啊，这个until对这个o set是不是可以拿到咱平量，对，然后现在还没完事呢，同学们在这里是我写有circle口，然后这个呢是给我circle口传参，然后接下来咱们再往下走干什么呢？那么你先要执行，那么执行是什么呢？有一个update的方法。

对吧，那么执行完update还不行对吧？那么你要想要这个circle再执行的话，得有一个什么呀，叫aline对吧，那么这块整个呢，这个circle才会去被执行啊，整个这个circleq呢才会被去执行对吧？这是关于我们大概的一个我们这个对吧，这个代码我呢在这给大家写的伪代码对吧？这块代码大家注意啊，这个东西大家简单的看一看啊，简单看一看对吧，因为这里这个代码和正常的一些我们现在不太一样啊，这里设及的一些方法，比如说DBS setup对吧，比如说呢，咱们现在呢DB的logo对吧，然后那这块呢，这里边也涉及了一些，对什么circle啊对吧，什么这里什么绑定啊，什么update啊，对这些对吧，其实呃，简单看一看不难啊，到时候直接咱们把这个东西拿过来，然后结合你的业务去保存一下就可以对吧？那么咱们现在呢，我说一共两种方案对吧？那么咱们呢，在这里我刚才大家记了第一种方案，这是方案一，我把方案一代码呢，直接拿过来，咱们运行一下对吧？来在这里我们复制对吧。

然后接下来咱们现在呢，把粘贴过来，那么当前呢，咱们的方案一它是怎么做的呢？它是单条插入啊，单调插入，然后把这个d streamam的名字呢，改一改啊，D名字改一改，然后接着咱一起来看同学们，那么在这呢，我们现在啊，如果使用我们这个方案一的话，其实和咱们刚才差不多，对，其实和咱刚差不多，对吧，说我现在呢，在这里有一个重要事啊，咱刚才没做，那这什么呢？大家想想这个是干什么。我们说这里是不是有分布式事物对吧？分布式事物咱们是不是要把这东西给拿到，把这数据给收集过来对吧？因为你本身注意啊同学们，咱们现在如果收集过来的话，那么这个时候咱们呢，是不是就没有必要在什么分区不分区了呀，对吧？所以说呢，注意咱们在这里对吧？如果以分区处理的话，那么这个时候呢，它有一个问题叫什么呢？叫分布顺对吧，咱们要避免一下导就你现在如了，如果刚才这里说分区对吧，那咱们现在分区的话，你要考虑对吧，这个分区的执行的时候，它是不不在同一台机器上啊对吧？所以说这块呢，是和咱们不一样的地方对吧？不一样的地方，那正常情况下大家一看，诶我现在要连接买circle，连接买circle，那么这个时候我要干什么，我是不是要对你做一个我们这个短这个以分区为单位进行处理呢？对吧？这个想法是对的，但是注意咱们这里还要考虑事物，那么如果考虑事物的话，那么这会儿呢，你不能把都做，咱们怎么办呢？咱们得把咱们这个分区的数据有多数据给他收集到专业端来，对吧，这样才行，然后接下来，那么咱们如果说数据不等于。

控的话，那么这个时候拿的数组咱们就做操作，咱们在当前这个数组里边，这就不用考虑什么性能了呀，因为全在咱们这个driver端的，对不对，所以说呢，咱们在这里对它的这个读取配置文件，对这个操作是干什么的，这个操作是读取我配置文件，呃读取配置文件，配置文件的名称和路径不要错，然后接下来在咱们logo ts里边把这东西传过去对吧？那咱们现在呢要写结果，那么写结果的话呢，这里他给他来一个统计时间啊，来统计时间，这个时间呢，咱们在这里先定一个simple for这样的一个格式化，对吧？然后呢，接下来把当前时间呢给拿到，当前时间也拿到对吧？然后接下来咱们从我们现在的这个数据里边，对吧，来做个分割，大家想一想，你现在呢，拿到的数据啊，这里边是不是这种形式的t midd，然后下划线，然后呢，名字对吧，然后接下来，然后这块是不是咱们现在的一个这个这个值啊，对吧，所以说呢，那么咱们现在呢，那么我对它进行遍历的时候，这个呢，应该有两步组成。

啊，一个是ID一个名字，所以说呢，我现在又下划线就能做了一个分割，把ID的名字给拿到，然后接下来把咱们现在呢这个给拿到，其实这块呢，你拿你不用在这处理也行，短因咱们上面是不是已经处理了呀，对，如果你要在下面处理的话，咱们上面这块是不是就不用处理了呀，对，删一个短删一个短的，比如说我现在把它上面这块对吧，这个呢，我就不需要处理了，对吧，刚才咱们在一输出的时候，我得让大家看看效果对吧，那这个时候呢，咱们现在这里你可以不处理对吧？那如果不处理的话，咱们现在呢在这对吧，你可以把我们现在的这个啊这个数据对吧，保留两位小数对吧，这样也行，对吧，然后接下来执行我这S狗对吧，这是S狗执行的时候呢，第一个S后语句对，那第二个呢，咱们这里短是用占位符对，然后接下来第三个给参数来赋值，那么这个参数赋值呢，主要有这么几个，一个统计时间就是当前时间，一个呢是我们的ID对，然后一个是名字，然后一个是我们当前这个值对吧，这块代码不难对吧，但是呢，对吧，我们这个这个就不写了，对吧，就直接呢在到这里边对，你直接把这。

东西拿过来就行啊，其实就是获取什么呀，就是获取咱们这个现在时间，然后对他做一个循环来进行处理对吧？那主要什么呢？主要是这块对吧？这有些东西大家没有接触过对吧？像这个东西呢，大家啊，简单练一练啊简单练一练对吧？然后接下来那么除了我的业务数据之外呢，还有偏量，这偏量呢，就对我的outside的认证来做一个便利啊，那做便利的话，那么咱们可以拿到这个分区ID，然后呢，以及我们现在偏量对吧？然后接下来咱们在这里注意啊，不是inser了，是我们release，然后呢，往我们这个0523啊这个表里面写数据，那么写完数据之后呢，在这里咱们呢，来去把这个东西给它对吧，这个参数绑定一下对吧，然后也是执行我们这个update，对对吧，这是我现在呢，这第一种方式，第一种方式呢，我们也不运行了，对吧，那么这种方式呢，一般咱们的这不用法对吧，那么咱们现在用什么呢？来第二种方式对吧，第二种方式对吧，因为第一种方式单条了嘛，对吧，虽然说咱们现在不用考虑我的优化对吧，但是呢，这个东西虽然数据。

特别较小啊，但咱们也得考虑优化啊，也得考虑优化对吧，那么第二种方式什么呢？来注意看是吧，我现在呢，把这个代码拿过来看一看同学们第二种方式能不能看懂啊，第二种方式啊，看一看能不能看懂。拿过来是吧，这个呢是我们的第二种方式，然后呢，把咱们现在这个对吧，给改一改。

批量插入啊，看一下咱现在第二种方式啊，第二种方式，其实第二种方式和第种方式它俩主要的一个区别在什么地方呢？来你啊，主要区别呢，其实就是对于我们现在这个数据处理的搜狗这块啊，这个主要是搜狗这块，别的呢，其实是吧，没有什么变化，大家看首先呢，第一件事这个东西还是不是把这有端数据啊，给你把一块数据给输到专有端呢，这是第一个，然后接下来这个呢，是固定语法，这个固定语法对，然后接下来这个拿到数据对吧，然后拿到时间，然后接下来在咱们这里边啊，这有一个叫这叫什么by permit list，你看这个东西可能放什么的呀。可能化参数的对不对，对吧？那是怎么回事呢？大家注意看我现在啊，那么把所有的数据都涉及到专用端了，那我对专用端数据呢，来进行一个遍历，每次遍利得到这样的一个元组对吧？前面的元组的第一元素是我这个品牌的ID和名字，第二个元素呢，是我们现在品牌它的一个交易额，对吧？然后接下来咱们把这个交易额呢，给它转换一下，叫四舍五入对吧？然后取出我们的品牌的这个ID和名字对吧？那接下来注意看同学们，像这几个东西，什么ID呀，名字呀，对吧？包括咱们现在它的一个统计的数量，包括什么呢？包括咱们上面的一个时间对吧？大家想一想，你在往我们的数务差的时候，这些东西是不是就是我们value，它对应的内容啊，对吧，你想我在统计时间这一个，然后呢，咱ID是一个name这一个，然后呢，咱们现在这个交易额这些东西就是我们现在要插入的内容，对吧？那所以说呢，那我现在呢，把这几个东西放在哪了，放在一个这个集合里边去了，注意啊，这里我把它当前这几个东西要插入数据放在哪了，放到一个集合里面去了，对吧。

我单独把咱们当前这四个数据都放在一起里去了，你可以把理解成什么，这是我当前要插入到我们现在买思里的一行数据。对吧，一行数据，然后接下来，那么你现在把它分成一个例子之后，那你又干什么呢？你又把它当前这行数据放在哪了？是放到一个粒子集里去了，也就是当前的结构应该是这样的，List里边的，然后嵌套了一个list等，或者说咱现在应该是SEQ里边，然后呢，嵌套了一个SEQ，因为在SC里边这个s seq是不是就是list子呀，对吧？那么什么意思呢？当前那边内层s seq，它代表的是咱们这里边数据的一个封装吧，但是我现在有多条啊，导我有多条，找到多条的话，那咱们放到哪了，是不是还是放到一个SQ里面去了，对吧，那们接下来它怎么执行的呢？大家看咱们现在呢，在执行的时候insert into，然后接下来这块都是一样的，然后这块呢，是我们这个value，这这这个语句是不是一样的，不一样地方大家注意看啊，咱们刚才调的什么，是不是调的是半这个方法，现在呢，调的是bech对吧？那如果be方法的话，那这里需要什么呢？需要去传一个参数，这个参数什么类型的，对吧？你看是不是咱们一个例子。

集合对吧，那咱这的集合上面是不是有啊同学们对吧？但是你这的是list，人家要求什么，人家要求你对吧，你在这里你得给我传什么对吧？来你看家传什么SEQ啊，所以说呢，你要把它转换一下啊，所以说s seq对吧，它的下边对吧有一个实现对吧，这具体实现啊吧是这意思的啊吧是这意思，那但是咱现在呢在这里对吧，我呢还是给转成s seq对吧，那么另外啊，这里如果说我现在这个这个集合里边对有多个参数的话，那么这个时候呢，那你要加上一个对吧这样的内容对吧，这个东西它有固定的，就我现在在往里边你在传的时候对吧，那么这里呢，它有固定的写法对吧，你要把这个东西呢给它加上啊，这个东西呢，就给加上对吧，表示我现在这里边这个参数对是任意的，然后呢，这个表示我们多个对吧，这个表示参数类型任意对，然后接下来没有什么update，直接apply就行啊，直接回apply就行对吧，然后上面呢，就这块处理不一样，下边这块呢处理啊，其实和咱刚才对就是一样了啊，还是我们这个。

啊replace对吧，下面就一样了对吧？那么这块呢是批量处理对吧？批量处理呢，主要设及这参数处理对吧？那么这块其实呃这我西得这这语法没必要去这个特意去练啊，因为你想你在这练的话，这个东西我估计到时候你也记不住啊吧，所以说呢，你就看效果对吧，知道咱们这个东西在这儿对吧，等到时候你拿过来对吧，用的话过来考就行了啊过来考就行了对吧，这个代码其实结合你们到时候你有这个东西代码到时候写的时候肯定不难啊，肯定不难好了，那关键咱现在要看看效果啊看效果我现在呢要测试对吧，看效果对吧？呃，那如果说看效果的话，诶我少东西，我同学们有同学告诉我说，老师我说少东西，你是不是得把这个偏移量提交啊，咱们说在outside什么这个这这个东西偏移量提交一下，是不是得做个这个事，把这个事给忘了是不是啊啊对咱们现在这个东西注意啊，同学们和原来不一样了，对吧，咱们现在这是干啥的，天量不在那里维护了。

对吧，就是前面整个业务是不是都一样的，从卡卡读数据对吧，然后呢，咱们做处理对吧，然后往他们这个保存，但是注意偏移量咱们不在red里了，对吧？所以说你看咱们现在说老师你这个里边没有写入片上操作，咱们在我这个offet的这个这个manager u里M里边，那么咱工击力里边的，我们写这个写入偏量在哪写入的，是不是咱们现在这个在这个事物流写入的对吧，就是目前你现在把咱当前这两个写入操作都放在哪了，都放在对吧，这个local ts里边了，那么他俩呢，就是一个事物啊，它就是一个事物对吧，要不然全部成功，要不然全部失败，对吧？那么咱现在来看一看同学们，假如说啊，我在这里，我给你测试，我把这个打开，那这干什么呢？上面是不是写入我们业务数据啊，下边是不是写入便宜量，然后进下来我在这里，他们中间抛出一个什么，抛出个异常对吧？那如果抛出异常，那意味着什么呢？对吧？那意味着咱们现在在咱们这里边对吧，那我。

是不是它俩是个整体对吧，它俩是个整体对吧，那是肯定都不成功了，对吧，所以说呢，咱现在来看一看同学们，我来运行我的程序啊，我来运行我的程序。

把这个起一下啊，把它起一下表名啊，另文我没改啊，在这里我记得我在上面改了一个，是不是改了一个单条的是吧？啊我我记得改了一个改了一个那个单条的注释掉了是吧？来到咱现在呢，来把这个东西呢去对来用一下啊。然后呢，来到我们现在这个数据库里边，对，来到咱数据库里边，呃，找到我们现在0523，然后呢，找到咱这两张表，那目前呢，咱们这张表里面没数据啊，这张表里面呢也没数据对吧？然后接下来对吧，那么咱们现在呢，来看一看，那这个应该是写了，因为咱们现在没有打印输出嘛，对吧？呃，然后呢，我来到这里，我呢去执行一下我这个模拟设能数据这个程序啊，来执一下模拟数据程序啊来看一看咱现在呢，对吧。

那大家想想，我现在盯着他的话，我期望能够出现一个什么结果呀，我现在啊，如果说我现在盯着这个，这个咱们控制台看的话，我期望控制台够出现一个什么结果。嗯。我希望控制他，给我抛个异常出来。你想一想，咱们现在这里，我我在咱们这里边，我是不是这要测试一下中间是不是抛异常啊对吧，你要控制还抛异常的话，那你想我怎么能往下进行呢？对吧？所以说我特别希望抛异常还好，是不是是不是有测试异常出来啊，对吧？那么如果出现异常说后咱程序执行了呀，对吧？那你说这个时候在数据库里面有数据吗？对吧？来刷新一下对吧？来没有来刷新一下对吧，这时也没有好，那么咱们现在这里啊，如果要是没有数据的话，那接下来咱们现在呢，把这异常给干掉啊，也就说我现在保存业务数据的时候，这是正常的，对吧？然后接下来咱们要写入偏移量，对吧？他整个执行的时候如果都正常，那么这个时候会什么情况来啊，我们现在再去运行一下程序。

来，那么咱们现在呢，来去执行一下啊，来去执行一下，呃，那么咱们现在呢，来运行我这个账va程序对吧？来模拟这数据，那么这个时候他这里面就应该没有异常了，应该没有异常了啊。看他吧。这个数据是不是过来了，已经到order order white过来了，Order过来了，那order white过来这块呢，估计稍微等一会对吧，然后咱们现在呢，来看一看没报错吧，没报错的话，咱们到这里来这个这个查询一下对吧？先查谁呢？来查查统计的情况对吧？先看这个吧，对吧，这是我这个这个偏移量来刷新对吧，大家看咱们当前，然后呢，我们现在这个消费者组，咱们这个主题，然后呢，这四个分区，它偏移量是多少，是不是有了，然后接下来除了这个之外呢，那么咱们这里注意看啊，这里我刷新一下是吧，咱们现在这品牌的数据是不是就关了对吧？哎，那么咱现在呢，这里对吧，包括什么，包括咱们当前的这个品牌对吧，它的一个我们现在对吧，这个交易额我问大家同学们，我现在如果说我再去运行一，再去运行一次的话，那么这个数据是吧，它会不会增多。

肯定会吧，对吧，咱们来看一看啊，要把这个弄明白，比如说老师这里面就这数据统计就行了，对吧，来运行对吧，来看是吧，那么咱们现在呢，把这个东西这个运习完之后，那么当前的咱们这个里数据会增多，这就数据呢，这里数据肯定会更新嘛，原来是三十三十三十六，45 34对吧来那咱们现在呢，等着刷新啊，诶三十三三十六四十五三十四是吧？等刷新啊。

95这个应该过了吧，对吧？来大家现在呢，来刷新一下，看一看我现在效果对吧，大家看33 34 45 36现在是不是变了对吧？现在是不是变了，然后接下来到这里呢，数据对吧，来看一下我现在呢，来刷新吧，那这里是不是又多了七条对吧？但是他们俩什么不一样呢？是它计时间是不是不一样对吧？统计时间不一样对吧？好了，那么假如说啊同学们，那么咱们现在呢，这里正常情况下是不是这这个这个数据是不是源源不断的在变化的呀，等源源不断的变化的对吧，那么接下来那人家有一个对吧，比如说你们公司制定我这公司战略的对吧，这样一个分析人员，然后呢，需要干什么，需要从你对吧这里大数据，你需要把这数据给他，对吧，那怎么拿呢？你说要给他提供一个数据接口了，对吧，也就是说你现在呢，我你们接下来要做的事是干什么，我现在需要你们从我当前这个数据库的这章表里边，然后呢，去把咱们现在的某一个品牌的某一个品牌，它的一个我的交易额情况给人拿过去。

对吧，那但你想要统计这个教流情况的话，那你是不是得给我一个这个时间限制呀，统计哪天的时候从哪到哪的呀，你说我加个时间呀，对吧，人家可能告诉你来，你把昨天到今天呢，咱们的交易额对吧，你给我拿过来，那你想昨天是不是咱们的起止时间对吧？咱今天是不是咱结束时间呀，对吧，那你这个时候对吧？那你应该把咱当前的这个这统计给我拿过去，对吧，肯定不是一个啊，那这个时候呢，那你得想我统计交流的话，那肯定对吧，也得把这思会句写一写，当前思维预学写好，那这怎么做，我先把这个提一下，给大家介绍一下啊。