Go Redis Crud 快速示例

#env file
redis_address=localhost
redis_port=6379
redis_password=123456
redis_db=0

#install on go
go get github.com/redis/go-redis/v9

package main

import (
    "fmt"
    "github.com/redis/go-redis/v9"
    "os"
    "strconv"
)

const customerdb = 0

type redismanager struct {
    db     int
    client *redis.client
}

func newredisclient(customerdb int) (*redismanager, error) {
    address := os.getenv("redis_address")
    if address == "" {
        return nil, fmt.errorf("redis_address is not set")
    }
    password := os.getenv("redis_password")
    if password == "" {
        return nil, fmt.errorf("redis_password is not set")
    }
    port := os.getenv("redis_port")
    if port == " " {
        return nil, fmt.errorf("redis_port is not set")
    }
    db := os.getenv("redis_db")
    if db == "" {
        return nil, fmt.errorf("redis_db is not set")
    }
    redisdb, err := strconv.atoi(db)
    if err != nil {
        return nil, fmt.errorf("redis_db is not a number")
    }
    cli := redis.newclient(&redis.options{
        addr:     fmt.sprintf("%s:%s", address, port),
        password: password,
        db:       redisdb,
    })
    return &redismanager{
        client: cli,
        db:     customerdb,
    }, nil
}
func (rd *redismanager) setdb(db int) {
    rd.db = db
}

type customerrepo struct {
    cli *redismanager
    db  int
}

func newcustomerrepo() (*customerrepo, error) {
    cli, err := newredisclient(customerdb)
    if err != nil {
        return nil, err
    }
    return &customerrepo{
        cli: cli,
    }, nil
}

type customer struct {
    id    string `redis:"id"`
    name  string `redis:"name"`
    email string `redis:"email"`
    phone string `redis:"phone"`
    age   int    `redis:"age"`
}

func (c *customerrepo) save(customer *customer) error {
    return c.cli.client.hset(context.todo(), customer.id, customer).err()
}

func (c *customerrepo) get(id string) (*customer, error) {
    customer := &customer{}
    resmap := c.cli.client.hgetall(context.todo(), id)
    if resmap.err() != nil {
        return nil, resmap.err()
    }
    if len(resmap.val()) == 0 {
        return nil, nil
    }
    err := resmap.scan(customer)
    if err != nil {
        return nil, err
    }
    return customer, nil
}

func (c *customerrepo) update(customer *customer) error {
    return c.cli.client.hset(context.todo(), customer.id, customer).err()
}

func (c *CustomerRepo) Delete(id string) error {
    return c.Cli.Client.Del(context.TODO(), id).Err()
}