db

package
v0.0.0-...-24cf382 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DbLogType      = zlogger.NewLogType("DB_OP")
	DbTraceLogType = zlogger.NewLogType("DB_TRACE_OP")
)

MARK: Variables

Functions

func GetManager 

func GetManager() *manager

GetManager - This function returns singleton instance of Db Manager

func NewCreateMongoWrapperErr 

func NewCreateMongoWrapperErr(err error) error

NewCreateMongoWrapperErr - return a new instance of CreateMongoWrapperErr

func NewCreateSqlWrapperErr 

func NewCreateSqlWrapperErr(err error) error

NewCreateSqlWrapperErr - return a new instance of CreateSqlWrapperErr

func NewDbLogger 

func NewDbLogger(config LoggerConfig) logger.Interface

NewDbLogger - return instance of DbLogger which implement Interface

func NewMigrateErr 

func NewMigrateErr(err error) error

NewMigrateErr - return a new instance of MigrateErr

func NewNotExistServiceNameErr 

func NewNotExistServiceNameErr(serviceName string) error

NewNotExistServiceNameErr - return a new instance of NotExistServiceNameErr

func NewNotImplementedErr 

func NewNotImplementedErr() error

NewNotImplementedErr - return a new instance of NotImplementedErr

func NewNotSupportedDbTypeErr 

func NewNotSupportedDbTypeErr(dbType string) error

NewNotSupportedDbTypeErr - return a new instance of NotSupportedDbTypeErr

Types

type Config 

type Config struct {
	SkipDefaultTransaction                   bool `json:"skip_default_transaction"`
	DryRun                                   bool `json:"dry_run"`
	PrepareStmt                              bool `json:"prepare_stmt"`
	DisableAutomaticPing                     bool `json:"disable_automatic_ping"`
	DisableForeignKeyConstraintWhenMigrating bool `json:"disable_foreign_key_constraint_when_migrating"`
	IgnoreRelationshipsWhenMigrating         bool `json:"ignore_relationships_when_migrating"`
	DisableNestedTransaction                 bool `json:"disable_nested_transaction"`
}

type CreateMongoWrapperErr 

type CreateMongoWrapperErr struct {
	Err error
}

CreateMongoWrapperErr Error

func (*CreateMongoWrapperErr) Error 

func (err *CreateMongoWrapperErr) Error() string

Error method - satisfying error interface

type CreateSqlWrapperErr 

type CreateSqlWrapperErr struct {
	Err error
}

CreateSqlWrapperErr Error

func (*CreateSqlWrapperErr) Error 

func (err *CreateSqlWrapperErr) Error() string

Error method - satisfying error interface

type DbLogger 

type DbLogger struct {
	logger.Config
}

DbLogger - DB Logger struct

func (DbLogger) Error 

func (l DbLogger) Error(ctx context.Context, msg string, data ...interface{})

Error - print error messages

func (DbLogger) Info 

func (l DbLogger) Info(ctx context.Context, msg string, data ...interface{})

Info - print info

func (*DbLogger) LogMode 

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

LogMode - set log mode

func (DbLogger) Trace 

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

Trace - print sql message

func (DbLogger) Warn 

func (l DbLogger) Warn(ctx context.Context, msg string, data ...interface{})

Warn - print warn messages

type LoggerConfig 

type LoggerConfig struct {
	SlowThreshold             int64  `json:"slow_threshold"`
	IgnoreRecordNotFoundError bool   `json:"ignore_record_not_found_error"`
	ParameterizedQueries      bool   `json:"parameterized_queries"`
	LogLevel                  string `json:"log_level"`
}

type MigrateErr 

type MigrateErr struct {
	Err error
}

MigrateErr Error

func (*MigrateErr) Error 

func (err *MigrateErr) Error() string

Error method - satisfying error interface

type Mongo 

type Mongo struct {
	DatabaseName string             `json:"db"`
	Username     string             `json:"username"`
	Password     string             `json:"password"`
	Host         string             `json:"host"`
	Port         string             `json:"port"`
	Options      map[string]string  `json:"options"`
	LoggerConfig *MongoLoggerConfig `json:"logger"`
}

type MongoLogger 

type MongoLogger struct {
}

MongoLogger - Mongo DB Logger struct

func (*MongoLogger) Error 

func (m *MongoLogger) Error(err error, message string, keysAndValues ...interface{})

func (*MongoLogger) Info 

func (m *MongoLogger) Info(level int, message string, keysAndValues ...interface{})

type MongoLoggerConfig 

