Как в Python можно работать с триггерами базы данных и что они делают?

# Как в Python работать с триггерами БД и что они делают?

Отличный вопрос о пересечении Python и БД. Разберу комплексно.

Что такое триггеры БД

Триггер — это хранимая процедура БД, которая автоматически выполняется при определённом событии:

• INSERT — при добавлении записи
• UPDATE — при изменении записи
• DELETE — при удалении записи

Выполняются внутри БД, на стороне сервера, не в Python коде.

Что делают триггеры

1. Валидация данных

CREATE TRIGGER check_price_trigger
BEFORE INSERT ON products
FOR EACH ROW
BEGIN
  IF NEW.price < 0 THEN
    SIGNAL SQLSTATE "45000" SET MESSAGE_TEXT = "Price cannot be negative";
  END IF;
END;

2. Аудит и логирование

CREATE TRIGGER log_changes
AFTER UPDATE ON users
FOR EACH ROW
BEGIN
  INSERT INTO audit_log (user_id, old_data, new_data, changed_at)
  VALUES (OLD.id, OLD.email, NEW.email, NOW());
END;

3. Каскадные обновления

CREATE TRIGGER update_total
AFTER INSERT ON order_items
FOR EACH ROW
BEGIN
  UPDATE orders SET total = total + NEW.price 
  WHERE id = NEW.order_id;
END;

Как Python работает с триггерами

Способ 1: Через SQL при миграции

Триггеры создаются SQL-миграциями (Alembic, Goose), не из Python кода:

# migration.py
from alembic import op
import sqlalchemy as sa

def upgrade():
    op.execute("""
        CREATE TRIGGER update_modified_at
        BEFORE UPDATE ON articles
        FOR EACH ROW
        SET NEW.modified_at = NOW();
    """)

def downgrade():
    op.execute("DROP TRIGGER IF EXISTS update_modified_at;")

Способ 2: Проверка срабатывания триггера из Python

Trigger срабатывает, когда Python отправляет SQL команду:

from sqlalchemy import create_engine, text

engine = create_engine("postgresql://...")

# Python отправляет INSERT, триггер срабатывает на стороне БД
with engine.connect() as conn:
    conn.execute(text("""
        INSERT INTO products (name, price)
        VALUES (:name, :price)
    """), {"name": "Laptop", "price": 999})
    # Триггер check_price_trigger выполнится автоматически
    conn.commit()

Способ 3: SQLAlchemy события вместо триггеров

В Python коде часто используют SQLAlchemy Events вместо БД-триггеров:

from sqlalchemy import event
from sqlalchemy.orm import Session
from datetime import datetime

class Article(Base):
    __tablename__ = "articles"
    id = Column(Integer, primary_key=True)
    content = Column(String)
    created_at = Column(DateTime, default=datetime.utcnow)
    updated_at = Column(DateTime, onupdate=datetime.utcnow)

# Event вместо триггера: отслеживаем изменения в Python
@event.listens_for(Article, "before_update")
def before_update(mapper, connection, target):
    target.updated_at = datetime.utcnow()
    print(f"Updating article {target.id}")

Python vs БД триггеры: когда что использовать

Когда триггеры опасны

• Сложность отладки — код триггера хранится в БД, не в Git
• Performance — много триггеров замораживают БД
• Зависимости скрыты — непонятно, что триггер делает при изменении таблицы
• Race conditions — триггеры могут конфликтовать

Лучшая практика

# ✅ Определяй триггеры в миграциях
# ✅ Логируй действия в Python слое (SQLAlchemy Events)
# ✅ Валидируй данные в Pydantic до БД
# ✅ Используй триггеры только для защиты целостности данных
# ❌ Не пиши сложную логику в SQL триггерах