core

type AfterFinder ¶

type AfterFinder interface {
	AfterFind() error
}

AfterFinder é um hook executado após buscar um registro.

type BeforeCreater ¶

type BeforeCreater interface {
	BeforeCreate() error
}

BeforeCreater é um hook executado antes de criar um registro.

type DB ¶

type DB struct {
	// contains filtered or unexported fields
}

DB é a estrutura principal do ORM. Usa generics para type-safety.

func New(sqlDB *sql.DB, dialect Dialect) *DB

func NewWithLogger(sqlDB *sql.DB, dialect Dialect, logger Logger) *DB

func (db *DB) Create(ctx context.Context, model interface{}) error

func (db *DB) Delete(ctx context.Context, model interface{}) error

func (db *DB) Dialect() Dialect

func (db *DB) Executor() Executor

func (db *DB) Logger() Logger

func (db *DB) SetLogger(logger Logger)

func (db *DB) Update(ctx context.Context, model interface{}) error

func (db *DB) WithTx(ctx context.Context, fn func(*DB) error) error

type DefaultLogger ¶

type DefaultLogger struct {
	// contains filtered or unexported fields
}

DefaultLogger é a implementação padrão do Logger que escreve para stdout.

func NewDefaultLogger(verbose bool) *DefaultLogger

func (l *DefaultLogger) LogError(query string, args []interface{}, err error)

func (l *DefaultLogger) LogQuery(query string, args []interface{}, duration int64)

type Dialect ¶

type Dialect interface {
	// Placeholder retorna o placeholder para a posição n (ex: $1 para PostgreSQL, ? para MySQL)
	Placeholder(n int) string

	// QuoteIdentifier adiciona aspas ao identificador (ex: "users" para PostgreSQL)
	QuoteIdentifier(name string) string

	// GetType retorna o tipo SQL para um tipo Go
	GetType(goType string) string
}

Dialect define a interface para diferentes dialetos de banco de dados. Cada dialeto (PostgreSQL, MySQL, SQLite) implementa esta interface.

type Executor ¶

type Executor interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
}

Executor é a interface que pode executar queries. Implementada por *sql.DB e *sql.Tx.

type Logger ¶

type Logger interface {
	LogQuery(query string, args []interface{}, duration int64)
	LogError(query string, args []interface{}, err error)
}

Logger é a interface para logging de queries SQL. Implementações podem enviar logs para stdout, arquivo, ou serviços externos.

type Model ¶

type Model struct {
	ID        int64     `db:"id"`
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`
}

Model é a struct base que deve ser embutida em todos os modelos. Usa embedding para fornecer campos comuns.

type NoOpLogger ¶

type NoOpLogger struct{}

NoOpLogger é um logger que não faz nada. Útil para testes ou quando você não quer logging.

func (n *NoOpLogger) LogError(query string, args []interface{}, err error)

func (n *NoOpLogger) LogQuery(query string, args []interface{}, duration int64)

type Optional ¶

type Optional[T any] struct {
	// contains filtered or unexported fields
}

Optional representa um valor que pode ou não estar presente. Resolve o problema da manipulação de sql.Null* e ponteiros em JSON com uma API limpa e unificada.

Exemplo de uso:

type User struct {
    core.Model
    Name  string
    Email Optional[string] // pode ser NULL no banco
    Age   Optional[int]    // pode ser NULL no banco
}

// Criar um valor presente
email := Some("user@example.com")

// Criar um valor ausente
age := None[int]()

// Verificar se tem valor
if email.IsPresent() {
    fmt.Println(email.Get()) // user@example.com
}

// Obter com valor padrão
value := age.GetOrDefault(18) // retorna 18

func FlatMap[T any, U any](o Optional[T], fn func(T) Optional[U]) Optional[U]

func FromPtr[T any](ptr *T) Optional[T]

func Map[T any, U any](o Optional[T], fn func(T) U) Optional[U]

func None[T any]() Optional[T]

func Some[T any](value T) Optional[T]

func (o Optional[T]) Filter(predicate func(T) bool) Optional[T]

func (o Optional[T]) Get() T

func (o Optional[T]) GetOrDefault(defaultValue T) T

func (o Optional[T]) GetOrZero() T

func (o Optional[T]) IfPresent(fn func(T))

func (o Optional[T]) IfPresentOrElse(fnPresent func(T), fnAbsent func())

func (o Optional[T]) IsAbsent() bool

func (o Optional[T]) IsPresent() bool

func (o Optional[T]) MarshalJSON() ([]byte, error)

func (o Optional[T]) Ptr() *T

func (o *Optional[T]) Scan(value any) error

func (o *Optional[T]) UnmarshalJSON(data []byte) error

func (o Optional[T]) Value() (driver.Value, error)

type Scanner ¶

type Scanner interface {
	Scan(dest ...interface{}) error
}

Scanner é a interface para tipos que podem escanear valores do banco.

type TableNamer ¶

type TableNamer interface {
	TableName() string
}

TableNamer é uma interface que os modelos podem implementar para especificar o nome da tabela customizado.