写入 JDBC 表的 SparkSQL SQL 查询是什么? [英] what's SparkSQL SQL query to write into JDBC table?

问题描述

用于 Spark 中的 SQL 查询.

For SQL query in Spark.

对于read，我们可以通过

For read, we can read jdbc by

CREATE TEMPORARY TABLE jdbcTable
USING org.apache.spark.sql.jdbc
OPTIONS dbtable ...;

对于write，使用SQL将数据写入远程JDBC表的查询是什么?

For write, what is the query to write the data to the remote JDBC table using SQL?

注意:我希望它是 SQL 查询.请提供使用 SparkSQL 的 HiveContext.sql(...) 时可以写入 jdbc 的纯SQL 查询".

NOTE: I want it to be SQL query. plz provide the pure "SQL query" that can write to jdbc when using HiveContext.sql(...) of SparkSQL.

推荐答案

INSERT OVERWRITE TABLE 将使用 JDBC 连接写入您的数据库:

An INSERT OVERWRITE TABLE will write to your database using the JDBC connection:

DROP TABLE IF EXISTS jdbcTemp;
CREATE TABLE jdbcTemp
USING org.apache.spark.sql.jdbc
OPTIONS (...);

INSERT OVERWRITE TABLE jdbcTemp
SELECT * FROM my_spark_data;
DROP TABLE jdbcTemp;

这篇关于写入 JDBC 表的 SparkSQL SQL 查询是什么?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！