gorm

package
v1.12.1 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2023 License: MIT Imports: 36 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DialectorSet = wire.NewSet(NewDialectorImpl, wire.Bind(new(Dialector), new(*DialectorImpl)))
View Source 
var (
	ErrorMissingWhereClause = errors.New("WHERE conditions required")
)
View Source 
var GormSet = wire.NewSet(NewGormImpl, wire.Bind(new(Gorm), new(*GormImpl)))
View Source 
var QuerySet = wire.NewSet(NewQueryImpl, wire.Bind(new(ormcontract.Query), new(*QueryImpl)))

Functions

func FileWithLineNum 

func FileWithLineNum() string

FileWithLineNum return the file name and line number of the current file

func New 

func New(connection string) (*gormio.DB, error)

DEPRECATED: Not recommended, if you must, use NewGormImpl.

func NewLogger 

func NewLogger(writer logger.Writer, config logger.Config) logger.Interface

Types

type Dialector added in v1.12.0 

type Dialector interface {
	Make(configs []databasecontract.Config) ([]gorm.Dialector, error)
}

type DialectorImpl added in v1.12.0 

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

func NewDialectorImpl added in v1.12.0 

func NewDialectorImpl(config config.Config, connection string) *DialectorImpl

func (*DialectorImpl) Make added in v1.12.0 

func (d *DialectorImpl) Make(configs []databasecontract.Config) ([]gorm.Dialector, error)

type Event added in v1.11.0 

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

func NewEvent added in v1.11.0 

func NewEvent(query *QueryImpl, model, dest any) *Event

func (*Event) ColumnNamesWithDbColumnNames added in v1.11.0 

func (e *Event) ColumnNamesWithDbColumnNames() map[string]string

func (*Event) Context added in v1.11.0 

func (e *Event) Context() context.Context

func (*Event) DestOfMap added in v1.11.0 

func (e *Event) DestOfMap() map[string]any

func (*Event) GetAttribute added in v1.11.0 

func (e *Event) GetAttribute(key string) any

func (*Event) GetOriginal added in v1.11.0 

func (e *Event) GetOriginal(key string, def ...any) any

func (*Event) IsClean added in v1.11.0 

func (e *Event) IsClean(fields ...string) bool

func (*Event) IsDirty added in v1.11.0 

func (e *Event) IsDirty(columns ...string) bool

func (*Event) ModelOfMap added in v1.11.0 

func (e *Event) ModelOfMap() map[string]any

func (*Event) Query added in v1.11.0 

func (e *Event) Query() orm.Query

func (*Event) SetAttribute added in v1.11.0 

func (e *Event) SetAttribute(key string, value any)

type Gorm added in v1.12.0 

type Gorm interface {
	Make() (*gormio.DB, error)
}

type GormImpl added in v1.12.0 

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

func InitializeGorm added in v1.12.0 

func InitializeGorm(config2 config.Config, connection string) *GormImpl

func NewGormImpl added in v1.12.0 

func NewGormImpl(config config.Config, connection string, dbConfig db.Config, dialector Dialector) *GormImpl

func (*GormImpl) Make added in v1.12.0 

func (r *GormImpl) Make() (*gormio.DB, error)

type Logger 

type Logger struct {
	logger.Writer
	logger.Config
	// contains filtered or unexported fields
}

func (Logger) Error 

func (l Logger) Error(ctx context.Context, msg string, data ...any)

Error print error messages

func (Logger) Info 

func (l Logger) Info(ctx context.Context, msg string, data ...any)

Info print info

func (*Logger) LogMode 

func (l *Logger) LogMode(level logger.LogLevel) logger.Interface

LogMode log mode

func (Logger) Trace 

func (l Logger) Trace(ctx context.Context, begin time.Time, fc func() (string, int64), err error)

Trace print sql message

func (Logger) Warn 

func (l Logger) Warn(ctx context.Context, msg string, data ...any)

Warn print warn messages

type MysqlDocker 

type MysqlDocker struct {
	MockConfig *configmock.Config
	Port       int
	// contains filtered or unexported fields
}

func NewMysqlDocker added in v1.12.0 

func NewMysqlDocker() *MysqlDocker

func (*MysqlDocker) Init added in v1.12.0 

func (r *MysqlDocker) Init() (*dockertest.Pool, *dockertest.Resource, error)

func (*MysqlDocker) MockReadWrite added in v1.12.0 

func (r *MysqlDocker) MockReadWrite(readPort, writePort int)

func (*MysqlDocker) New added in v1.12.0 

func (r *MysqlDocker) New() (*dockertest.Pool, *dockertest.Resource, orm.Query, error)

func (*MysqlDocker) Query added in v1.12.0 

func (r *MysqlDocker) Query(createTable bool) (orm.Query, error)

func (*MysqlDocker) QueryWithPrefixAndSingular added in v1.12.0 

func (r *MysqlDocker) QueryWithPrefixAndSingular() (orm.Query, error)

type PostgresqlDocker 

type PostgresqlDocker struct {
	MockConfig *configmock.Config
	Port       int
	// contains filtered or unexported fields
}

func NewPostgresqlDocker added in v1.12.0 

