bn_user
/
sigma
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Обновить dags/upload_dicts.py

This commit is contained in:
bn_user 2025-11-13 16:11:09 +00:00
parent d0c9f336cc
commit c44863c23b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dags/upload_dicts.py
View File

@ -144,7 +144,7 @@ def take_bank(**kwargs):
) )
# conn.execute(f"DELETE FROM public.{table_name}") # conn.execute(f"DELETE FROM public.{table_name}")
conn.execute(f""" conn.execute(f"""
INSERT INTO public.{table_name} (name, inn, kpp, uid_bank) INSERT INTO public.{table_name} (id, name, inn, kpp, uid_bank)
SELECT SELECT
row_number() over (order by uid_bank) id, row_number() over (order by uid_bank) id,
name, name,
@ -206,7 +206,7 @@ def take_organizaciya(**kwargs):
) )
# conn.execute(f"DELETE FROM public.{table_name}") # conn.execute(f"DELETE FROM public.{table_name}")
conn.execute(f""" conn.execute(f"""
INSERT INTO public.{table_name} (name, inn, kpp, uid_organizaciya) INSERT INTO public.{table_name} (id, name, inn, kpp, uid_organizaciya)
SELECT SELECT
row_number() over (order by uid_organizaciya) id, row_number() over (order by uid_organizaciya) id,
name, name,