Обновить dags/pogasheniya.py
This commit is contained in:
parent
12cf25d36c
commit
7ad336d6e3
|
|
@ -64,8 +64,8 @@ def pogasheniya(**kwargs):
|
||||||
conn.execute("""
|
conn.execute("""
|
||||||
INSERT INTO public.pogasheniya (schet, uid_dogovor, name, nomer, date_begin, date_end)
|
INSERT INTO public.pogasheniya (schet, uid_dogovor, name, nomer, date_begin, date_end)
|
||||||
SELECT * FROM temp_pogasheniya
|
SELECT * FROM temp_pogasheniya
|
||||||
DO UPDATE SET
|
|
||||||
ON CONFLICT (schet, uid_dogovor, nomer)
|
ON CONFLICT (schet, uid_dogovor, nomer)
|
||||||
|
DO UPDATE SET
|
||||||
name = EXCLUDED.name,
|
name = EXCLUDED.name,
|
||||||
agreement_num = EXCLUDED.agreement_num,
|
agreement_num = EXCLUDED.agreement_num,
|
||||||
agreement_date = EXCLUDED.agreement_date,
|
agreement_date = EXCLUDED.agreement_date,
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue