db

package
v3.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2026 License: BSD-3-Clause Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MySQLResetRootPassword 

func MySQLResetRootPassword(password string) error

MySQLResetRootPassword 重置 MySQL root密码

Types

type Database 

type Database struct {
	Name      string `json:"name"`      // 数据库名
	Owner     string `json:"owner"`     // 所有者，MySQL 这个字段为空
	CharSet   string `json:"char_set"`  // 字符集，PG 里面对应 Encoding
	Collation string `json:"collation"` // 校对集，PG 这个字段为空
	Comment   string `json:"comment"`
}

type MySQL 

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

func (*MySQL) Close 

func (r *MySQL) Close()

func (*MySQL) DatabaseCreate 

func (r *MySQL) DatabaseCreate(name string) error

func (*MySQL) DatabaseDrop 

func (r *MySQL) DatabaseDrop(name string) error

func (*MySQL) DatabaseExists 

func (r *MySQL) DatabaseExists(name string) (bool, error)

func (*MySQL) DatabaseSize 

func (r *MySQL) DatabaseSize(name string) (int64, error)

func (*MySQL) Databases 

func (r *MySQL) Databases() ([]Database, error)

func (*MySQL) Exec 

func (r *MySQL) Exec(query string, args ...any) (sql.Result, error)

func (*MySQL) Ping 

func (r *MySQL) Ping() error

func (*MySQL) Prepare 

func (r *MySQL) Prepare(query string) (*sql.Stmt, error)

func (*MySQL) PrivilegesGrant 

func (r *MySQL) PrivilegesGrant(user, database string, host ...string) error

func (*MySQL) PrivilegesRevoke 

func (r *MySQL) PrivilegesRevoke(user, database string, host ...string) error

func (*MySQL) Query 

func (r *MySQL) Query(query string, args ...any) (*sql.Rows, error)

func (*MySQL) QueryRow 

func (r *MySQL) QueryRow(query string, args ...any) *sql.Row

func (*MySQL) UserCreate 

func (r *MySQL) UserCreate(user, password string, host ...string) error

func (*MySQL) UserDrop 

func (r *MySQL) UserDrop(user string, host ...string) error

func (*MySQL) UserPassword 

func (r *MySQL) UserPassword(user, password string, host ...string) error

func (*MySQL) UserPrivileges 

func (r *MySQL) UserPrivileges(user string, host ...string) ([]string, error)

func (*MySQL) Users 

func (r *MySQL) Users() ([]User, error)

type Operator 

type Operator interface {
	Close()
	Ping() error

	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	Exec(query string, args ...any) (sql.Result, error)
	Prepare(query string) (*sql.Stmt, error)

	DatabaseCreate(name string) error
	DatabaseDrop(name string) error
	DatabaseExists(name string) (bool, error)
	DatabaseSize(name string) (int64, error)

	UserCreate(user, password string, host ...string) error
	UserDrop(user string, host ...string) error
	UserPassword(user, password string, host ...string) error
	UserPrivileges(user string, host ...string) ([]string, error)

	PrivilegesGrant(user, database string, host ...string) error
	PrivilegesRevoke(user, database string, host ...string) error

	Users() ([]User, error)
	Databases() ([]Database, error)
}

func NewMySQL 

func NewMySQL(username, password, address string, typ ...string) (Operator, error)

func NewPostgres 

func NewPostgres(username, password, address string, port uint) (Operator, error)

type Postgres 

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

func (*Postgres) Close 

func (r *Postgres) Close()

func (*Postgres) DatabaseComment 

func (r *Postgres) DatabaseComment(name, comment string) error

func (*Postgres) DatabaseCreate 

func (r *Postgres) DatabaseCreate(name string) error

func (*Postgres) DatabaseDrop 

func (r *Postgres) DatabaseDrop(name string) error

func (*Postgres) DatabaseExists 

func (r *Postgres) DatabaseExists(name string) (bool, error)

func (*Postgres) DatabaseSize 

func (r *Postgres) DatabaseSize(name string) (int64, error)

func (*Postgres) Databases 

func (r *Postgres) Databases() ([]Database, error)

func (*Postgres) Exec 

func (r *Postgres) Exec(query string, args ...any) (sql.Result, error)

func (*Postgres) Ping 

func (r *Postgres) Ping() error

func (*Postgres) Prepare 

func (r *Postgres) Prepare(query string) (*sql.Stmt, error)

func (*Postgres) PrivilegesGrant 

func (r *Postgres) PrivilegesGrant(user, database string, host ...string) error

func (*Postgres) PrivilegesRevoke 

func (r *Postgres) PrivilegesRevoke(user, database string, host ...string) error

func (*Postgres) Query 

func (r *Postgres) Query(query string, args ...any) (*sql.Rows, error)

func (*Postgres) QueryRow 

func (r *Postgres) QueryRow(query string, args ...any) *sql.Row

func (*Postgres) UserCreate 

func (r *Postgres) UserCreate(user, password string, host ...string) error

func (*Postgres) UserDrop 

func (r *Postgres) UserDrop(user string, host ...string) error

func (*Postgres) UserPassword 

func (r *Postgres) UserPassword(user, password string, host ...string) error

func (*Postgres) UserPrivileges 

func (r *Postgres) UserPrivileges(user string, host ...string) ([]string, error)

func (*Postgres) Users 

func (r *Postgres) Users() ([]User, error)

type Redis 

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

func NewRedis 

func NewRedis(username, password, address string) (*Redis, error)

func (*Redis) Clear 

func (r *Redis) Clear() error

func (*Redis) Close 

func (r *Redis) Close()

func (*Redis) Data 

func (r *Redis) Data(page, pageSize int) ([]RedisKV, int, error)

func (*Redis) Database 

func (r *Redis) Database() (int, error)

Database 获取数据库数量

func (*Redis) Del 

func (r *Redis) Del(keys ...string) error

Del 删除 key

func (*Redis) Exec 

func (r *Redis) Exec(command string, args ...any) (any, error)

func (*Redis) Expire 

func (r *Redis) Expire(key string, ttl int64) error

Expire 设置 key 的 TTL，ttl 为 -1 时移除过期时间

func (*Redis) Get 

func (r *Redis) Get(key string) (*RedisKV, error)

Get 获取单个 key 的完整信息

func (*Redis) Rename 

func (r *Redis) Rename(oldKey, newKey string) error

Rename 重命名 key

func (*Redis) Search 

func (r *Redis) Search(pattern string, page, pageSize int) ([]RedisKV, int, error)

Search 搜索匹配的 key，支持分页

func (*Redis) Select 

func (r *Redis) Select(db int) error

func (*Redis) SetKey 

func (r *Redis) SetKey(key, value, keyType string, ttl int64) error

SetKey 根据类型创建或设置 key

func (*Redis) Size 

func (r *Redis) Size() (int, error)

type RedisKV 

type RedisKV struct {
	Key       string    `json:"key"`
	Value     string    `json:"value"`
	Type      string    `json:"type"`
	Size      int64     `json:"size"`
	Length    int64     `json:"length"`
	TTL       int64     `json:"ttl"`
	UpdatedAt time.Time `json:"updated_at"`
}

type User 

type User struct {
	User   string   `json:"user"`   // 用户名，PG 里面对应 Role
	Host   string   `json:"host"`   // 主机，PG 这个字段为空
	Grants []string `json:"grants"` // 权限列表
}

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.