database

Documentation

Index

• func InitDb(cfg config.DataBaseConfig) (*sql.DB, error)
• type Database
  • func (c *Database) GetUserByEmail(ctx context.Context, request *dbtypes.GetUserByEmailRequest) (*dbtypes.GetUserResponse, error)
  • func (c *Database) GetUserById(ctx context.Context, request *dbtypes.GetUserInfoByIdRequest) (*dbtypes.GetUserInfoByIdResponse, error)
  • func (c *Database) Register(ctx context.Context, request *dbtypes.RegisterRequest) (*dbtypes.RegisterResponse, error)
• type Driver
• type Repository
  • func New(db *sql.DB) Repository

Functions

func InitDb

func InitDb(cfg config.DataBaseConfig) (*sql.DB, error)

Types

type Database

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

func (*Database) GetUserByEmail

func (c *Database) GetUserByEmail(
	ctx context.Context,
	request *dbtypes.GetUserByEmailRequest,
) (*dbtypes.GetUserResponse, error)

func (*Database) GetUserById

func (c *Database) GetUserById(
	ctx context.Context,
	request *dbtypes.GetUserInfoByIdRequest,
) (*dbtypes.GetUserInfoByIdResponse, error)

func (*Database) Register

func (c *Database) Register(
	ctx context.Context,
	request *dbtypes.RegisterRequest,
) (*dbtypes.RegisterResponse, error)

type Driver

type Driver interface {
	// QueryContext executes a query that returns rows, typically a SELECT.
	// The args are for any placeholder parameters in the query.
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

	// QueryRowContext executes a query that is expected to return at most one row.
	// QueryRowContext always returns a non-nil value. Errors are deferred until
	// [Row]'s Scan method is called.
	// If the query selects no rows, the [*Row.Scan] will return [ErrNoRows].
	// Otherwise, [*Row.Scan] scans the first selected row and discards
	// the rest.
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

	// ExecContext executes a query without returning any rows.
	// The args are for any placeholder parameters in the query.
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type Repository

type Repository interface {
	Register(ctx context.Context, request *dbtypes.RegisterRequest) (*dbtypes.RegisterResponse, error)

	GetUserByEmail(ctx context.Context, request *dbtypes.GetUserByEmailRequest) (*dbtypes.GetUserResponse, error)
	GetUserById(ctx context.Context, request *dbtypes.GetUserInfoByIdRequest) (*dbtypes.GetUserInfoByIdResponse, error)
}

func New

func New(db *sql.DB) Repository