Databases

go get github.com/jackc/pgx/v5/pgxpool

package main

import (
    "context"
    "fmt"
    "os"
    "github.com/jackc/pgx/v5/pgxpool"
)

func main() {
    // Connection string automatically injected by Suga
    pool, err := pgxpool.New(context.Background(), os.Getenv("DATABASE_URL"))
    if err != nil {
        panic(err)
    }
    defer pool.Close()

    // Query with parameters
    rows, err := pool.Query(context.Background(),
        "SELECT * FROM users WHERE active = $1", true)
    if err != nil {
        panic(err)
    }
    defer rows.Close()

    // Insert data
    _, err = pool.Exec(context.Background(),
        "INSERT INTO users (name, email) VALUES ($1, $2)",
        "Alice", "alice@example.com")

    // Update data
    _, err = pool.Exec(context.Background(),
        "UPDATE users SET name = $1 WHERE id = $2",
        "Bob", 1)

    // Delete data
    _, err = pool.Exec(context.Background(),
        "DELETE FROM users WHERE id = $1", 1)
}

go get gorm.io/gorm
go get gorm.io/driver/postgres

package main

import (
    "os"
    "gorm.io/driver/postgres"
    "gorm.io/gorm"
)

type User struct {
    ID     uint
    Name   string
    Email  string `gorm:"unique"`
    Active bool   `gorm:"default:true"`
}

func main() {
    // Connection string automatically injected by Suga
    db, err := gorm.Open(postgres.Open(os.Getenv("DATABASE_URL")), &gorm.Config{})
    if err != nil {
        panic(err)
    }

    // Query
    var users []User
    db.Where("active = ?", true).Find(&users)

    // Insert
    db.Create(&User{
        Name:  "Alice",
        Email: "alice@example.com",
    })

    // Update
    db.Model(&User{}).Where("id = ?", 1).Update("name", "Bob")

    // Delete
    db.Delete(&User{}, 1)
}

go get github.com/jmoiron/sqlx
go get github.com/lib/pq

package main

import (
    "os"
    "github.com/jmoiron/sqlx"
    _ "github.com/lib/pq"
)

type User struct {
    ID     int    `db:"id"`
    Name   string `db:"name"`
    Email  string `db:"email"`
    Active bool   `db:"active"`
}

func main() {
    // Connection string automatically injected by Suga
    db, err := sqlx.Connect("postgres", os.Getenv("DATABASE_URL"))
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // Query
    users := []User{}
    db.Select(&users, "SELECT * FROM users WHERE active = $1", true)

    // Insert
    db.Exec("INSERT INTO users (name, email) VALUES ($1, $2)",
        "Alice", "alice@example.com")

    // Update
    db.Exec("UPDATE users SET name = $1 WHERE id = $2", "Bob", 1)
}

import (
    "context"
    "os"
    "github.com/jackc/pgx/v5/pgxpool"
)

// Connect to different databases
usersPool, _ := pgxpool.New(context.Background(), os.Getenv("USERS_DATABASE_URL"))
productsPool, _ := pgxpool.New(context.Background(), os.Getenv("PRODUCTS_DATABASE_URL"))

// Query different databases
usersRows, _ := usersPool.Query(context.Background(), "SELECT * FROM users")
productsRows, _ := productsPool.Query(context.Background(), "SELECT * FROM products")

import (
    "context"
    "os"
    "github.com/jackc/pgx/v5/pgxpool"
)

// Create pool with custom configuration
config, _ := pgxpool.ParseConfig(os.Getenv("DATABASE_URL"))
config.MaxConns = 20
config.MinConns = 5

pool, _ := pgxpool.NewWithConfig(context.Background(), config)
defer pool.Close()

// Pool automatically manages connections
rows, _ := pool.Query(context.Background(), "SELECT * FROM users")