gpt4 book ai didi

python - PYSPARK:CX_ORACLE.InterfaceError:不是查询

转载 作者:行者123 更新时间:2023-12-03 23:14:45 25 4
gpt4 key购买 nike

我需要在 spark 作业中执行更新查询。我正在尝试下面的代码。但面临问题。

import cx_Oracle
def query(sql):
connection = cx_Oracle.connect("username/password@s<url>/db")
cursor = connection.cursor()
cursor.execute(sql)
result = cursor.fetchall()
return result
v = [10]
rdd = sc.parallelize(v).coalesce(1)
rdd.foreachPartition(lambda x : [query("UPDATE db.tableSET MAPPERS ="+str(i)+" WHERE TABLE_NAME = 'table_name'") for i in x])

当我执行上述过程时,出现以下错误。
cx_Oracle.InterfaceError: not a query

我尝试使用以下代码手动更新。
result = query("<update query>")

当我这样做时,作业正在连续执行

最佳答案

我解决了我的问题。根据卢克的输入。我用过 fetchall()用于查询。我需要使用 commit() .所以更改了代码并检查其工作正常。

import cx_Oracle
def query(sql):
connection = cx_Oracle.connect("username/password@s<url>/db")
cursor = connection.cursor()
cursor.execute(sql)
result = connection.commit()
v = [10]
rdd = sc.parallelize(v).coalesce(1)
rdd.foreachPartition(lambda x : [query("UPDATE db.tableSET MAPPERS ="+str(i)+"WHERE TABLE_NAME = 'table_name'") for i in x])

关于python - PYSPARK:CX_ORACLE.InterfaceError:不是查询,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53285101/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com