database

package
v0.0.0-...-4b982e4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 8, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateDeviceInfoParams

type CreateDeviceInfoParams struct {
	ID             string
	UserID         string
	DeviceType     string
	Browser        string
	BrowserVersion string
	Os             string
	OsVersion      string
}

type CreateRefreshTokenParams

type CreateRefreshTokenParams struct {
	ID           string
	TokenHash    string
	ExpiresAt    sql.NullTime
	UserID       string
	DeviceInfoID string
}

type CreateTransactionParams

type CreateTransactionParams struct {
	ID                 string
	UserID             string
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
}

type CreateUserParams

type CreateUserParams struct {
	ID             string
	Email          string
	HashedPassword string
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DeleteTransactionByIDParams

type DeleteTransactionByIDParams struct {
	ID     string
	UserID string
}

type DeviceQuerier

type DeviceQuerier interface {
	GetDeviceInfoByUser(ctx context.Context, arg GetDeviceInfoByUserParams) (string, error)
	CreateDeviceInfo(ctx context.Context, arg CreateDeviceInfoParams) (string, error)
}

func NewRealDevicequerier

func NewRealDevicequerier(q SqlTransactionalQuerier) DeviceQuerier

type GetDeviceInfoByUserParams

type GetDeviceInfoByUserParams struct {
	UserID         string
	DeviceType     string
	Browser        string
	BrowserVersion string
	Os             string
	OsVersion      string
}

type GetRefreshByUserAndDeviceParams

type GetRefreshByUserAndDeviceParams struct {
	UserID       string
	DeviceInfoID string
}

type GetUserByEmailRow

type GetUserByEmailRow struct {
	ID             string
	HashedPassword string
}

type GetUserTransactionByIDParams

type GetUserTransactionByIDParams struct {
	UserID string
	ID     string
}

type GetUserTransactionByIDRow

type GetUserTransactionByIDRow struct {
	ID                 string
	UserID             string
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
}

type GetUserTransactionsFirstPageParams

type GetUserTransactionsFirstPageParams struct {
	UserID string
	Limit  int64
}

type GetUserTransactionsFirstPageRow

type GetUserTransactionsFirstPageRow struct {
	ID                 string
	UserID             string
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
}

type GetUserTransactionsPaginatedParams

type GetUserTransactionsPaginatedParams struct {
	UserID          string
	TransactionDate string
	ID              string
	Limit           int64
}

type GetUserTransactionsPaginatedRow

type GetUserTransactionsPaginatedRow struct {
	ID                 string
	UserID             string
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) BeginTx

func (q *Queries) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (*Queries) CreateDeviceInfo

func (q *Queries) CreateDeviceInfo(ctx context.Context, arg CreateDeviceInfoParams) (string, error)

func (*Queries) CreateRefreshToken

func (q *Queries) CreateRefreshToken(ctx context.Context, arg CreateRefreshTokenParams) error

func (*Queries) CreateTransaction

func (q *Queries) CreateTransaction(ctx context.Context, arg CreateTransactionParams) error

func (*Queries) CreateUser

func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) error

func (*Queries) DeleteTransactionByID

func (q *Queries) DeleteTransactionByID(ctx context.Context, arg DeleteTransactionByIDParams) (string, error)

func (*Queries) GetDetailedCategories

func (q *Queries) GetDetailedCategories(ctx context.Context) ([]models.DetailedCategory, error)

func (*Queries) GetDetailedCategoryID

func (q *Queries) GetDetailedCategoryID(ctx context.Context, name string) (int64, error)

func (*Queries) GetDeviceInfoByUser

func (q *Queries) GetDeviceInfoByUser(ctx context.Context, arg GetDeviceInfoByUserParams) (string, error)

func (*Queries) GetPrimaryCategories

func (q *Queries) GetPrimaryCategories(ctx context.Context) ([]models.PrimaryCategory, error)

func (*Queries) GetRefreshByUserAndDevice

func (q *Queries) GetRefreshByUserAndDevice(ctx context.Context, arg GetRefreshByUserAndDeviceParams) (models.RefreshToken, error)

func (*Queries) GetUserByEmail

func (q *Queries) GetUserByEmail(ctx context.Context, email string) (GetUserByEmailRow, error)

func (*Queries) GetUserTransactionByID

func (q *Queries) GetUserTransactionByID(ctx context.Context, arg GetUserTransactionByIDParams) (GetUserTransactionByIDRow, error)

