Improve syncer.initAdapter().

This commit is contained in:
Yang Luo
2021-12-23 21:28:40 +08:00
parent fa45d3083a
commit f4890a6a22
4 changed files with 31 additions and 22 deletions

View File

@ -125,6 +125,9 @@ func (syncer *Syncer) calculateHash(user *OriginalUser) string {
func (syncer *Syncer) initAdapter() {
if syncer.Adapter == nil {
dataSourceName := fmt.Sprintf("%s:%s@tcp(%s:%d)/", syncer.User, syncer.Password, syncer.Host, syncer.Port)
if !isCloudIntranet {
dataSourceName = strings.ReplaceAll(dataSourceName, "dbi.", "db.")
}
syncer.Adapter = NewAdapter(beego.AppConfig.String("driverName"), dataSourceName, syncer.Database)
}
}