db

Documentation

Index

• func NewConfigDbClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)
• func NewConfigMongoDbClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)
• func NewConfigMysqlClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)
• func NewConfigRedisClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)
• func NewDbClientFromUri(ctx context.Context, name string, uri string) (gira.DbClient, error)
• type MigrateConnectTimeout
  • func WithMigrateConnectTimeout(timeout int64) MigrateConnectTimeout
  • func (opt MigrateConnectTimeout) ConfigMigrateOptions(opts *MigrateOptions)
• type MigrateDropIndex
  • func WithMigrateDropIndex(enabled bool) MigrateDropIndex
  • func (opt MigrateDropIndex) ConfigMigrateOptions(opts *MigrateOptions)
• type MigrateOption
• type MigrateOptions
• type MongoDbClient
  • func (self *MongoDbClient) GetMongoClient() *mongo.Client
  • func (self *MongoDbClient) GetMongoDatabase() *mongo.Database
  • func (self *MongoDbClient) Uri() string
• type MysqlClient
  • func (self *MysqlClient) GetMysqlClient() *sql.DB
  • func (self *MysqlClient) Uri() string
• type RedisClient
  • func (self *RedisClient) GetRedisClient() *redis.Client
  • func (self *RedisClient) Uri() string

Functions

func NewConfigDbClient

func NewConfigDbClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)

根据配置构造db client

func NewConfigMongoDbClient

func NewConfigMongoDbClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)

根据配置构造mongodb client

func NewConfigMysqlClient

func NewConfigMysqlClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)

根据配置构造mysql client

func NewConfigRedisClient

func NewConfigRedisClient(ctx context.Context, name string, config gira.DbConfig) (gira.DbClient, error)

根据配置构造redis client

func NewDbClientFromUri

func NewDbClientFromUri(ctx context.Context, name string, uri string) (gira.DbClient, error)

根据url构造db client

Types

type MigrateConnectTimeout

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

func WithMigrateConnectTimeout

func WithMigrateConnectTimeout(timeout int64) MigrateConnectTimeout

设置连接超时时间

func (MigrateConnectTimeout) ConfigMigrateOptions

func (opt MigrateConnectTimeout) ConfigMigrateOptions(opts *MigrateOptions)

type MigrateDropIndex

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

func WithMigrateDropIndex

func WithMigrateDropIndex(enabled bool) MigrateDropIndex

设置允许drop index

func (MigrateDropIndex) ConfigMigrateOptions

func (opt MigrateDropIndex) ConfigMigrateOptions(opts *MigrateOptions)

type MigrateOption

type MigrateOption interface {
	ConfigMigrateOptions(opts *MigrateOptions)
}

type MigrateOptions

type MigrateOptions struct {
	EnabledDropIndex bool
	ConnectTimeout   int64
}

========= migrate选项 ==================

type MongoDbClient

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

mongodb客户端

func (*MongoDbClient) GetMongoClient

func (self *MongoDbClient) GetMongoClient() *mongo.Client

func (*MongoDbClient) GetMongoDatabase

func (self *MongoDbClient) GetMongoDatabase() *mongo.Database

func (*MongoDbClient) Uri

func (self *MongoDbClient) Uri() string

type MysqlClient

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

mysql客户端

func (*MysqlClient) GetMysqlClient

func (self *MysqlClient) GetMysqlClient() *sql.DB

func (*MysqlClient) Uri

func (self *MysqlClient) Uri() string

type RedisClient

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

redis客户端

func (*RedisClient) GetRedisClient

func (self *RedisClient) GetRedisClient() *redis.Client

func (*RedisClient) Uri

func (self *RedisClient) Uri() string