用于 Spark 中的 SQL 查询。
对于读取，我们可以通过以下方式读取 jdbc
CREATE TEMPORARY TABLE jdbcTable
USING org.apache.spark.sql.jdbc
OPTIONS dbtable ...;
对于写入，使用 SQL 将数据写入远程 JDBC 表的查询是什么？
注意：我希望它是 SQL 查询。请提供纯“SQL查询”，可以在使用SparkSQL的HiveContext.sql(...)时写入jdbc。
An INSERT OVERWRITE TABLE将使用 JDBC 连接写入您的数据库：
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;
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
