温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
那么在介绍一种用的比较少的,也是不推荐的方式啊,咱们前面讲的是用官方提供的这个connect连接器,那么它底层会自动帮我们做很多的优化,那么在早期没有提供这个connect之前,我们是可以用JDBC的方式去连的,为啥呢?因为我们知道Doris是遵循的是my circlel协议,对吧?那么既然遵循my circle协议,讲道理我就能通过JDBC去连接啊,这也是以前做的方式,是一个早期写法,但他有个不好的地方,无法感知Doris的数据分布。那这样的话,对可能就对Doris造成了查询压力比较大,但如果你使用官方的连接器啊,那这方面他都会都考虑到了。那这个写法我们就简单了解一下,看一眼就行了啊。这边给大家啊,你看。呃,写入数据的话,那前面也是创造一个DF对吧,那你看下面怎么写这个df right mode,哎,我以追加的方式,然后呢,点JDBC啊区别就在这里啊,然后地址呢,我得写这个,那这个端口写的是查询端口。
01:11
就像我们在命令行通过MYSQL客户端连接fe的时候,用的也是查询端口9030。那跟上一个库名啊,跟上一个表明还有其他配置项,只能放在这个配置对象里面了,比如说用户名密码。通过这种方式来进行一个写入,那查询呢,我们也一起看一下啊,我先给它执行完吧。那这边。就是。我改一下吧,比如说这个212121啊。好,先让它跑起来。通过JDBC也是能写入的啊。那再看一下读取数据。读取数据一样的,我们这个Spark session read,然后format只能指定为JDBC的方式。
02:06
那这个时候呢,我们也同样要指定几个基本配置项啊连接地址。用户名密码啊,数据库和表名。那这种是不是传统的MYSQL写法是吧?啊,当然这边也能实现,但是不建议使用啊,大家注意JDBC的方式,不推荐再这么去写了啊。等他执行的话,我们看一下效果就OK了。插入完成,我们查一下这张表有没有ID为二一的,你看这几条是不是新插入的。对吧,前面还没有21呢啊,现在有了CDBBC的方式可以写啊,但不推荐啊。那就一样的,我们来看一下读数据啊,一样可以可以读出来,我们快速的给他跑一遍。来编译一下。
03:03
好,执行。那我们可以看到结果出来了啊,全部都查到了JDBC的方式啊。不推荐使用。但我们还是简单讲一下啊。嗯。
我来说两句