Описание типа Tx database/sql

package main

import (
	"context"
	"database/sql"
	"log"
	_ "github.com/go-sql-driver/mysql" // Импорт драйвера БД
)

func main() {
	// Инициализация подключения к БД
	db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/dbname")
	if err != nil {
		log.Fatal("Failed to connect to database:", err)
	}
	defer db.Close()

	// Проверка соединения
	ctx := context.Background()
	if err := db.PingContext(ctx); err != nil {
		log.Fatal("Database connection failed:", err)
	}

	// Начало транзакции
	tx, err := db.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelSerializable})
	if err != nil {
		log.Fatal("Failed to begin transaction:", err)
	}

	// Выполнение операций в транзакции
	id := 37
	_, execErr := tx.ExecContext(ctx, "UPDATE users SET status = ? WHERE id = ?", "paid", id)
	if execErr != nil {
		// Попытка отката при ошибке
		if rollbackErr := tx.Rollback(); rollbackErr != nil {
			log.Printf("UPDATE failed: %v, rollback also failed: %v", execErr, rollbackErr)
		} else {
			log.Printf("UPDATE failed, transaction rolled back: %v", execErr)
		}
		return
	}

	// Фиксация транзакции
	if err := tx.Commit(); err != nil {
		log.Fatal("Failed to commit transaction:", err)
	}

	log.Println("Transaction completed successfully")
}

package main

import (
	"context"
	"database/sql"
	"log"
	_ "github.com/go-sql-driver/mysql" // Импорт драйвера БД
)

func main() {
	// Инициализация подключения к БД
	db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/dbname?parseTime=true")
	if err != nil {
		log.Fatal("Failed to connect to database:", err)
	}
	defer db.Close()

	// Проверка соединения
	if err := db.Ping(); err != nil {
		log.Fatal("Database connection failed:", err)
	}

	projects := []struct {
		mascot  string
		release int
	}{
		{"tux", 1991},
		{"duke", 1996},
		{"gopher", 2009},
		{"moby dock", 2013},
	}

	// Начало транзакции
	ctx := context.Background()
	tx, err := db.BeginTx(ctx, nil)
	if err != nil {
		log.Fatal("Failed to begin transaction:", err)
	}
	// Откат в случае ошибки (игнорируется если был Commit)
	defer func() {
		if err := tx.Rollback(); err != nil && err != sql.ErrTxDone {
			log.Printf("Warning: rollback failed: %v", err)
		}
	}()

	// Подготовка выражения
	stmt, err := tx.PrepareContext(ctx, "INSERT INTO projects(id, mascot, release, category) VALUES(?, ?, ?, ?)")
	if err != nil {
		log.Fatal("Failed to prepare statement:", err)
	}
	defer stmt.Close()

	// Вставка данных
	for id, project := range projects {
		if _, err := stmt.ExecContext(ctx, id+1, project.mascot, project.release, "open source"); err != nil {
			log.Fatal("Failed to insert project:", err)
		}
	}

	// Фиксация транзакции
	if err := tx.Commit(); err != nil {
		log.Fatal("Failed to commit transaction:", err)
	}

	log.Println("Successfully inserted", len(projects), "projects")
}

package main

import (
	"context"
	"database/sql"
	"log"
	_ "github.com/lib/pq" // Импорт драйвера PostgreSQL
)

func main() {
	// Инициализация подключения к БД
	connStr := "user=postgres dbname=mydb sslmode=disable"
	db, err := sql.Open("postgres", connStr)
	if err != nil {
		log.Fatal("Failed to connect to database:", err)
	}
	defer db.Close()

	// Проверка соединения
	if err := db.Ping(); err != nil {
		log.Fatal("Database connection failed:", err)
	}

	// Создаем контекст с таймаутом
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()

	// Начало транзакции
	tx, err := db.BeginTx(ctx, &sql.TxOptions{Isolation: sql.LevelSerializable})
	if err != nil {
		log.Fatal("Failed to begin transaction:", err)
	}
	// Гарантированный откат при ошибках
	defer func() {
		if err := tx.Rollback(); err != nil && err != sql.ErrTxDone {
			log.Printf("Warning: rollback error: %v", err)
		}
	}()

	id := 53

	// 1. Обновление статуса водителя
	_, err = tx.ExecContext(ctx, "UPDATE drivers SET status = $1 WHERE id = $2", "assigned", id)
	if err != nil {
		log.Printf("Failed to update driver status: %v", err)
		return
	}

	// 2. Назначение водителя на заказы
	_, err = tx.ExecContext(ctx, "UPDATE pickups SET driver_id = $1 WHERE driver_id IS NULL", id)
	if err != nil {
		log.Printf("Failed to assign driver to pickups: %v", err)
		return
	}

	// Фиксация транзакции
	if err := tx.Commit(); err != nil {
		log.Fatal("Failed to commit transaction:", err)
	}

	log.Printf("Successfully assigned driver %d and updated pickup orders", id)
}