跳到主要内容

Spark 模式 - JDBC数据源

读取 JDBC 数据源

Dataset<Row> sparkDataset = spark.read()
.format("jdbc")
.option("url", "myUrl")
.option("user", "myUser")
.option("password", "myPwd")
.option("query", "myQuery")
.option("driver", "org.postgresql.Driver")
.load();
SparkDataset dataset = new SparkDataset(sparkDataset);

在下面的例子中,项目必须包含 postgresql Driver 的依赖

<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
<version>42.5.1</version>
</dependency>

查看所有支持的选项 官方文档.

写入

不建议使用 jdbc 格式来编写 Trevas 的Dataset (请看 这里)