00:00
接下来给大家讲一下SPA circle如何来连接my circle my circle是关数据库,那我完全可以把这个MY数据库的表啊,当成我的数据源,对吧?那么从这个表中读取数据来形成我们data frame来继续操作,那么我们接下来呢,就给大家演示一下啊,咱们看一看我们该如何去完成它的操作,那我们这里只演示在当中通过操。首先我们第一个要导入的是依赖关系啊,那么这个依赖关系呢,在咱们这里呢,咱们来看,我们首先把买SQL的驱动的依赖关系给它加上。呃,加上之后,接下来我们在这里面继续往下看啊,那么下面呢,其实跟我们前面大同小异,只不过呢,它采用的是通用的方式,然后呢,加了个format,再加上option来增加一些我的环境配置,那么这里呢,我们一块来看一看,首先拷贝。零四啊,然后呢,这个改成我们叫JDBC,然后呢,点击OK啊放过来,放过来以后其他呢,我们暂时就先都不要了啊,把这个去掉,同样道理呢,把这个呢,我们也都不要啊,咱们也都不要把这个去掉,嗯。
01:10
好了,那么现在呢,我们就读取啊,来写上咱们叫读取my circle的数据啊,那怎么读取呢?spark.read点我们叫load,但load大家都知道,其实我们load的时候啊,它会有一个什么格式,那我们一般情况下呢,需要把这个格式变一下,咱们叫form,然后写上一个叫JDBC,对吧,那应该是这样啊,然后接下来我们再来点我们的option,这个option呢,是需要增加一些配置的,这个咱们就不一点一点给大家写了,咱们直接拷贝了啊来。咱们的这个呢,就直接拷贝啊,拷贝到咱们的这个位置,诶来拷贝,嗯拷贝之后呢,把这一块呢给它拿过来啊来拿过来好复制一下,那这里呢,是我本机的地址,这是买SQL的默认端口号3306啊这是数据库的名字,这是驱动程序用户名和我们的密码啊这是我们的表啊,这张表呢,我们这里是有的啊SPA,然后呢,里面ID和那我们现在就要想办法从中把数据给它读取出来,对吧?嗯,那我完全可以这样啊,咱们写上一个叫DF,嗯,好OK,然后呢,把这个呢,诶咱们写上咱们叫DF。
02:25
好了,那这么写完了以后,我们就看看我们的结果是不是能够跟我数据库当中的数据保持一致,好吧,现在呢,我的运行啊,看一看结果。如果没问题的情况下,我们数据库当中的数据就会展现出来,对吧?同学们好,同学们,我们现在呢,已经把数据给它读取出来了,那你能把数据读取出来,你是不是应该还能够给它保存呢?所以呢,我们写上啊,咱们叫做保存数据,那么保存数据的时候,因为我们前面已经有DF了,对不对,那所以我们就准备呢去保存不就完了吗?所以拷贝啊来,我们写上叫做right,嗯,咱们叫做点right以后,咱们在点有一个叫save啊,但是你要记住了,同学们,我们save呢,保存默认呢,也是什么我们的格式,所以呢,我们在这种情况下也要把它稍微的变一变啊,把这些东西来拷贝,那我觉得呢,把这个咱们原封不动放过来,那也就可以了,但你放过来以后还有个问题,点,点什么呢?
03:23
我们叫做那个保存模式,因为我们保存的时候,默认情况下它会有个什么东西啊,它会有一个栏,就是我们说会涉到一个出错的问题,所以我们点一下这边有个叫aend啊,但是我也担心啊,就是说我们想演示一个创建新表的操作,所以呢,我们这里给他来一个啊,咱们叫做一啊,就是一张新表,这样的话跟之前的表呢不冲突啊,咱们希望完成这样的一个操作啊,所以前面是读取,下面呢就是保存,现在我们一块来看一看。好,同学们,现在程序已经执行完毕了,我们来看看我们的表,咱们刷新一下,在这里我们刷新,刷新以后你会发现多出来一条数据,对不对,来再点一下,点完以后看一看,你会发现咱们现在里面就会有我们的数据啊,就是这样的。
04:13
好了,那么我们在当前的这个情况下呢,我们去进行了操作就完事了啊好了同学们,嗯。
我来说两句