@@ -45,20 +45,24 @@ func (m *mongo) Initialization() error {
45
45
opts = internal .Mongo .GetClientOptions ()
46
46
}
47
47
ctx := context .Background ()
48
- client , err := qmgo . Open ( ctx , & qmgo.Config {
48
+ config := & qmgo.Config {
49
49
Uri : global .GVA_CONFIG .Mongo .Uri (),
50
50
Coll : global .GVA_CONFIG .Mongo .Coll ,
51
51
Database : global .GVA_CONFIG .Mongo .Database ,
52
52
MinPoolSize : & global .GVA_CONFIG .Mongo .MinPoolSize ,
53
53
MaxPoolSize : & global .GVA_CONFIG .Mongo .MaxPoolSize ,
54
54
SocketTimeoutMS : & global .GVA_CONFIG .Mongo .SocketTimeoutMs ,
55
55
ConnectTimeoutMS : & global .GVA_CONFIG .Mongo .ConnectTimeoutMs ,
56
- Auth : & qmgo.Credential {
56
+ }
57
+ if global .GVA_CONFIG .Mongo .Username != "" && global .GVA_CONFIG .Mongo .Password != "" {
58
+ config .Auth = & qmgo.Credential {
57
59
Username : global .GVA_CONFIG .Mongo .Username ,
58
60
Password : global .GVA_CONFIG .Mongo .Password ,
59
61
AuthSource : global .GVA_CONFIG .Mongo .AuthSource ,
60
- },
61
- }, opts ... )
62
+ }
63
+ }
64
+ client , err := qmgo .Open (ctx , config , opts ... )
65
+
62
66
if err != nil {
63
67
return errors .Wrap (err , "链接mongodb数据库失败!" )
64
68
}
0 commit comments