rice

README

rice

Usage

Database

import "github.com/woxingliu/rice"

go mod tidy

postgresql

pg, err := rice.NewPostgresDB(
	"postgres://postgres:123456@localhost:5432/user?sslmode=disable",
	rice.ConnAttempts_Postgres(10),
	rice.MaxPoolSize_Postgres(4),
)
if err != nil {
	return err
}
defer pg.Close()

mariadb

mariaDB := rice.NewMariaDB(
	"root:root@tcp(localhost:3306)/user?parseTime=True&loc=Local&charset=utf8mb4&collation=utf8mb4_unicode_ci",
	rice.MaxIdleConns_MYSQL(4),
	rice.MaxOpenConns_MYSQL(4),
)
defer mariaDB.Close()

Documentation

Index

• func AESDecrypt(key []byte, s string) (string, error)
• func AESEncrypt(key []byte, s string) (string, error)
• func AESNewCBCDecrypter()
• func AESNewCBCEncrypter()
• func AESNewCFBDecrypter()
• func AESNewCFBEncrypter()
• func AESNewGCMDecrypt(keyString, nonceString, ciphertext string) (string, error)
• func AESNewGCMEncrypt(keyString, plaintext string) (string, error)
• func BCryptCompareHashAndPassword(pwd, hash string) bool
• func BCryptGenerateFromPassword(pwd string) (string, error)
• func ByteString(b []byte) string
• func BytesNewBufferString(b []byte) string
• func CloseDB()
• func FmtSprintfByte(b []byte) string
• func StrconvFormatInt(i int64) string
• func StrconvParseFloat(i int) (float64, error)
• func StrconvParseInt(s string) (int64, error)
• func StringByte(s string) []byte
• func TimeFormat(tm time.Time) string
• func TimeNowFormat() string
• func TimeParse(s string) (time.Time, error)
• func TimeUnix(sec int64) time.Time
• type MariaDB
  • func GetMariaDB() *MariaDB
  • func NewMariaDB(url string, opts ...MariaDBOption) *MariaDB
  • func (db *MariaDB) Close()
• type MariaDBOption
  • func ConnAttempts_MYSQL(attempts int) MariaDBOption
  • func ConnMaxIdleTime_MYSQL(d time.Duration) MariaDBOption
  • func ConnMaxLifetime_MYSQL(d time.Duration) MariaDBOption
  • func ConnTimeout_MYSQL(timeout time.Duration) MariaDBOption
  • func MaxIdleConns_MYSQL(size int) MariaDBOption
  • func MaxOpenConns_MYSQL(size int) MariaDBOption
• type Postgres
  • func GetPostgresDB() *Postgres
  • func NewPostgresDB(url string, opts ...PostgresOption) (*Postgres, error)
  • func (p *Postgres) Close()
• type PostgresOption
  • func ConnAttempts_Postgres(attempts int) PostgresOption
  • func ConnTimeout_Postgres(timeout time.Duration) PostgresOption
  • func MaxPoolSize_Postgres(size int) PostgresOption
• type Redis
  • func NewRedisClient(addr, pwd string, db, poolSize int) *Redis
  • func (r *Redis) Close()

Functions

func AESDecrypt

func AESDecrypt(key []byte, s string) (string, error)

func AESEncrypt

func AESEncrypt(key []byte, s string) (string, error)

func AESNewCBCDecrypter

func AESNewCBCDecrypter()

func AESNewCBCEncrypter

func AESNewCBCEncrypter()

func AESNewCFBDecrypter

func AESNewCFBDecrypter()

func AESNewCFBEncrypter

func AESNewCFBEncrypter()

func AESNewGCMDecrypt

func AESNewGCMDecrypt(keyString, nonceString, ciphertext string) (string, error)

func AESNewGCMEncrypt

func AESNewGCMEncrypt(keyString, plaintext string) (string, error)

func BCryptCompareHashAndPassword

func BCryptCompareHashAndPassword(pwd, hash string) bool

BCryptCompareHashAndPassword true or false

func BCryptGenerateFromPassword

func BCryptGenerateFromPassword(pwd string) (string, error)

