版本和准备
MySQL 的版本
5.7.25 ,innodb 引擎jar 包的准备
mysql-connector-java-8.0.11.jar 是从这儿下载:
https://jar-download.com/artifacts/mysql/mysql-connector-java/8.0.11/source-code关键部分
代码部分
#把最终的结果写入到mysql, sqldf201301是一个spark DataFrame的数据结构
sqldf201301.write.format('jdbc').options(url='jdbc:mysql://ip:3306/nytaxi?useUnicode=true&characterEncoding=utf8', useSSL="false",\
driver='com.mysql.jdbc.Driver',dbtable='nytaxistaus201301',user='prod',password='pw').mode('append').save()
# 'ip'就是填写具体的ip,比如192.168.1.10, 'nytaxi' 是库名
# ‘nytaxistaus201301’ 是表名; 'pw' 就是 mysql 中 prod 用户的密码。