查询MySQL数据砖

这个示例查询MySQL使用JDBC驱动程序。为更多的细节在阅读,写作,配置并行性,和查询下推,看到的使用JDBC查询数据库。

请注意

你可能更喜欢Lakehouse联合会管理MySQL查询。看到使用Lakehouse联合运行查询。

使用JDBC

              司机=“org.mariadb.jdbc.Driver”database_host=“< database-host-url >”database_port=“3306”如果你使用非默认端口#更新database_name=“<数据库名称>”表=“<表名称>”用户=“<用户名>”密码=“<密码>”url=f" jdbc: mysql: / /{database_host}:{database_port}/{database_name}”remote_table=(火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载())
             

              瓦尔司机=“org.mariadb.jdbc.Driver”瓦尔database_host=“< database-host-url >”瓦尔database_port=“3306”#更新如果你使用一个非- - - - - -默认的港口瓦尔database_name=“<数据库名称>”瓦尔表=“<表名称>”瓦尔用户=“<用户名>”瓦尔密码=“<密码>”瓦尔url=s " jdbc: mysql: / /$ {database_host}:$ {database_port}/$ {database_name}”瓦尔remote_table=火花。读。格式(“jdbc”)。选项(“司机”,司机)。选项(“url”,url)。选项(“数据表”,表)。选项(“用户”,用户)。选项(“密码”,密码)。负载()
             

在砖运行时使用MySQL连接器

在砖运行时11.2及以上的,您可以使用已命名的查询MySQL连接器。看下面的例子:

              remote_table=(火花。读。格式(“mysql”)。选项(“数据表”,table_name)。选项(“主机”,database_host_url)。选项(“端口”,3306年)。选项(“数据库”,database_name)。选项(“用户”,用户名)。选项(“密码”,密码)。负载())
             

              下降表如果存在mysql_table;创建表mysql_table使用mysql选项(数据表“<表名称>”,主机“< database-host-url >”,港口“3306”,数据库“<数据库名称>”,用户“<用户名>”,密码“<密码>”);选择*从mysql_table;
             

              瓦尔remote_table=火花。读。格式(“mysql”)。选项(“数据表”,table_name)。选项(“主机”,database_host_url)。选项(“端口”,3306年)。选项(“数据库”,database_name)。选项(“用户”,用户名)。选项(“密码”,密码)。负载()
             