func NewPostgresqlDocker() *PostgresqlDocker

func (*PostgresqlDocker) Init added in v1.12.0 

func (r *PostgresqlDocker) Init() (*dockertest.Pool, *dockertest.Resource, error)

func (*PostgresqlDocker) MockReadWrite added in v1.12.0 

func (r *PostgresqlDocker) MockReadWrite(readPort, writePort int)

func (*PostgresqlDocker) New added in v1.12.0 

func (r *PostgresqlDocker) New() (*dockertest.Pool, *dockertest.Resource, orm.Query, error)

func (*PostgresqlDocker) Query added in v1.12.0 

func (r *PostgresqlDocker) Query(createTable bool) (orm.Query, error)

func (*PostgresqlDocker) QueryWithPrefixAndSingular added in v1.12.0 

func (r *PostgresqlDocker) QueryWithPrefixAndSingular() (orm.Query, error)

type QueryImpl added in v1.12.0 

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

func InitializeQuery added in v1.12.0 

func InitializeQuery(ctx context.Context, config2 config.Config, connection string) (*QueryImpl, error)

func NewQueryImpl added in v1.12.0 

func NewQueryImpl(ctx context.Context, config config.Config, gorm Gorm) (*QueryImpl, error)

func NewQueryWithWithoutEvents added in v1.11.0 

func NewQueryWithWithoutEvents(instance *gormio.DB, withoutEvents bool) *QueryImpl

func (*QueryImpl) Association added in v1.12.0 

func (r *QueryImpl) Association(association string) ormcontract.Association

func (*QueryImpl) Begin added in v1.12.0 

func (r *QueryImpl) Begin() (ormcontract.Transaction, error)

func (*QueryImpl) Count added in v1.12.0 

func (r *QueryImpl) Count(count *int64) error

func (*QueryImpl) Create added in v1.12.0 

func (r *QueryImpl) Create(value any) error

func (*QueryImpl) Delete added in v1.12.0 

func (r *QueryImpl) Delete(dest any, conds ...any) (*ormcontract.Result, error)

func (*QueryImpl) Distinct added in v1.12.0 

func (r *QueryImpl) Distinct(args ...any) ormcontract.Query

func (*QueryImpl) Driver added in v1.12.0 

func (r *QueryImpl) Driver() ormcontract.Driver

func (*QueryImpl) Exec added in v1.12.0 

func (r *QueryImpl) Exec(sql string, values ...any) (*ormcontract.Result, error)

func (*QueryImpl) Find added in v1.12.0 

func (r *QueryImpl) Find(dest any, conds ...any) error

func (*QueryImpl) FindOrFail added in v1.12.0 

func (r *QueryImpl) FindOrFail(dest any, conds ...any) error

func (*QueryImpl) First added in v1.12.0 

func (r *QueryImpl) First(dest any) error

func (*QueryImpl) FirstOr added in v1.12.0 

func (r *QueryImpl) FirstOr(dest any, callback func() error) error

func (*QueryImpl) FirstOrCreate added in v1.12.0 

func (r *QueryImpl) FirstOrCreate(dest any, conds ...any) error

func (*QueryImpl) FirstOrFail added in v1.12.0 

func (r *QueryImpl) FirstOrFail(dest any) error

func (*QueryImpl) FirstOrNew added in v1.12.0 

func (r *QueryImpl) FirstOrNew(dest any, attributes any, values ...any) error

func (*QueryImpl) ForceDelete added in v1.12.0 

func (r *QueryImpl) ForceDelete(value any, conds ...any) (*ormcontract.Result, error)

func (*QueryImpl) Get added in v1.12.0 

func (r *QueryImpl) Get(dest any) error

func (*QueryImpl) Group added in v1.12.0 

func (r *QueryImpl) Group(name string) ormcontract.Query

func (*QueryImpl) Having added in v1.12.0 

func (r *QueryImpl) Having(query any, args ...any) ormcontract.Query

func (*QueryImpl) Instance added in v1.12.0 

func (r *QueryImpl) Instance() *gormio.DB

func (*QueryImpl) Join added in v1.12.0 

func (r *QueryImpl) Join(query string, args ...any) ormcontract.Query

func (*QueryImpl) Limit added in v1.12.0 

func (r *QueryImpl) Limit(limit int) ormcontract.Query

func (*QueryImpl) Load added in v1.12.0 

func (r *QueryImpl) Load(model any, relation string, args ...any) error

func (*QueryImpl) LoadMissing added in v1.12.0 

func (r *QueryImpl) LoadMissing(model any, relation string, args ...any) error

func (*QueryImpl) LockForUpdate added in v1.12.0 

func (r *QueryImpl) LockForUpdate() ormcontract.Query

func (*QueryImpl) Model added in v1.12.0 

func (r *QueryImpl) Model(value any) ormcontract.Query

func (*QueryImpl) Offset added in v1.12.0 

func (r *QueryImpl) Offset(offset int) ormcontract.Query

func (*QueryImpl) Omit added in v1.12.0 

func (r *QueryImpl) Omit(columns ...string) ormcontract.Query

func (*QueryImpl) OrWhere added in v1.12.0 