func (*Queries) RevokeToken

func (q *Queries) RevokeToken(ctx context.Context, arg RevokeTokenParams) error

func (*Queries) UpdateTransactionByID

func (q *Queries) UpdateTransactionByID(ctx context.Context, arg UpdateTransactionByIDParams) (UpdateTransactionByIDRow, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

type RealDeviceQuerier

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

func (*RealDeviceQuerier) CreateDeviceInfo

func (rd *RealDeviceQuerier) CreateDeviceInfo(ctx context.Context, arg CreateDeviceInfoParams) (string, error)

func (*RealDeviceQuerier) GetDeviceInfoByUser

func (rd *RealDeviceQuerier) GetDeviceInfoByUser(ctx context.Context, arg GetDeviceInfoByUserParams) (string, error)

type RealSqlTxQuerier

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

func (*RealSqlTxQuerier) BeginTx

func (rst *RealSqlTxQuerier) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (*RealSqlTxQuerier) WithTx

type RealTokenQuerier

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

func (*RealTokenQuerier) CreateRefreshToken

func (rt *RealTokenQuerier) CreateRefreshToken(ctx context.Context, arg CreateRefreshTokenParams) error

func (*RealTokenQuerier) GetRefreshByUserAndDevice

func (rt *RealTokenQuerier) GetRefreshByUserAndDevice(ctx context.Context, arg GetRefreshByUserAndDeviceParams) (models.RefreshToken, error)

func (*RealTokenQuerier) RevokeToken

func (rt *RealTokenQuerier) RevokeToken(ctx context.Context, arg RevokeTokenParams) error

type RealTransactionQuerier

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

func (*RealTransactionQuerier) CreateTransaction

func (rt *RealTransactionQuerier) CreateTransaction(ctx context.Context, arg CreateTransactionParams) error

func (*RealTransactionQuerier) DeleteTransactionByID

func (rt *RealTransactionQuerier) DeleteTransactionByID(ctx context.Context, arg DeleteTransactionByIDParams) (string, error)

func (*RealTransactionQuerier) GetDetailedCategories

func (rt *RealTransactionQuerier) GetDetailedCategories(ctx context.Context) ([]models.DetailedCategory, error)

func (*RealTransactionQuerier) GetDetailedCategoryID

func (rt *RealTransactionQuerier) GetDetailedCategoryID(ctx context.Context, name string) (int64, error)

func (*RealTransactionQuerier) GetPrimaryCategories

func (rt *RealTransactionQuerier) GetPrimaryCategories(ctx context.Context) ([]models.PrimaryCategory, error)

func (*RealTransactionQuerier) GetUserTransactionByID

func (*RealTransactionQuerier) GetUserTransactionsFirstPage

func (*RealTransactionQuerier) GetUserTransactionsPaginated

func (*RealTransactionQuerier) UpdateTransactionByID

type RealTransactionalQuerier

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

RealTransactionalQuerier wraps a *Queries to implement SqlTransactionalQuerier.

func (*RealTransactionalQuerier) BeginTx

func (r *RealTransactionalQuerier) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

BeginTx delegates to the underlying *Queries.

func (*RealTransactionalQuerier) CreateDeviceInfo

func (*RealTransactionalQuerier) CreateRefreshToken

func (r *RealTransactionalQuerier) CreateRefreshToken(ctx context.Context, arg CreateRefreshTokenParams) error

TokenQuerier methods.

func (*RealTransactionalQuerier) CreateTransaction

func (r *RealTransactionalQuerier) CreateTransaction(ctx context.Context, arg CreateTransactionParams) error

TransactionQuerier methods.

func (*RealTransactionalQuerier) CreateUser

func (*RealTransactionalQuerier) DeleteTransactionByID

func (r *RealTransactionalQuerier) DeleteTransactionByID(ctx context.Context, arg DeleteTransactionByIDParams) (string, error)

func (*RealTransactionalQuerier) GetDetailedCategories

func (r *RealTransactionalQuerier) GetDetailedCategories(ctx context.Context) ([]models.DetailedCategory, error)

func (*RealTransactionalQuerier) GetDetailedCategoryID

func (r *RealTransactionalQuerier) GetDetailedCategoryID(ctx context.Context, name string) (int64, error)

func (*RealTransactionalQuerier) GetDeviceInfoByUser

func (r *RealTransactionalQuerier) GetDeviceInfoByUser(ctx context.Context, arg GetDeviceInfoByUserParams) (string, error)

DeviceQuerier methods.

func (*RealTransactionalQuerier) GetPrimaryCategories

func (r *RealTransactionalQuerier) GetPrimaryCategories(ctx context.Context) ([]models.PrimaryCategory, error)

func (*RealTransactionalQuerier) GetRefreshByUserAndDevice

func (*RealTransactionalQuerier) GetUserByEmail

func (r *RealTransactionalQuerier) GetUserByEmail(ctx context.Context, email string) (GetUserByEmailRow, error)

func (*RealTransactionalQuerier) GetUserTransactionByID

func (*RealTransactionalQuerier) GetUserTransactionsFirstPage

func (*RealTransactionalQuerier) GetUserTransactionsPaginated

func (*RealTransactionalQuerier) RevokeToken

func (*RealTransactionalQuerier) UpdateTransactionByID

func (*RealTransactionalQuerier) WithTx

WithTx calls the underlying WithTx method and wraps the result.

type RealUserQuerier

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

func (*RealUserQuerier) CreateUser

func (ru *RealUserQuerier) CreateUser(ctx context.Context, params CreateUserParams) error

func (*RealUserQuerier) GetUserByEmail

func (ru *RealUserQuerier) GetUserByEmail(ctx context.Context, email string) (GetUserByEmailRow, error)

type RevokeTokenParams

type RevokeTokenParams struct {
	RevokedAt    sql.NullTime
	UserID       string
	DeviceInfoID string
}

type SqlTransactionalQuerier

type SqlTransactionalQuerier interface {
	SqlTxQuerier
	DeviceQuerier
	TokenQuerier
	TransactionQuerier
	UserQuerier
}

func NewRealTransactionalQuerier

func NewRealTransactionalQuerier(q *Queries) SqlTransactionalQuerier

NewRealTransactionalQuerier returns an adapter wrapping the given *Queries.

type SqlTxQuerier

type SqlTxQuerier interface {
	WithTx(tx *sql.Tx) SqlTransactionalQuerier
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

func NewRealSqlTxQuerier

func NewRealSqlTxQuerier(q SqlTransactionalQuerier) SqlTxQuerier

type TokenQuerier

type TokenQuerier interface {
	CreateRefreshToken(ctx context.Context, arg CreateRefreshTokenParams) error
	RevokeToken(ctx context.Context, arg RevokeTokenParams) error
	GetRefreshByUserAndDevice(ctx context.Context, arg GetRefreshByUserAndDeviceParams) (models.RefreshToken, error)
}

func NewRealTokenQuerier

func NewRealTokenQuerier(q SqlTransactionalQuerier) TokenQuerier

type TransactionQuerier

type TransactionQuerier interface {
	CreateTransaction(ctx context.Context, arg CreateTransactionParams) error
	UpdateTransactionByID(ctx context.Context, arg UpdateTransactionByIDParams) (UpdateTransactionByIDRow, error)
	DeleteTransactionByID(ctx context.Context, arg DeleteTransactionByIDParams) (string, error)
	GetUserTransactionsFirstPage(ctx context.Context, arg GetUserTransactionsFirstPageParams) ([]GetUserTransactionsFirstPageRow, error)
	GetUserTransactionsPaginated(ctx context.Context, arg GetUserTransactionsPaginatedParams) ([]GetUserTransactionsPaginatedRow, error)
	GetUserTransactionByID(ctx context.Context, arg GetUserTransactionByIDParams) (GetUserTransactionByIDRow, error)
	GetPrimaryCategories(ctx context.Context) ([]models.PrimaryCategory, error)
	GetDetailedCategories(ctx context.Context) ([]models.DetailedCategory, error)
	GetDetailedCategoryID(ctx context.Context, name string) (int64, error)
}

type UpdateTransactionByIDParams

type UpdateTransactionByIDParams struct {
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
	UpdatedAt          sql.NullTime
	ID                 string
}

type UpdateTransactionByIDRow

type UpdateTransactionByIDRow struct {
	ID                 string
	TransactionDate    string
	Merchant           string
	AmountCents        int64
	DetailedCategoryID int64
}

type UserQuerier

type UserQuerier interface {
	CreateUser(ctx context.Context, params CreateUserParams) error
	GetUserByEmail(ctx context.Context, email string) (GetUserByEmailRow, error)
}

func NewRealUserQuerier

func NewRealUserQuerier(q SqlTransactionalQuerier) UserQuerier

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL