面试题：PostgreSQL事务结束时异常处理与数据一致性维护

PostgreSQL 处理方式

自动回滚：当事务执行过程中遇到错误，PostgreSQL会自动回滚该事务，撤销在事务中已经执行的所有数据修改操作。这确保了在事务失败时，数据库状态保持在事务开始之前的样子，维护数据一致性。例如，一个事务包含插入、更新操作，若更新操作出错，插入操作所做的更改也会被撤销。
错误信息记录：PostgreSQL会记录详细的错误信息，包括错误类型、错误位置等。这些信息可通过日志文件或者应用程序获取，帮助开发者定位和解决问题。

应用程序层面措施

捕获异常：在应用程序代码中，使用合适的异常处理机制捕获数据库操作可能抛出的异常。例如，在Python的 psycopg2 库中，使用 try - except 块捕获 psycopg2.Error 及其子类异常。

import psycopg2

try:
    # 数据库操作
    conn = psycopg2.connect(database="test", user="user", password="password", host="127.0.0.1", port="5432")
    cur = conn.cursor()
    cur.execute("INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')")
    conn.commit()
except psycopg2.Error as e:
    print(f"数据库操作错误: {e}")
    # 可以选择回滚事务（在某些情况下，PostgreSQL可能已经自动回滚，但再次回滚通常是安全的）
    if conn:
        conn.rollback()
finally:
    if cur:
        cur.close()
    if conn:
        conn.close()

重试机制：对于一些可恢复的错误，如短暂的网络故障，可以实现重试机制。但需要注意设置合理的重试次数和时间间隔，避免无限重试。例如，使用装饰器实现简单的重试逻辑。

import time
import psycopg2

def retry_on_db_error(func):
    def wrapper(*args, **kwargs):
        max_retries = 3
        retry_delay = 1
        for attempt in range(max_retries):
            try:
                return func(*args, **kwargs)
            except psycopg2.Error as e:
                if attempt < max_retries - 1:
                    print(f"操作失败，重试第 {attempt + 1} 次...错误: {e}")
                    time.sleep(retry_delay)
                else:
                    print(f"经过 {max_retries} 次重试后仍失败，错误: {e}")
    return wrapper

@retry_on_db_error
def perform_db_operation():
    conn = psycopg2.connect(database="test", user="user", password="password", host="127.0.0.1", port="5432")
    cur = conn.cursor()
    cur.execute("INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')")
    conn.commit()
    cur.close()
    conn.close()

日志记录：应用程序应详细记录数据库操作相关的日志，包括事务开始、结束以及遇到的错误信息。这有助于排查问题和分析系统运行状况。例如，使用Python的 logging 模块记录日志。

import logging

logging.basicConfig(level=logging.INFO)

try:
    # 数据库操作
    conn = psycopg2.connect(database="test", user="user", password="password", host="127.0.0.1", port="5432")
    cur = conn.cursor()
    cur.execute("INSERT INTO table_name (column1, column2) VALUES ('value1', 'value2')")
    conn.commit()
except psycopg2.Error as e:
    logging.error(f"数据库操作错误: {e}")
    if conn:
        conn.rollback()
finally:
    if cur:
        cur.close()
    if conn:
        conn.close()

业务补偿：根据业务逻辑，对于已经部分完成且无法回滚的操作，可能需要执行补偿操作。例如，在涉及财务转账的事务中，如果扣除一方账户金额成功但增加另一方账户金额失败，需要对扣除操作进行补偿（将金额加回原账户）。

星途面试题库

面试题：PostgreSQL事务结束时异常处理与数据一致性维护

知识考点

面试题答案

PostgreSQL 处理方式

应用程序层面措施