uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Better migrator detection for sameDB connection

Browse Source
This commit is contained in:
DanB
2018-05-29 20:30:28 +02:00
parent 25730575ee
commit ccf1468e6e
1 changed files with 39 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
cmd/cgr-migrator/cgr-migrator.go
View File

@@ -143,25 +143,39 @@ func main() {
}
// outDataDB
if *outDataDBType != utils.MetaDataDB {
if *outDataDBType == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBType = mgrCfg.DataDbType
} else {
mgrCfg.MigratorCgrConfig.OutDataDBType = strings.TrimPrefix(*outDataDBType, "*")
}
if *outDataDBHost != utils.MetaDataDB {
if *outDataDBHost == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBHost = mgrCfg.DataDbHost
} else {
mgrCfg.MigratorCgrConfig.OutDataDBHost = *outDataDBHost
}
if *outDataDBPort != utils.MetaDataDB {
if *outDataDBPort == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBPort = mgrCfg.DataDbPort
} else {
mgrCfg.MigratorCgrConfig.OutDataDBPort = *outDataDBPort
}
if *outDataDBName != utils.MetaDataDB {
if *outDataDBName == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBName = mgrCfg.DataDbName
} else {
mgrCfg.MigratorCgrConfig.OutDataDBName = *outDataDBName
}
if *outDataDBUser != utils.MetaDataDB {
if *outDataDBUser == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBUser = mgrCfg.DataDbUser
} else {
mgrCfg.MigratorCgrConfig.OutDataDBUser = *outDataDBUser
}
if *outDataDBPass != utils.MetaDataDB {
if *outDataDBPass == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBPassword = mgrCfg.DataDbPass
} else {
mgrCfg.MigratorCgrConfig.OutDataDBPassword = *outDataDBPass
}
if *outDBDataEncoding != utils.MetaDataDB {
if *outDBDataEncoding == utils.MetaDataDB {
mgrCfg.MigratorCgrConfig.OutDataDBEncoding = mgrCfg.DBDataEncoding
} else {
mgrCfg.MigratorCgrConfig.OutDataDBEncoding = *outDBDataEncoding
}
@@ -186,27 +200,36 @@ func main() {
}
// outStorDB
if *outStorDBType != utils.MetaStorDB {
if *outStorDBType == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBType = mgrCfg.StorDBType
} else {
mgrCfg.MigratorCgrConfig.OutStorDBType = strings.TrimPrefix(*outStorDBType, "*")
}
if *outStorDBHost != utils.MetaStorDB {
if *outStorDBHost == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBHost = mgrCfg.StorDBHost
} else {
mgrCfg.MigratorCgrConfig.OutStorDBHost = *outStorDBHost
}
if *outStorDBPort != utils.MetaStorDB {
if *outStorDBPort == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBPort = mgrCfg.StorDBPort
} else {
mgrCfg.MigratorCgrConfig.OutStorDBPort = *outStorDBPort
}
if *outStorDBName != utils.MetaStorDB {
if *outStorDBName == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBName = mgrCfg.StorDBName
} else {
mgrCfg.MigratorCgrConfig.OutStorDBName = *outStorDBName
}
if *outStorDBUser != utils.MetaStorDB {
if *outStorDBUser == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBUser = mgrCfg.StorDBUser
} else {
mgrCfg.MigratorCgrConfig.OutStorDBUser = *outStorDBUser
}
if *outStorDBPass != utils.MetaStorDB {
if *outStorDBPass == utils.MetaStorDB {
mgrCfg.MigratorCgrConfig.OutStorDBPassword = mgrCfg.StorDBPass
} else {
mgrCfg.MigratorCgrConfig.OutStorDBPassword = *outStorDBPass
}
if *outDBDataEncoding != "" {
*outDBDataEncoding = mgrCfg.DBDataEncoding
}
sameDataDB = mgrCfg.MigratorCgrConfig.OutDataDBType == mgrCfg.DataDbType &&
mgrCfg.MigratorCgrConfig.OutDataDBHost == mgrCfg.DataDbHost &&