database

Documentation

Index

• type Database
  • func NewDatabase(host, port, database, user, password, schema string) (*Database, error)
  • func (db *Database) BeginTransaction() (pgx.Tx, error)
  • func (db *Database) Close()
  • func (db *Database) CommitTransaction(tx pgx.Tx) error
  • func (db *Database) CountUserByEmail(email string) (int, error)
  • func (db *Database) DeleteUser(tx pgx.Tx, id int64) error
  • func (db *Database) InsertUser(tx pgx.Tx, email, password, fullName string) (int64, error)
  • func (db *Database) RollbackTransaction(tx pgx.Tx) error
  • func (db *Database) SelectIdAndPasswordByEmail(email string) (int64, string, error)
  • func (db *Database) SelectUserById(id int64) (internal.User, error)
  • func (db *Database) SelectUsers(limit int, offset int) ([]internal.User, error)
  • func (db *Database) UpdateUserById(tx pgx.Tx, id int64, email, password, fullName string) error
  • func (db *Database) UpdateUserPasswordById(tx pgx.Tx, id int64, password string) error

Types

type Database

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

func NewDatabase

func NewDatabase(host, port, database, user, password, schema string) (*Database, error)

func (*Database) BeginTransaction

func (db *Database) BeginTransaction() (pgx.Tx, error)

func (*Database) Close

func (db *Database) Close()

func (*Database) CommitTransaction

func (db *Database) CommitTransaction(tx pgx.Tx) error

func (*Database) CountUserByEmail

func (db *Database) CountUserByEmail(email string) (int, error)

func (*Database) DeleteUser

func (db *Database) DeleteUser(tx pgx.Tx, id int64) error

func (*Database) InsertUser

func (db *Database) InsertUser(tx pgx.Tx, email, password, fullName string) (int64, error)

func (*Database) RollbackTransaction

func (db *Database) RollbackTransaction(tx pgx.Tx) error

func (*Database) SelectIdAndPasswordByEmail

func (db *Database) SelectIdAndPasswordByEmail(email string) (int64, string, error)

func (*Database) SelectUserById

func (db *Database) SelectUserById(id int64) (internal.User, error)

func (*Database) SelectUsers

func (db *Database) SelectUsers(limit int, offset int) ([]internal.User, error)

func (*Database) UpdateUserById

func (db *Database) UpdateUserById(tx pgx.Tx, id int64, email, password, fullName string) error

func (*Database) UpdateUserPasswordById

func (db *Database) UpdateUserPasswordById(tx pgx.Tx, id int64, password string) error