type MongoLoggerConfig struct {
	MaxDocumentLength   int    `json:"max_document_length"`
	ComponentCommand    string `json:"component_command"`
	ComponentConnection string `json:"component_connection"`
}

type MongoWrapper 

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

SqlWrapper struct

func NewMongoWrapper 

func NewMongoWrapper(name string) (*MongoWrapper, error)

NewMongoWrapper - create a new instance of MongoWrapper and returns it

func (*MongoWrapper) GetDb 

func (m *MongoWrapper) GetDb() (*mongo.Client, error)

GetDb - return associated internal Db

type Mysql 

type Mysql struct {
	DatabaseName   string               `json:"db"`
	Username       string               `json:"username"`
	Password       string               `json:"password"`
	Host           string               `json:"host"`
	Port           string               `json:"port"`
	Protocol       string               `json:"protocol"`
	Options        map[string]string    `json:"options"`
	Config         *Config              `json:"config"`
	LoggerConfig   *LoggerConfig        `json:"logger"`
	SpecificConfig *MysqlSpecificConfig `json:"specific_config"`
}

type MysqlSpecificConfig 

type MysqlSpecificConfig struct {
	DefaultStringSize         uint `json:"default_string_size"`
	DisableDatetimePrecision  bool `json:"disable_datetime_precision"`
	DefaultDatetimePrecision  int  `json:"default_datetime_precision"`
	SupportRenameIndex        bool `json:"support_rename_index"`
	SupportRenameColumn       bool `json:"support_rename_column"`
	SkipInitializeWithVersion bool `json:"skip_initialize_with_version"`
	DisableWithReturning      bool `json:"disable_with_returning"`
	SupportForShareClause     bool `json:"support_for_share_clause"`
	SupportNullAsDefaultValue bool `json:"support_null_as_default_value"`
	SupportRenameColumnUnique bool `json:"support_rename_column_unique"`
}

type NotExistServiceNameErr 

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

NotExistServiceNameErr Error

func (*NotExistServiceNameErr) Error 

func (err *NotExistServiceNameErr) Error() string

Error method - satisfying error interface

type NotImplementedErr 

type NotImplementedErr struct {
}

NotImplementedErr Error

func (*NotImplementedErr) Error 

func (err *NotImplementedErr) Error() string

Error method - satisfying error interface

type NotSupportedDbTypeErr 

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

NotSupportedDbTypeErr Error

func (*NotSupportedDbTypeErr) Error 

func (err *NotSupportedDbTypeErr) Error() string

Error method - satisfying error interface

type Postgresql 

type Postgresql struct {
	DatabaseName   string                    `json:"db"`
	Username       string                    `json:"username"`
	Password       string                    `json:"password"`
	Host           string                    `json:"host"`
	Port           string                    `json:"port"`
	Options        map[string]string         `json:"options"`
	Config         *Config                   `json:"config"`
	LoggerConfig   *LoggerConfig             `json:"logger"`
	SpecificConfig *PostgresqlSpecificConfig `json:"specific_config"`
}

type PostgresqlSpecificConfig 

type PostgresqlSpecificConfig struct {
	PreferSimpleProtocol bool `json:"prefer_simple_protocol"`
	WithoutReturning     bool `json:"without_returning"`
}

type SqlConfigurable 

type SqlConfigurable interface {
	Sqlite | Mysql | Postgresql
}

type SqlWrapper 

type SqlWrapper[T SqlConfigurable] struct {
	// contains filtered or unexported fields
}

SqlWrapper struct

func NewSqlWrapper 

func NewSqlWrapper[T SqlConfigurable](name string, dbType string) (*SqlWrapper[T], error)

NewSqlWrapper - create a new instance of SqlWrapper and returns it

func (*SqlWrapper[T]) AttachMigrationFunc 

func (s *SqlWrapper[T]) AttachMigrationFunc(f func(migrator gorm.Migrator) error) error

AttachMigrationFunc - attach migration function to be called by end user

func (*SqlWrapper[T]) GetDb 

func (s *SqlWrapper[T]) GetDb() (*gorm.DB, error)

GetDb - return associated internal Db

func (*SqlWrapper[T]) Migrate 

func (s *SqlWrapper[T]) Migrate(models ...interface{}) error

Migrate - migrate models to the database

type Sqlite 

type Sqlite struct {
	FileName     string            `json:"db"`
	Options      map[string]string `json:"options"`
	Config       *Config           `json:"config"`
	LoggerConfig *LoggerConfig     `json:"logger"`
}

Source Files

View all Source files

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.