На каком уровне работал с базами данных

Мой опыт работы с базами данных

За 10+ лет работы с Go я взаимодействовал с базами данных на различных уровнях — от низкоуровневого SQL до высокоуровневых ORM и распределённых систем. Мой подход всегда ситуативен: я выбираю инструменты и уровень абстракции в зависимости от требований проекта, масштаба и производительности.

1. Низкоуровневая работа с SQL через database/sql

Я часто работаю напрямую с пакетом database/sql, особенно в высоконагруженных проектах, где важны контроль и оптимизация.

import (
    "database/sql"
    _ "github.com/lib/pq"
)

func GetUser(db *sql.DB, id int) (*User, error) {
    var u User
    // Явное управление запросами и параметрами
    err := db.QueryRow("SELECT id, name, email FROM users WHERE id = $1", id).
        Scan(&u.ID, &u.Name, &u.Email)
    if err != nil {
        return nil, err
    }
    return &u, nil
}

Преимущества такого подхода:

• Полный контроль над SQL-запросами и их оптимизацией
• Минимальные накладные расходы (нет overhead от ORM)
• Прямая работа с подготовленными запросами (prepared statements)
• Возможность тонкой настройки пула соединений

2. Использование SQL-билдеров

Для сложных динамических запросов применяю SQL-билдеры вроде squirrel или goqu:

import sq "github.com/Masterminds/squirrel"

func BuildUserQuery(filters map[string]interface{}) (string, []interface{}, error) {
    query := sq.Select("*").From("users").Where(sq.Eq{"active": true})
    
    // Динамическое построение запроса
    if name, ok := filters["name"]; ok {
        query = query.Where(sq.Like{"name": "%" + name.(string) + "%"})
    }
    
    return query.ToSql()
}

3. Работа с ORM и query-билдерами

Для проектов с сложной бизнес-логикой использую GORM или entgo:

// Пример с GORM
type Product struct {
    gorm.Model
    Code  string
    Price uint
}

func GetExpensiveProducts(db *gorm.DB, minPrice uint) ([]Product, error) {
    var products []Product
    // GORM предоставляет цепочные методы для построения запросов
    result := db.Where("price > ?", minPrice).
               Order("price desc").
               Limit(100).
               Find(&products)
    return products, result.Error
}

Когда выбираю ORM:

• При сложных отношениях между сущностями (one-to-many, many-to-many)
• Для быстрого прототипирования и MVP
• Когда команда предпочитает работать с объектами, а не с SQL
• Для миграций схемы БД

4. Работа с NoSQL базами данных

Имею опыт работы с различными NoSQL решениями:

• MongoDB через официальный драйвер для агрегаций и документной модели
• Redis для кэширования, очередей и сессий
• Elasticsearch для полнотекстового поиска и логов
• Cassandra/ScyllaDB для высоконагруженных записей

// Пример работы с Redis
func CacheUserSession(rdb *redis.Client, userID string, sessionData []byte) error {
    ctx := context.Background()
    // Установка TTL для автоматического удаления
    return rdb.Set(ctx, "session:"+userID, sessionData, 24*time.Hour).Err()
}

5. Работа с распределёнными базами данных

В микросервисных архитектурах работал с:

• Шардированием баз данных (горизонтальное разделение)
• Репликацией (master-slave, master-master)
• Транзакциями в распределённых системах (Saga-паттерн)
• Event sourcing и CQRS с использованием Kafka и специальных БД

6. Оптимизация и мониторинг

На глубоком уровне занимаюсь:

• Профилированием запросов с использованием EXPLAIN ANALYZE
• Индексацией стратегий и покрывающих индексов
• Настройкой пулов соединений и мониторингом deadlocks
• Реализацией реторики запросов и кэширования
• Использованием коннекторов и миграций схемы

// Пример использования контекста для таймаутов
func GetUserWithTimeout(db *sql.DB, id int) (*User, error) {
    ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
    defer cancel()
    
    var u User
    // Контекст позволяет контролировать время выполнения запроса
    err := db.QueryRowContext(ctx, "SELECT * FROM users WHERE id = $1", id).
        Scan(&u.ID, &u.Name, &u.Email)
    
    if errors.Is(err, context.DeadlineExceeded) {
        // Обработка таймаута
        log.Println("Query timeout exceeded")
    }
    
    return &u, err
}

7. Принципы работы с БД

В своей практике придерживаюсь следующих принципов:

• Использую миграции для управления схемой БД (go-migrate, tern)
• Всегда параметризую запросы для защиты от SQL-инъекций
• Контролирую N+1 проблемы в запросах
• Разделяю read/write нагрузки через репликацию
• Тестирую запросы на реалистичных объемах данных
• Мониторю медленные запросы через логирование и Prometheus

В зависимости от проекта, я выбираю подходящий уровень абстракции: низкоуровневый SQL для высоконагруженных сервисов, ORM для продуктов со сложной бизнес-логикой, или гибридный подход, где критичные участки оптимизированы через чистый SQL, а остальная часть использует ORM для продуктивности разработки.