gorm

Documentation

Index

• func Delete(db *gorm.DB, tableName string, column string, value any) error
• func DeleteById(db *gorm.DB, tableName string, id uint64) error
• func Exists(db *gorm.DB, tableName, column string, value interface{}, withDeletedAt bool) (bool, error)
• func ExistsByColumn(db *gorm.DB, tableName, column string, value interface{}) (bool, error)
• func ExistsByFilterExprs(db *gorm.DB, tableName string, filters dbi.FilterExprs) (bool, error)
• func ExistsById(db *gorm.DB, tableName string, id uint64) (bool, error)
• func ExistsByIdWithDeletedAt(db *gorm.DB, tableName string, id uint64) (bool, error)
• func ExistsByQuerySQL(db *gorm.DB, qsql string, value ...any) (bool, error)
• func ExistsBySQL(db *gorm.DB, sql string, value ...any) (bool, error)
• func GetById[T any](db *gorm.DB, id any) (*T, error)
• func GetDBWithContext(db *gorm.DB, ctx context.Context) *gorm.DB
• func GetDBWithLogger(db *gorm.DB, log *log.Logger, conf *logger.Config) *gorm.DB
• func NewScope(field string, op dbi.Operation, args ...interface{}) func(*gorm.DB) *gorm.DB
• func NewTraceDB(db *gorm.DB, ctx context.Context, traceId string) *gorm.DB
• type BaseDao
  • func NewRepository[T any](db *gorm.DB) *BaseDao[T]
  • func (r *BaseDao[T]) Create(t *T) error
  • func (r *BaseDao[T]) Delete(id any) error
  • func (r *BaseDao[T]) Retrieve(id any) (*T, error)
  • func (r *BaseDao[T]) Update(t *T) error
• type ChainScope
  • func (c ChainScope) ById(id int) ChainScope
  • func (c ChainScope) ByIdNoCheck(id any) ChainScope
  • func (c ChainScope) ByName(name string) ChainScope
  • func (c ChainScope) ByNameNoCheck(name any) ChainScope
  • func (c ChainScope) Exec(db *gorm.DB) *gorm.DB
• type Config
  • func (c *Config) Init()
• type FilterExprs
  • func (f FilterExprs) Build(odb *gorm.DB) *gorm.DB
• type Mysql
• type Postgres
• type PrometheusConfig
• type Scope
• type Sqlite

Functions

func Delete

func Delete(db *gorm.DB, tableName string, column string, value any) error

func DeleteById

func DeleteById(db *gorm.DB, tableName string, id uint64) error

func Exists

func Exists(db *gorm.DB, tableName, column string, value interface{}, withDeletedAt bool) (bool, error)

func ExistsByColumn

func ExistsByColumn(db *gorm.DB, tableName, column string, value interface{}) (bool, error)

func ExistsByFilterExprs

func ExistsByFilterExprs(db *gorm.DB, tableName string, filters dbi.FilterExprs) (bool, error)

func ExistsById

func ExistsById(db *gorm.DB, tableName string, id uint64) (bool, error)

func ExistsByIdWithDeletedAt

func ExistsByIdWithDeletedAt(db *gorm.DB, tableName string, id uint64) (bool, error)

func ExistsByQuerySQL

func ExistsByQuerySQL(db *gorm.DB, qsql string, value ...any) (bool, error)

根据查询语句查询数据是否存在

func ExistsBySQL

func ExistsBySQL(db *gorm.DB, sql string, value ...any) (bool, error)

func GetById

func GetById[T any](db *gorm.DB, id any) (*T, error)

func GetDBWithContext

func GetDBWithContext(db *gorm.DB, ctx context.Context) *gorm.DB

func GetDBWithLogger

func GetDBWithLogger(db *gorm.DB, log *log.Logger, conf *logger.Config) *gorm.DB

func NewScope

func NewScope(field string, op dbi.Operation, args ...interface{}) func(*gorm.DB) *gorm.DB

func NewTraceDB

func NewTraceDB(db *gorm.DB, ctx context.Context, traceId string) *gorm.DB

Types

type BaseDao

type BaseDao[T any] struct {
	*gorm.DB
}

func NewRepository

func NewRepository[T any](db *gorm.DB) *BaseDao[T]

func (*BaseDao[T]) Create

func (r *BaseDao[T]) Create(t *T) error

func (*BaseDao[T]) Delete

func (r *BaseDao[T]) Delete(id any) error

func (*BaseDao[T]) Retrieve

func (r *BaseDao[T]) Retrieve(id any) (*T, error)

func (*BaseDao[T]) Update

func (r *BaseDao[T]) Update(t *T) error

type ChainScope

type ChainScope []func(db *gorm.DB) *gorm.DB

func (ChainScope) ById

func (c ChainScope) ById(id int) ChainScope

db.Scope(ById(1),ByName("a")).First(v)

func (ChainScope) ByIdNoCheck

func (c ChainScope) ByIdNoCheck(id any) ChainScope

func (ChainScope) ByName

func (c ChainScope) ByName(name string) ChainScope

func (ChainScope) ByNameNoCheck

func (c ChainScope) ByNameNoCheck(name any) ChainScope

func (ChainScope) Exec

func (c ChainScope) Exec(db *gorm.DB) *gorm.DB

type Config

type Config struct {
	Type, Charset, Database, TimeZone string
	Host                              string `flag:"name:db_host;usage:数据库host"`
	Port                              int32
	User, Password                    string
	Postgres                          Postgres
	Mysql                             Mysql
	Sqlite                            Sqlite
	MaxIdleConns, MaxOpenConns        int
	ConnMaxLifetime, ConnMaxIdleTime  time.Duration

	Gorm gorm.Config

	EnableStdLogger bool
	Logger          logger.Config

	NamingStrategy schema.NamingStrategy

	EnablePrometheus  bool
	Prometheus        prometheus.Config
	PrometheusConfigs []PrometheusConfig
}

func (*Config) Init

func (c *Config) Init()

type FilterExprs

type FilterExprs dbi.FilterExprs

func (FilterExprs) Build

func (f FilterExprs) Build(odb *gorm.DB) *gorm.DB

type Mysql

type Mysql struct {
	ParseTime string
	Loc       string
}

type Postgres

type Postgres struct {
	Schema  string
	SSLMode string
}

type PrometheusConfig

type PrometheusConfig struct {
	Prefix        string
	Interval      uint32
	VariableNames []string
}

type Scope

type Scope func(*gorm.DB) *gorm.DB

type Sqlite

type Sqlite struct {
	DSN string
}