sqladapter

package

v1.0.0 Latest Latest Go to latest Published: Jul 29, 2026 License: MIT Imports: 12 Imported by: 0

Details

Package sqladapter implements the shared database/sql adapter used by the PostgreSQL and SQLite dialect packages.

This section is empty.

This section is empty.

This section is empty.

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

Adapter is a schema-aware database/sql adapter. Call Migrate explicitly before serving requests.

func New(db *sql.DB, dialect Dialect) (*Adapter, error)

func (adapter *Adapter) Capabilities() betterauth.AdapterCapabilities

func (adapter *Adapter) ConsumeOne(ctx context.Context, query betterauth.DeleteQuery) (betterauth.Record, error)

func (adapter *Adapter) Count(ctx context.Context, query betterauth.CountQuery) (int64, error)

func (adapter *Adapter) Create(ctx context.Context, query betterauth.CreateQuery) (betterauth.Record, error)

func (adapter *Adapter) Delete(ctx context.Context, query betterauth.DeleteQuery) error

func (adapter *Adapter) DeleteMany(ctx context.Context, query betterauth.DeleteQuery) (int64, error)

func (adapter *Adapter) FindMany(ctx context.Context, query betterauth.FindManyQuery) ([]betterauth.Record, error)

func (adapter *Adapter) FindOne(ctx context.Context, query betterauth.FindOneQuery) (betterauth.Record, error)

func (adapter *Adapter) ID() string

func (adapter *Adapter) IncrementOne(ctx context.Context, query betterauth.IncrementQuery) (betterauth.Record, error)

func (adapter *Adapter) Migrate(ctx context.Context, schema betterauth.Schema) error

Migrate creates missing tables and indexes for the supplied merged schema. It is additive and never drops or rewrites an existing column.

func (adapter *Adapter) Transaction(ctx context.Context, callback func(betterauth.DatabaseAdapter) error) error

func (adapter *Adapter) Update(ctx context.Context, query betterauth.UpdateQuery) (betterauth.Record, error)

func (adapter *Adapter) UpdateMany(ctx context.Context, query betterauth.UpdateQuery) (int64, error)

func (adapter *Adapter) WithSchema(schema betterauth.Schema) (betterauth.DatabaseAdapter, error)

type Dialect string

const (
	PostgreSQL Dialect = "postgresql"
	SQLite     Dialect = "sqlite"
)