
118
|
第
5
章
# Python代码
# 用load方法从JDBC源读取数据
jdbcDF = (spark
.read
.format("jdbc")
.option("url", "jdbc:mysql://[DBSERVER]:3306/[DATABASE]")
.option("driver", "com.mysql.jdbc.Driver")
.option("dbtable", "[TABLENAME]")
.option("user", "[USERNAME]")
.option("password", "[PASSWORD]")
.load())
# 用save方法将数据写入JDBC源
(jdbcDF
.write
.format("jdbc")
.option("url", "jdbc:mysql://[DBSERVER]:3306/[DATABASE]")
.option("driver", "com.mysql.jdbc.Driver")
.option("dbtable", "[TABLENAME]")
.option("user", "[USERNAME]")
.option("password", "[PASSWORD]")
.save())
5.3.4
Azure Cosmos DB
为了连接
Azure Cosmos DB
数据库,需要先构建或者从
Maven
或
GitHub
下载用于
JDBC
连接的
jar
包
,接着将其添加到 ...