BCryptGenerateFromPassword generate hash from password

func ByteString

func ByteString(b []byte) string

ByteString []byte to string

func BytesNewBufferString

func BytesNewBufferString(b []byte) string

BytesNewBufferString []byte to string

func CloseDB

func CloseDB()

func FmtSprintfByte

func FmtSprintfByte(b []byte) string

FmtSprintfByte []byte to string

func StrconvFormatInt

func StrconvFormatInt(i int64) string

StrconvFormatInt 1645270804 to "1645270804"

func StrconvParseFloat

func StrconvParseFloat(i int) (float64, error)

StrconvParseFloat int/100 to float64 保留 2 位小数点 example: 2333 -> 23.33

func StrconvParseInt

func StrconvParseInt(s string) (int64, error)

StrconvParseInt "1645270804" to 1645270804

func StringByte

func StringByte(s string) []byte

StringByte string to []byte

func TimeFormat

func TimeFormat(tm time.Time) string

TimeFormat time.Time to "2006-01-02 15:04:05"

func TimeNowFormat

func TimeNowFormat() string

TimeNowFormat time.Time to "2006-01-02 15:04:05"

func TimeParse

func TimeParse(s string) (time.Time, error)

TimeParse "2006-01-02 15:04:05" to time.Time

func TimeUnix

func TimeUnix(sec int64) time.Time

TimeUnix 1645270804 to time.Time

Types

type MariaDB

type MariaDB struct {
	*sql.DB
	// contains filtered or unexported fields
}

func GetMariaDB

func GetMariaDB() *MariaDB

func NewMariaDB

func NewMariaDB(url string, opts ...MariaDBOption) *MariaDB

func (*MariaDB) Close

func (db *MariaDB) Close()

type MariaDBOption

type MariaDBOption func(*MariaDB)

func ConnAttempts_MYSQL

func ConnAttempts_MYSQL(attempts int) MariaDBOption

ConnAttempts_MYSQL 尝试连接数据库次数

func ConnMaxIdleTime_MYSQL

func ConnMaxIdleTime_MYSQL(d time.Duration) MariaDBOption

ConnMaxIdleTime_MYSQL 一个连接空闲的最大时长

func ConnMaxLifetime_MYSQL

func ConnMaxLifetime_MYSQL(d time.Duration) MariaDBOption

ConnMaxLifetime_MYSQL 一个连接使用的最大时长

func ConnTimeout_MYSQL

func ConnTimeout_MYSQL(timeout time.Duration) MariaDBOption

ConnTimeout_MYSQL 连接数据库超时时间

func MaxIdleConns_MYSQL

func MaxIdleConns_MYSQL(size int) MariaDBOption

MaxIdleConns_MYSQL 最大闲置的连接数

func MaxOpenConns_MYSQL

func MaxOpenConns_MYSQL(size int) MariaDBOption

MaxOpenConns_MYSQL 最大打开的连接数

type Postgres

type Postgres struct {
	Builder squirrel.StatementBuilderType
	Pool    *pgxpool.Pool
	// contains filtered or unexported fields
}

Postgres -.

func GetPostgresDB

func GetPostgresDB() *Postgres

func NewPostgresDB

func NewPostgresDB(url string, opts ...PostgresOption) (*Postgres, error)

NewPostgresDB -.

func (*Postgres) Close

func (p *Postgres) Close()

Close -.

type PostgresOption

type PostgresOption func(*Postgres)

Option -.

func ConnAttempts_Postgres

func ConnAttempts_Postgres(attempts int) PostgresOption

ConnAttempts -.

func ConnTimeout_Postgres

func ConnTimeout_Postgres(timeout time.Duration) PostgresOption

ConnTimeout -.

func MaxPoolSize_Postgres

func MaxPoolSize_Postgres(size int) PostgresOption

MaxPoolSize -.

type Redis

type Redis struct {
	*redis.Client
	// contains filtered or unexported fields
}

func NewRedisClient

func NewRedisClient(addr, pwd string, db, poolSize int) *Redis

func (*Redis) Close

func (r *Redis) Close()