Function handle_import

pac/redis_export.go:143–196

Redis 导入

()

// Redis 导入
func handle_import() {

	bs, err := ioutil.ReadFile(FileName)
	if err != nil {
		Info("读取文件失败" + err.Error())
	}
	redis_info := RedisInfo{}
	err = json.Unmarshal(bs, &redis_info)
	if err != nil {
		Info("不是合法的json文件" + err.Error())
	}
	//string
	for _, v := range redis_info.String {
		Rdb.Set(ctx, v.Key, v.Val, 0)
	}
	//hash
	for _, v := range redis_info.Hash {
		maps := map[string]string{}
		for _, d := range v.Data {
			maps[d.Field] = d.Val
		}
		Rdb.HMSet(ctx, v.Key, maps)
	}
	//set
	for _, v := range redis_info.Set {

		for _, v1 := range v.Data {
			Rdb.SAdd(ctx, v.Key, v1)
		}
	}
	//zset

	for _, v := range redis_info.Zset {

		zs := []*redis.Z{}
		for _, v1 := range v.Data {
			zs = append(zs, &redis.Z{
				Member: v1.Member,
				Score:  v1.Score,
			})
		}

		Rdb.ZAdd(ctx, v.Key, zs...)
	}
	//list
	for _, v := range redis_info.List {
		for _, v1 := range v.Data {
			Rdb.RPush(ctx, v.Key, v1)
		}
	}

	Success(FileName + "  导入成功")

}