weSubDatabase

Sep 14, 2023

Changes in this version

type Setting

+ func (s *Setting) AddForPrimary(table string, encryptedKey []string, keys []string, value [][]string, ...) ([]int64, []error)

Sep 11, 2023

Changes in this version

type Config

+ Redis []RedisConfig

type LinkSQLO

+ func OLRedisAutoDeleteTime(AutoDeleteTime int) LinkSQLO

+ func OLRedisIsDelete(IsDelete bool) LinkSQLO

+ func OLRedisIsErrorStop(IsErrorStop bool) LinkSQLO

+ func OLRedisIsShowPrint(IsShowPrint bool) LinkSQLO

type Option

+ AutoDeleteTime int

+ IsDelete bool

+ IsErrorStop bool

+ type RedisConfig struct

+ Addr string

+ MaxDB int

+ Password string

+ Port string

+ type RedisDB struct

+ Addr string

+ DB *redis.Client

+ DBItem int

+ func (db *RedisDB) Close()

+ func (rDB *RedisDB) Del(keys []string, options ...RedisO) error

+ func (rDB *RedisDB) DelMulti(keyPattern string, options ...RedisO) error

+ func (rDB *RedisDB) GetString(key string, options ...RedisO) (string, error)

+ func (rDB *RedisDB) GetStringAll(keyPattern string, options ...RedisO) (map[string]string, error)

+ func (rDB *RedisDB) Keys(keyPattern string) ([]string, error)

+ func (rDB *RedisDB) SetValue(key string, val string, options ...RedisO) error

+ type RedisO func(*Option)

+ func OLRedisWaitCount(WaitCount int) RedisO

+ func OLRedisWaitTime(WaitTime int) RedisO

type Setting

+ NextRedisDBID int

+ RedisConfigs []RedisConfig

+ RedisConnectFailTime []*time.Time

+ RedisDB []*RedisDB

+ RedisLinkNum int

+ RedisMaxLink int

+ RedisMaxNum int

+ func (s *Setting) RedisClose(i int, options ...IsShowPrintO)

+ func (s *Setting) RedisIsRun(item int, dbID int, options ...RedisO) (int, error)

+ func (s *Setting) RedisLink(item int, dbID int) (*RedisDB, error)

Jul 19, 2023

Changes in this version

+ func CheckString(str string) []string

+ func SetRegexpString(regexpStr string)

Jul 17, 2023

Changes in this version

+ type IsPrimaryKeyO func(*Option)

+ func OIPKIsPrimaryKey(IsPrimaryKey bool) IsPrimaryKeyO

+ func OIPKIsShowPrint(IsShowPrint bool) IsPrimaryKeyO

+ type IsShowPrintO func(*Option)

+ func OIsShowPrint(IsShowPrint bool) IsShowPrintO

+ type LinkSQLO func(*Option)

+ func OLIsShowPrint(IsShowPrint bool) LinkSQLO

+ func OLWaitCount(WaitCount int) LinkSQLO

+ func OLWaitTime(WaitTime int) LinkSQLO

type Option

+ IsShowPrint bool

+ type RetryTimeO func(*Option)

type Setting

+ NextDBID int

Jul 14, 2023

Changes in this version

+ type NewOptionConfig func(*Option)

+ func OptionRetryTime(RetryTime int) NewOptionConfig

type Option

+ RetryTime int

type Setting

+ ConnectAgainTime int

+ ConnectFailTime []*time.Time

+ func (s *Setting) IsRetryConnect(item int) bool

Jul 14, 2023

Changes in this version

+ func Parse(jsonStr string) (*wJson, error)

+ func Test()

+ type Config struct

+ Contrast Contrast

+ MaxLink MaxLinkNumber

+ Mysql []SQLConfig

+ MysqlName string

+ func GetConfig(configStr string) (*Config, error)

+ type Contrast struct

+ ExtraItem int

+ Key []string

+ type LinkSQLOptionConfig func(*Option)

+ func OptionWaitCount(WaitCount int) LinkSQLOptionConfig

+ func OptionWaitTime(WaitTime int) LinkSQLOptionConfig

+ type MaxLinkNumber struct

+ MySQL int

+ Redis int

+ type MysqlDB struct

+ DB *sql.DB

+ DBItem int

+ Name string

+ func (db *MysqlDB) Close()

+ func (s *MysqlDB) AddRecord(table string, keys string, values string, Debug *log.Logger) (int64, error)

+ func (s *MysqlDB) ExecCMD(sqlStr string, Debug *log.Logger) (int64, int64, error)

+ func (s *MysqlDB) QueryCMD(sqlStr string, Debug *log.Logger) ([]map[string]string, error)

+ type Option struct

+ IsPrimaryKey bool

+ WaitCount int

+ WaitTime int

+ type SQLConfig struct

+ Address string

+ DB string

+ Password string

+ Port string

+ User string

+ func GetSQLConfig(config string) (*SQLConfig, error)

+ func GetSQLConfigMap(configMap map[string]interface{}) *SQLConfig

+ type Setting struct

+ DBMaxNum int

+ DBName string

+ LinkNum int

+ MaxLink int

+ MySQLDB []*MysqlDB

+ NextAddDBID int

+ SEKey *simpleEncryption.SecretKey

+ SqlConfigs []SQLConfig

+ func New(configString string, nextDBID int) (*Setting, error)

+ func (s *Setting) Add(table string, keys []string, values [][]string, Debug *log.Logger) ([]int64, []error)

+ func (s *Setting) DecryptID(primaryKey string, ids []string) ([]bool, [][]string, [][]int)

+ func (s *Setting) Delete(table string, forKey string, ids []string, Debug *log.Logger, ...) ([]int64, []error)

+ func (s *Setting) EncryptPrimaryKey(queryDatas []map[string]string, primaryKey string) []map[string]string

+ func (s *Setting) Link(item int) (*MysqlDB, error)

+ func (s *Setting) MysqlClose(i int)

+ func (s *Setting) MysqlIsRun(item int, options ...LinkSQLOptionConfig) (int, error)

+ func (s *Setting) Query(table string, from string, primaryKey string, where string, order string, ...) ([]map[string]string, []error)

+ func (s *Setting) QueryID(table string, from string, primaryKey string, ids []string, order string, ...) ([]map[string]string, []error)

+ func (s *Setting) SelectLastID(table string, primaryKey string, Debug *log.Logger) (int, int, error)

+ func (s *Setting) Update(table string, key []string, value [][]string, forKey string, ids []string, ...) ([]int64, []error)

+ type UpdateOptionConfig func(*Option)

+ func OptionIsPrimaryKey(IsPrimaryKey bool) UpdateOptionConfig