yizhisec/packages
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: new cache(redis) uri invalid

Browse Source
This commit is contained in:
zhaoyupeng 2025-06-23 17:04:06 +08:00
parent 6d1024f951
commit b6ee2966cf
2 changed files with 35 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
database/cache/new_test.go vendored
View File

@ -37,3 +37,37 @@ func TestNew(t *testing.T) {
t.Fatal(err)
}*/
}
func TestNoAuth(t *testing.T) {
//if err := Init(WithRedis("10.125.1.28", 6379, "", "")); err != nil {
// t.Fatal(err)
//}
//
//type User struct {
// Name string `json:"name"`
// Age int `json:"age"`
//}
//
//if err := Default.Set(t.Context(), "zyp:haha", &User{
// Name: "cache",
// Age: 18,
//}); err != nil {
// t.Fatal(err)
//}
//
//s := Default.GetDelScan(t.Context(), "zyp:haha")
//u := new(User)
//
//if err := s.Scan(u); err != nil {
// t.Fatal(err)
//}
//
//t.Logf("%#v", *u)
//
//if err := Default.SetEx(t.Context(), "zyp:haha", &User{
// Name: "redis",
// Age: 2,
//}, time.Hour); err != nil {
// t.Fatal(err)
//}
}

2
database/cache/option.go vendored
View File

@ -22,7 +22,7 @@ func WithCtx(ctx context.Context) OptionFn {
func WithRedis(host string, port int, username, password string) OptionFn {
return func(c *config) {
uri := fmt.Sprintf("%s:%d", host, port)
uri := fmt.Sprintf("redis://%s:%d", host, port)
if username != "" || password != "" {
uri = fmt.Sprintf("redis://%s:%s@%s:%d", username, password, host, port)
}