Запрос работает в редакторе SQL, но, когда я передаю его в код JDBC, добавляя дополнительные аргументы, как ниже:
Main Fucntion:
def Read_jdbc_source (Spark, connection_details, Query):
попробуйте:
return Spark.Reard
. Формат):
попробуйте:
return spark.read
. />.option("url ", connection_details [" url "])
.option("dbtable", f "({Query})")
.option("driver ", connection_details [" Driver "]
. Загрузите? /> logger.error(f"eror Reading JDBC Источник: {str (e)} »)
rave < /p>
Ошибка -
info:py4j.clientserver: java.sql.SQLSyntaxErrorException: ORA-00907: missing right parenthesis
and qeury to jdbc =>
Caused by: Error : 907,
i am passing correct query to jdbc spark but its appending some other things in query every time
what we can do with this ? < /p>
select * from (selectCount ( *) as alot_rows, sum (fund_skey) как sum_of_fund_skey, sum (servicer_client_id) как sum_of_servicer_client_id, sum (fund_id) как sum_fund_id, sum (Legal_Entity_org_Or_ort_ SUM(FUND_TYPE_ID) AS SUM_OF_FUND_TYPE_ID FROM dev_dl_uat_hvr_tci.silver.dim_fund WHERE dim_fund.DS_MARKER_ID = '20250209224347') SPARK_GEN_SUBQ_16 WHERE 1=0
this is comming extract in query ....
Spark_gen_subq_16, где 1 = 0 < /strong> < /p>
исходный Query => Query я хочу передать основную функцию, которая работает нормально в редакторе
select * from ( * select ( *) as total_row Sum_of_servicer_client_id,
sum (fund_id) как sum_of_fund_id,
sum (legal_entity_org_id) как sum_of_legal_entity_org_id,
sum (fund_type_id) как sum_of_fund_type_id
from (fund_type_id) dev_dl_uat_hvr_tci.silver.dim_fund, где dim_fund.ds_marker_id = '20250209224347')
Подробнее здесь: https://stackoverflow.com/questions/796 ... -and-prant
