查詢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)。選項(“用戶”,用戶名)。選項(“密碼”,密碼)。負載()
             