0

На первой части скрипта при неуникальных данных в вставляемых элементах возникает ошибка останавливающая скрипт. Как сделать чтобы возникающая ошибка не останавливала выполнение скрипта, и скрипт выполнял дальнейшую работу? В моем понимании в случае ошибки 1го"try:", должен обрабатываться 2й"try:" но этого не происходит....

Ошибка: cur.execute(sql_update) psycopg2.errors.InFailedSqlTransaction: ОШИБКА: текущая транзакция прервана, команды до конца блока транзакции игнорируются

def table_update():
    conn = psycopg2.connect( dbname user host password)
    cur = conn.cursor()
    try:
        cur.execute("insert into us(A,B,C,D,F,G) "
                    "VALUES (%s,%s,%s,%s,%s,%s)", us_table)
    except: 
        print("Error")
        try:
            update = "UPDATE us set(A,B,C,D,F,G) = "
            where = " WHERE A = "
            sql_update = update + str(tuple(us_table)) + where + 
                "'" + us_table[0] + "'"
            cur.execute(sql_update)
        except KeyError as e2:
            print("Error", e2)
    conn.commit()
    cur.close()
    conn.close()
12
  • вы же уже работаете с except. Ну и обработайте ошибку так же. 21 мая 2022 в 10:40
  • Сергей, просьба описать поподробнее как пропустить ошибку.
    – traderr
    21 мая 2022 в 10:49
  • давайте наоборот, а то долго будет - вы except KeyError as e1: по какому принципу делали? 21 мая 2022 в 10:59
  • в моем понимании except должен обработать ошибку и отпустить дальше обрабатывать скрипт. но он в этой конфигурации except репорт выдал и скрипт остановил. гдето в синтаксисе ошибка чтоли?
    – traderr
    21 мая 2022 в 13:59
  • Тогда вопрос: у вас именно такая ошибка? (не указано в вопросе). Именно Key Error? Вывод ошибки тогда в вопрос включите, чтобы могли помочь. 21 мая 2022 в 14:02

1 ответ 1

0

В каждом try нужны свои open/close конекшн. Print после первого except:тоже ставить нельзя он не позволят второй функции запуститься. Правильно будет так:

def table_update():
    try:
        conn = psycopg2.connect( dbname user host password)
        cur = conn.cursor()        
        cur.execute("insert into us(A,B,C,D,F,G) VALUES (%s,%s,%s,%s,%s,%s)", us_table)
        conn.commit()
        cur.close()
        conn.close()
        print("insert ok")
    except: 
        try:
            update = "UPDATE us set(A,B,C,D,F,G) = "
            where = " WHERE A = "
            sql_update = update + str(tuple(us_table)) + where + 
                "'" + us_table[0] + "'"
            cur.execute(sql_update)
            conn.commit()
            cur.close()
            conn.close()
            print("update ok")
        except KeyError as e:
            print("Error", e)

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.