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 ByteString(b []byte) string
• func CloseDB()
• func StrconvFormatInt(i int64) string
• func StrconvParseFloat(i int) float64
• func StrconvParseInt(s string) int64
• func StringByte(s string) (b []byte)
• func TimeFormat(tm time.Time) string
• func TimeNowFormat() string
• func TimeParse(s string) time.Time
• 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 ByteString

func ByteString(b []byte) string

[]byte to string

func CloseDB

func CloseDB()

func StrconvFormatInt

func StrconvFormatInt(i int64) string

1645270804 to "1645270804"

func StrconvParseFloat

func StrconvParseFloat(i int) float64

int/100 to float64 保留 2 位小数点

func StrconvParseInt

func StrconvParseInt(s string) int64

"1645270804" to 1645270804

func StringByte

func StringByte(s string) (b []byte)

string to []byte

func TimeFormat

func TimeFormat(tm time.Time) string

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

func TimeNowFormat

func TimeNowFormat() string

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

func TimeParse

func TimeParse(s string) time.Time

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

func TimeUnix

func TimeUnix(sec int64) time.Time

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()