pyspark df.write.format("jdbc") 授权声明 DB2

Posted

技术标签:

【中文标题】pyspark df.write.format("jdbc") 授权声明 DB2【英文标题】:pyspark df.write.format("jdbc") grant statement DB2 【发布时间】:2020-04-10 15:56:06 【问题描述】:

我想添加一个命令来添加我的授权语句,这样我就可以为用户提供对我使用 pyspark 加载的表的选择访问权限。

  df.write.format("jdbc")
    .option("url", "jdbc:db2:@//<host>:<port>/<srvice_name") \
    .option("user", "<user>") \
    .option("password", "<pass>") \
    .option("dbtable", db_query) \
    .option("driver", "com.ibm.db2.jcc.DB2Driver")

【问题讨论】:

您的主题行和关键字提到了 Db2,但您只显示了 Oracle url 和 Oracke 驱动程序。编辑您的问题以解决该问题。 【参考方案1】:

我假设您正在寻找 pyspark 中的选项。不知道是否可以使用pyspark。您可以使用其他数据库访问方法,如 SQL Alchemy。

How to grant access privileges to DB2 table using SQLAlchemy in a jupyter notebook

【讨论】:

以上是关于pyspark df.write.format("jdbc") 授权声明 DB2的主要内容,如果未能解决你的问题,请参考以下文章

通过 Spark 加载的表在 Hive 中无法访问

Databricks 写回天蓝色突触错误

Spark 3.0 - 使用 .save() 或 .saveAsTable() 保存时的读取性能

以编程方式定义 SQL 列的大小

将数据帧保存为外部配置单元表

如何使用 Spark 删除数据库中的行?