func (r *QueryImpl) OrWhere(query any, args ...any) ormcontract.Query

func (*QueryImpl) Order added in v1.12.0 

func (r *QueryImpl) Order(value any) ormcontract.Query

func (*QueryImpl) Paginate added in v1.12.0 

func (r *QueryImpl) Paginate(page, limit int, dest any, total *int64) error

func (*QueryImpl) Pluck added in v1.12.0 

func (r *QueryImpl) Pluck(column string, dest any) error

func (*QueryImpl) Raw added in v1.12.0 

func (r *QueryImpl) Raw(sql string, values ...any) ormcontract.Query

func (*QueryImpl) Save added in v1.12.0 

func (r *QueryImpl) Save(value any) error

func (*QueryImpl) SaveQuietly added in v1.12.0 

func (r *QueryImpl) SaveQuietly(value any) error

func (*QueryImpl) Scan added in v1.12.0 

func (r *QueryImpl) Scan(dest any) error

func (*QueryImpl) Scopes added in v1.12.0 

func (r *QueryImpl) Scopes(funcs ...func(ormcontract.Query) ormcontract.Query) ormcontract.Query

func (*QueryImpl) Select added in v1.12.0 

func (r *QueryImpl) Select(query any, args ...any) ormcontract.Query

func (*QueryImpl) SharedLock added in v1.12.0 

func (r *QueryImpl) SharedLock() ormcontract.Query

func (*QueryImpl) Table added in v1.12.0 

func (r *QueryImpl) Table(name string, args ...any) ormcontract.Query

func (*QueryImpl) Update added in v1.12.0 

func (r *QueryImpl) Update(column any, value ...any) (*ormcontract.Result, error)

func (*QueryImpl) UpdateOrCreate added in v1.12.0 

func (r *QueryImpl) UpdateOrCreate(dest any, attributes any, values any) error

func (*QueryImpl) Where added in v1.12.0 

func (r *QueryImpl) Where(query any, args ...any) ormcontract.Query

func (*QueryImpl) With added in v1.12.0 

func (r *QueryImpl) With(query string, args ...any) ormcontract.Query

func (*QueryImpl) WithTrashed added in v1.12.0 

func (r *QueryImpl) WithTrashed() ormcontract.Query

func (*QueryImpl) WithoutEvents added in v1.12.0 

func (r *QueryImpl) WithoutEvents() ormcontract.Query

type SqliteDocker 

type SqliteDocker struct {
	MockConfig *configmock.Config
	// contains filtered or unexported fields
}

func NewSqliteDocker added in v1.12.0 

func NewSqliteDocker(dbName string) *SqliteDocker

func (*SqliteDocker) Init added in v1.12.0 

func (r *SqliteDocker) Init() (*dockertest.Pool, *dockertest.Resource, error)

func (*SqliteDocker) MockReadWrite added in v1.12.0 

func (r *SqliteDocker) MockReadWrite()

func (*SqliteDocker) New added in v1.12.0 

func (r *SqliteDocker) New() (*dockertest.Pool, *dockertest.Resource, orm.Query, error)

func (*SqliteDocker) Query added in v1.12.0 

func (r *SqliteDocker) Query(createTable bool) (orm.Query, error)

func (*SqliteDocker) QueryWithPrefixAndSingular added in v1.12.0 

func (r *SqliteDocker) QueryWithPrefixAndSingular() (orm.Query, error)

type SqlserverDocker 

type SqlserverDocker struct {
	MockConfig *configmock.Config
	Port       int
	// contains filtered or unexported fields
}

func NewSqlserverDocker added in v1.12.0 

func NewSqlserverDocker() *SqlserverDocker

func (*SqlserverDocker) Init added in v1.12.0 

func (r *SqlserverDocker) Init() (*dockertest.Pool, *dockertest.Resource, error)

func (*SqlserverDocker) MockReadWrite added in v1.12.0 

func (r *SqlserverDocker) MockReadWrite(readPort, writePort int)

func (*SqlserverDocker) New added in v1.12.0 

func (r *SqlserverDocker) New() (*dockertest.Pool, *dockertest.Resource, orm.Query, error)

func (*SqlserverDocker) Query added in v1.12.0 

func (r *SqlserverDocker) Query(createTable bool) (orm.Query, error)

func (*SqlserverDocker) QueryWithPrefixAndSingular added in v1.12.0 

func (r *SqlserverDocker) QueryWithPrefixAndSingular() (orm.Query, error)

type Table added in v1.12.0 

type Table struct {
}

func (Table) Create added in v1.12.0 

func (r Table) Create(driver orm.Driver, db orm.Query) error

func (Table) CreateWithPrefixAndSingular added in v1.12.0 

func (r Table) CreateWithPrefixAndSingular(driver orm.Driver, db orm.Query) error

type Transaction 

type Transaction struct {
	orm.Query
	// contains filtered or unexported fields
}

func NewTransaction 

func NewTransaction(tx *gorm.DB) *Transaction

func (*Transaction) Commit 

func (r *Transaction) Commit() error

func (*Transaction) Rollback 

func (r *Transaction) Rollback() error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.