gorm

Documentation

Index

• func Delete(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 int) (*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 NewTraceDB(db *gorm.DB, ctx context.Context, traceId string) *gorm.DB
• type ChainDao
  • func NewChainDao(ctx context.Context, db *gorm.DB) *ChainDao
  • func (c *ChainDao) ById(id int) *ChainDao
  • func (c *ChainDao) ByIdNoCheck(id int) *ChainDao
  • func (c *ChainDao) ByName(name string) *ChainDao
  • func (c *ChainDao) ByNameNoCheck(name string) *ChainDao
  • func (c *ChainDao) ResetDB()
• type Config
  • func (c *Config) Init()
• type FilterExprs
  • func (f FilterExprs) Build(odb *gorm.DB) *gorm.DB
• type Mysql
• type Postgres
• type PrometheusConfig
• type Repository
  • func NewRepository[T any](ctx context.Context, db *gorm.DB) *Repository[T]
  • func (r *Repository[T]) Create(t *T) error
  • func (r *Repository[T]) Delete(id int) error
  • func (r *Repository[T]) Retrieve(id int) (*T, error)
  • func (r *Repository[T]) Update(t *T) error
• type Repository2
  • func (db *Repository2[T]) GetById(id int) (*T, error)
• type Repository3
  • func (db *Repository3[T]) GetById(id int) (*T, error)
• type Sqlite

Functions

func Delete

func Delete(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 int) (*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 NewTraceDB

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

Types

type ChainDao

type ChainDao struct {
	DB, OriginDB *gorm.DB
}

func NewChainDao

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

func (*ChainDao) ById

func (c *ChainDao) ById(id int) *ChainDao

func (*ChainDao) ByIdNoCheck

func (c *ChainDao) ByIdNoCheck(id int) *ChainDao

func (*ChainDao) ByName

func (c *ChainDao) ByName(name string) *ChainDao

func (*ChainDao) ByNameNoCheck

func (c *ChainDao) ByNameNoCheck(name string) *ChainDao

func (*ChainDao) ResetDB

func (c *ChainDao) ResetDB()

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 Repository

type Repository[T any] ChainDao

func NewRepository

func NewRepository[T any](ctx context.Context, db *gorm.DB) *Repository[T]

func (*Repository[T]) Create

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

func (*Repository[T]) Delete

func (r *Repository[T]) Delete(id int) error

func (*Repository[T]) Retrieve

func (r *Repository[T]) Retrieve(id int) (*T, error)

func (*Repository[T]) Update

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

type Repository2

type Repository2[T any] gorm.DB

func (*Repository2[T]) GetById

func (db *Repository2[T]) GetById(id int) (*T, error)

type Repository3

type Repository3[T any] struct {
	gorm.DB
}

func (*Repository3[T]) GetById

func (db *Repository3[T]) GetById(id int) (*T, error)

type Sqlite

type Sqlite struct {
	Path string
}