sql is a Go library designed to simplify database interactions, migrations, and query management.
The ConditionBuilder provide functions for dynamically constructing SQL conditions.
import "github.com/go-universal/sql/query"
func main() {
cond := query.NewCondition(query.NumbericResolver)
cond.And("name = ?", "John").
AndClosure("age > ? AND age < ?", 9, 31).
OrIf(false, "age IS NULL").
OrClosureIf(true, "membership @in", "admin", "manager", "accountant")
// Result: "name = $1 AND (age > $2 AND age < $3) OR (membership IN ($4, $5, $6))"
}The query package provides tools for managing and generating SQL queries.
import (
"github.com/go-universal/sql/query"
"github.com/go-universal/fs"
)
func main() {
queriesFS := fs.NewDir("database/queries")
queryManager, _err_ := query.NewQueryManager(fs, query.WithRoot("database"))
usersList := queryManager.Get("queries/users/users_list")
usersTrash := queryManager.Get("queries/users/deleted users")
customers, exists := queryManager.Find("queries/customers/list")
customers, exists := queryManager.Find("queries/customers/deleted") // "", false
}Query files style:
-- users.sql
-- { query: users_list }
SELECT * FROM users WHERE `deleted_at` IS NULL AND `name` LIKE ?;
-- { query: deleted users }
SELECT * FROM users WHERE deleted_at IS NOT NULL;
-- customers.sql
-- { query: list }
SELECT * from customers;The postgres package provides tools for constructing and executing SQL commands specifically for PostgreSQL databases. Query placeholders must ?.
package main
import (
"context"
"github.com/go-universal/sql/postgres"
"github.com/jackc/pgx/v5/pgconn"
)
func main() {
ctx := context.Background()
config := postgres.NewConfig().
Host("localhost").
Port(5432).
User("postgres").
Password("password").
Database("test").
SSLMode("disable").
MinConns(2)
conn, err := postgres.New(
ctx, config.Build(),
func(c *pgxpool.Config) { c.MaxConns = 7 },
)
defer conn.Close(ctx)
cmd := postgres.NewCmd(conn)
result, err := cmd.Command("INSERT INTO users (name) VALUES (?)").Exec(ctx, "John Doe")
}The mysql package provides tools for constructing and executing SQL commands specifically for MySQL databases.
package main
import (
"context"
"github.com/go-universal/sql/mysql"
)
func main() {
conn, err := mysql.New(
context.Background(),
mysql.NewConfig().Database("test").Password("root").Build(),
)
if err != nil {
log.Fatal(err)
}
cmd := mysql.NewCmd(conn)
result, err := cmd.Command("INSERT INTO users (name) VALUES (?)").Exec(context.Background(), "John Doe")
}The migration package provides tools for managing database migrations by stage.
package main
import (
"log"
"github.com/go-universal/fs"
"github.com/go-universal/sql/migration"
"github.com/go-universal/sql/mysql"
)
func main() {
conn := CreateConnection()
fs := CreateFS()
mig, err := migration.NewMigration(
migration.NewMySQLSource(conn),
fs,
migration.WithRoot("migrations"),
)
err := mig.Up([]string{"table", "index", "seed"})
if err != nil {
log.Fatal(err)
}
}Migration files style:
-- 1741791024-create-users-table.sql
-- { up: table } table is sectin name
CREATE TABLE IF NOT EXISTS ...
-- { down: table }
-- { up: index }
...
-- { down: index }
...
-- { up: seed }
...
-- { down: seed }
...This library is licensed under the ISC License. See the LICENSE file for details.