import (
    "database/sql"
    _ "github.com/jackc/pgx/v5/stdlib" // driver postgres (ตัวอย่าง)
)
db, err := sql.Open("pgx", os.Getenv("DATABASE_URL"))
if err != nil { return err }
defer db.Close()
if err := db.PingContext(ctx); err != nil { return err }

db.SetMaxOpenConns(20)
db.SetMaxIdleConns(5)
db.SetConnMaxLifetime(5 * time.Minute)

ctx, cancel := context.WithTimeout(r.Context(), 2*time.Second)
defer cancel()
row := db.QueryRowContext(ctx, "SELECT name FROM users WHERE id=$1", id)

tx, _ := db.BeginTx(ctx, nil)
defer tx.Rollback() // พังก็ถอย
_, _ = tx.ExecContext(ctx, "UPDATE acc SET bal=bal-100 WHERE id=$1", from)
_, _ = tx.ExecContext(ctx, "UPDATE acc SET bal=bal+100 WHERE id=$1", to)
tx.Commit()

myapp/
  main.go (ต่อของ + graceful)
  api/user.go (รับ request/ตอบ JSON อย่างเดียว)
  store/user.go (คุย DB อย่างเดียว)

// store: คืนของจริง + error
func (s *Store) GetUser(ctx context.Context, id string) (User, error)
// api: แปล error เป็น status
user, err := s.GetUser(ctx, id)
if errors.Is(err, sql.ErrNoRows) { http.NotFound(w, r); return }

if id == "" { http.Error(w, "id จำเป็น", 400); return } // 400 = client ผิด
if errors.Is(err, sql.ErrNoRows) { http.NotFound(w, r); return } // 404
slog.Error("db fail", "err", err)
http.Error(w, "ระบบขัดข้อง", 500) // 500 อย่าโชว์ err ดิบให้ user

db, err := sql.Open("postgres", dsn)
if err != nil {
    return err
}
db.SetMaxOpenConns(25)                 // อย่าเปิดไม่จำกัด DB ตาย
db.SetMaxIdleConns(5)
db.SetConnMaxLifetime(5 * time.Minute) // หมุนเวียน connection เก่า
if err := db.PingContext(ctx); err != nil { // sql.Open ยังไม่ต่อจริง ต้อง Ping
    return err
}

func inTx(ctx context.Context, db *sql.DB, fn func(*sql.Tx) error) (err error) {
    tx, err := db.BeginTx(ctx, nil)
    if err != nil {
        return err
    }
    defer func() {
        if err != nil {
            tx.Rollback() // พัง = ยกเลิกหมด
        }
    }()
    if err = fn(tx); err != nil {
        return err
    }
    return tx.Commit() // ผ่านหมด = บันทึก
}

ctx, cancel := context.WithTimeout(r.Context(), 3*time.Second)
defer cancel()
var name string
err := db.QueryRowContext(ctx, "SELECT name FROM users WHERE id=$1", id).Scan(&name)