開始
加載和管理數據
處理數據
政府
參考和資源
2023年4月7日更新
給我們反饋
這個例子使用JDBC驅動程序查詢MySQL。有關讀取、寫入、配置並行和查詢下推的詳細信息，請參見使用JDBC查詢數據庫．
司機＝“org.mariadb.jdbc.Driver”database_host＝“< database-host-url >”database_port＝“3306”如果使用非默認端口，則# updatedatabase_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）．選項（“數據表”，表格）．選項（“用戶”，用戶）．選項（“密碼”，密碼）．負載（）
在Databricks運行時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）．選項（“用戶”，用戶名）．選項（“密碼”，密碼）．負載（）