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

Updated dataDB config structure

Browse Source
This commit is contained in:
Trial97
2021-03-08 11:44:46 +02:00
committed by Dan Christian Bogos
parent f6b6e62cf4
commit 5f0150b639
46 changed files with 488 additions and 486 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
migrator/accounts2_it_test.go
View File

@@ -65,18 +65,18 @@ func TestAccMigrateWithInternal(t *testing.T) {
}
func testAcc2ITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(acc2CfgIn.DataDbCfg().DataDbType,
acc2CfgIn.DataDbCfg().DataDbHost, acc2CfgIn.DataDbCfg().DataDbPort,
acc2CfgIn.DataDbCfg().DataDbName, acc2CfgIn.DataDbCfg().DataDbUser,
acc2CfgIn.DataDbCfg().DataDbPass, acc2CfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(acc2CfgIn.DataDbCfg().Type,
acc2CfgIn.DataDbCfg().Host, acc2CfgIn.DataDbCfg().Port,
acc2CfgIn.DataDbCfg().Name, acc2CfgIn.DataDbCfg().User,
acc2CfgIn.DataDbCfg().Password, acc2CfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), acc2CfgIn.DataDbCfg().Opts)
if err != nil {
t.Error(err)
}
dataDBOut, err := NewMigratorDataDB(acc2CfgOut.DataDbCfg().DataDbType,
acc2CfgOut.DataDbCfg().DataDbHost, acc2CfgOut.DataDbCfg().DataDbPort,
acc2CfgOut.DataDbCfg().DataDbName, acc2CfgOut.DataDbCfg().DataDbUser,
acc2CfgOut.DataDbCfg().DataDbPass, acc2CfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(acc2CfgOut.DataDbCfg().Type,
acc2CfgOut.DataDbCfg().Host, acc2CfgOut.DataDbCfg().Port,
acc2CfgOut.DataDbCfg().Name, acc2CfgOut.DataDbCfg().User,
acc2CfgOut.DataDbCfg().Password, acc2CfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), acc2CfgOut.DataDbCfg().Opts)
if err != nil {
t.Error(err)

16
migrator/accounts_it_test.go
View File

@@ -163,18 +163,18 @@ func TestAccountITMoveEncoding2(t *testing.T) {
}
func testAccITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(accCfgIn.DataDbCfg().DataDbType,
accCfgIn.DataDbCfg().DataDbHost, accCfgIn.DataDbCfg().DataDbPort,
accCfgIn.DataDbCfg().DataDbName, accCfgIn.DataDbCfg().DataDbUser,
accCfgIn.DataDbCfg().DataDbPass, accCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(accCfgIn.DataDbCfg().Type,
accCfgIn.DataDbCfg().Host, accCfgIn.DataDbCfg().Port,
accCfgIn.DataDbCfg().Name, accCfgIn.DataDbCfg().User,
accCfgIn.DataDbCfg().Password, accCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), accCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(accCfgOut.DataDbCfg().DataDbType,
accCfgOut.DataDbCfg().DataDbHost, accCfgOut.DataDbCfg().DataDbPort,
accCfgOut.DataDbCfg().DataDbName, accCfgOut.DataDbCfg().DataDbUser,
accCfgOut.DataDbCfg().DataDbPass, accCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(accCfgOut.DataDbCfg().Type,
accCfgOut.DataDbCfg().Host, accCfgOut.DataDbCfg().Port,
accCfgOut.DataDbCfg().Name, accCfgOut.DataDbCfg().User,
accCfgOut.DataDbCfg().Password, accCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), accCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/action_it_test.go
View File

@@ -161,18 +161,18 @@ func TestActionITMoveEncoding2(t *testing.T) {
}
func testActITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(actCfgIn.DataDbCfg().DataDbType,
actCfgIn.DataDbCfg().DataDbHost, actCfgIn.DataDbCfg().DataDbPort,
actCfgIn.DataDbCfg().DataDbName, actCfgIn.DataDbCfg().DataDbUser,
actCfgIn.DataDbCfg().DataDbPass, actCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(actCfgIn.DataDbCfg().Type,
actCfgIn.DataDbCfg().Host, actCfgIn.DataDbCfg().Port,
actCfgIn.DataDbCfg().Name, actCfgIn.DataDbCfg().User,
actCfgIn.DataDbCfg().Password, actCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(actCfgOut.DataDbCfg().DataDbType,
actCfgOut.DataDbCfg().DataDbHost, actCfgOut.DataDbCfg().DataDbPort,
actCfgOut.DataDbCfg().DataDbName, actCfgOut.DataDbCfg().DataDbUser,
actCfgOut.DataDbCfg().DataDbPass, actCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(actCfgOut.DataDbCfg().Type,
actCfgOut.DataDbCfg().Host, actCfgOut.DataDbCfg().Port,
actCfgOut.DataDbCfg().Name, actCfgOut.DataDbCfg().User,
actCfgOut.DataDbCfg().Password, actCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/action_plan_it_test.go
View File

@@ -161,18 +161,18 @@ func TestActionPlanITMoveEncoding2(t *testing.T) {
}
func testActPlnITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(actPlnCfgIn.DataDbCfg().DataDbType,
actPlnCfgIn.DataDbCfg().DataDbHost, actPlnCfgIn.DataDbCfg().DataDbPort,
actPlnCfgIn.DataDbCfg().DataDbName, actPlnCfgIn.DataDbCfg().DataDbUser,
actPlnCfgIn.DataDbCfg().DataDbPass, actPlnCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(actPlnCfgIn.DataDbCfg().Type,
actPlnCfgIn.DataDbCfg().Host, actPlnCfgIn.DataDbCfg().Port,
actPlnCfgIn.DataDbCfg().Name, actPlnCfgIn.DataDbCfg().User,
actPlnCfgIn.DataDbCfg().Password, actPlnCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actPlnCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(actPlnCfgOut.DataDbCfg().DataDbType,
actPlnCfgOut.DataDbCfg().DataDbHost, actPlnCfgOut.DataDbCfg().DataDbPort,
actPlnCfgOut.DataDbCfg().DataDbName, actPlnCfgOut.DataDbCfg().DataDbUser,
actPlnCfgOut.DataDbCfg().DataDbPass, actPlnCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(actPlnCfgOut.DataDbCfg().Type,
actPlnCfgOut.DataDbCfg().Host, actPlnCfgOut.DataDbCfg().Port,
actPlnCfgOut.DataDbCfg().Name, actPlnCfgOut.DataDbCfg().User,
actPlnCfgOut.DataDbCfg().Password, actPlnCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actPlnCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/action_trigger_it_test.go
View File

@@ -143,18 +143,18 @@ func TestActionTriggerITMoveEncoding2(t *testing.T) {
}
func testActTrgITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(actTrgCfgIn.DataDbCfg().DataDbType,
actTrgCfgIn.DataDbCfg().DataDbHost, actTrgCfgIn.DataDbCfg().DataDbPort,
actTrgCfgIn.DataDbCfg().DataDbName, actTrgCfgIn.DataDbCfg().DataDbUser,
actTrgCfgIn.DataDbCfg().DataDbPass, actTrgCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(actTrgCfgIn.DataDbCfg().Type,
actTrgCfgIn.DataDbCfg().Host, actTrgCfgIn.DataDbCfg().Port,
actTrgCfgIn.DataDbCfg().Name, actTrgCfgIn.DataDbCfg().User,
actTrgCfgIn.DataDbCfg().Password, actTrgCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actTrgCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(actTrgCfgOut.DataDbCfg().DataDbType,
actTrgCfgOut.DataDbCfg().DataDbHost, actTrgCfgOut.DataDbCfg().DataDbPort,
actTrgCfgOut.DataDbCfg().DataDbName, actTrgCfgOut.DataDbCfg().DataDbUser,
actTrgCfgOut.DataDbCfg().DataDbPass, actTrgCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(actTrgCfgOut.DataDbCfg().Type,
actTrgCfgOut.DataDbCfg().Host, actTrgCfgOut.DataDbCfg().Port,
actTrgCfgOut.DataDbCfg().Name, actTrgCfgOut.DataDbCfg().User,
actTrgCfgOut.DataDbCfg().Password, actTrgCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actTrgCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/actionprofiles_it_test.go
View File

@@ -125,18 +125,18 @@ func TestActPrfITMoveEncoding2(t *testing.T) {
}
func testActPrfITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(actPrfCfgIn.DataDbCfg().DataDbType,
actPrfCfgIn.DataDbCfg().DataDbHost, actPrfCfgIn.DataDbCfg().DataDbPort,
actPrfCfgIn.DataDbCfg().DataDbName, actPrfCfgIn.DataDbCfg().DataDbUser,
actPrfCfgIn.DataDbCfg().DataDbPass, actPrfCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(actPrfCfgIn.DataDbCfg().Type,
actPrfCfgIn.DataDbCfg().Host, actPrfCfgIn.DataDbCfg().Port,
actPrfCfgIn.DataDbCfg().Name, actPrfCfgIn.DataDbCfg().User,
actPrfCfgIn.DataDbCfg().Password, actPrfCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actPrfCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(actPrfCfgOut.DataDbCfg().DataDbType,
actPrfCfgOut.DataDbCfg().DataDbHost, actPrfCfgOut.DataDbCfg().DataDbPort,
actPrfCfgOut.DataDbCfg().DataDbName, actPrfCfgOut.DataDbCfg().DataDbUser,
actPrfCfgOut.DataDbCfg().DataDbPass, actPrfCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(actPrfCfgOut.DataDbCfg().Type,
actPrfCfgOut.DataDbCfg().Host, actPrfCfgOut.DataDbCfg().Port,
actPrfCfgOut.DataDbCfg().Name, actPrfCfgOut.DataDbCfg().User,
actPrfCfgOut.DataDbCfg().Password, actPrfCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), actPrfCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/alias_it_test.go
View File

@@ -79,18 +79,18 @@ func testStart(testName string, t *testing.T) {
}
func testAlsITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(alsCfgIn.DataDbCfg().DataDbType,
alsCfgIn.DataDbCfg().DataDbHost, alsCfgIn.DataDbCfg().DataDbPort,
alsCfgIn.DataDbCfg().DataDbName, alsCfgIn.DataDbCfg().DataDbUser,
alsCfgIn.DataDbCfg().DataDbPass, alsCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(alsCfgIn.DataDbCfg().Type,
alsCfgIn.DataDbCfg().Host, alsCfgIn.DataDbCfg().Port,
alsCfgIn.DataDbCfg().Name, alsCfgIn.DataDbCfg().User,
alsCfgIn.DataDbCfg().Password, alsCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), alsCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(alsCfgOut.DataDbCfg().DataDbType,
alsCfgOut.DataDbCfg().DataDbHost, alsCfgOut.DataDbCfg().DataDbPort,
alsCfgOut.DataDbCfg().DataDbName, alsCfgOut.DataDbCfg().DataDbUser,
alsCfgOut.DataDbCfg().DataDbPass, alsCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(alsCfgOut.DataDbCfg().Type,
alsCfgOut.DataDbCfg().Host, alsCfgOut.DataDbCfg().Port,
alsCfgOut.DataDbCfg().Name, alsCfgOut.DataDbCfg().User,
alsCfgOut.DataDbCfg().Password, alsCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), alsCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/attributes_it_test.go
View File

@@ -199,18 +199,18 @@ func TestAttributeITMoveEncoding2(t *testing.T) {
}
func testAttrITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(attrCfgIn.DataDbCfg().DataDbType,
attrCfgIn.DataDbCfg().DataDbHost, attrCfgIn.DataDbCfg().DataDbPort,
attrCfgIn.DataDbCfg().DataDbName, attrCfgIn.DataDbCfg().DataDbUser,
attrCfgIn.DataDbCfg().DataDbPass, attrCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(attrCfgIn.DataDbCfg().Type,
attrCfgIn.DataDbCfg().Host, attrCfgIn.DataDbCfg().Port,
attrCfgIn.DataDbCfg().Name, attrCfgIn.DataDbCfg().User,
attrCfgIn.DataDbCfg().Password, attrCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), attrCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(attrCfgOut.DataDbCfg().DataDbType,
attrCfgOut.DataDbCfg().DataDbHost, attrCfgOut.DataDbCfg().DataDbPort,
attrCfgOut.DataDbCfg().DataDbName, attrCfgOut.DataDbCfg().DataDbUser,
attrCfgOut.DataDbCfg().DataDbPass, attrCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(attrCfgOut.DataDbCfg().Type,
attrCfgOut.DataDbCfg().Host, attrCfgOut.DataDbCfg().Port,
attrCfgOut.DataDbCfg().Name, attrCfgOut.DataDbCfg().User,
attrCfgOut.DataDbCfg().Password, attrCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), attrCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/chargers_it_test.go
View File

@@ -124,18 +124,18 @@ func TestChargersITMoveEncoding2(t *testing.T) {
}
func testChrgITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(chrgCfgIn.DataDbCfg().DataDbType,
chrgCfgIn.DataDbCfg().DataDbHost, chrgCfgIn.DataDbCfg().DataDbPort,
chrgCfgIn.DataDbCfg().DataDbName, chrgCfgIn.DataDbCfg().DataDbUser,
chrgCfgIn.DataDbCfg().DataDbPass, chrgCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(chrgCfgIn.DataDbCfg().Type,
chrgCfgIn.DataDbCfg().Host, chrgCfgIn.DataDbCfg().Port,
chrgCfgIn.DataDbCfg().Name, chrgCfgIn.DataDbCfg().User,
chrgCfgIn.DataDbCfg().Password, chrgCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), chrgCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(chrgCfgOut.DataDbCfg().DataDbType,
chrgCfgOut.DataDbCfg().DataDbHost, chrgCfgOut.DataDbCfg().DataDbPort,
chrgCfgOut.DataDbCfg().DataDbName, chrgCfgOut.DataDbCfg().DataDbUser,
chrgCfgOut.DataDbCfg().DataDbPass, chrgCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(chrgCfgOut.DataDbCfg().Type,
chrgCfgOut.DataDbCfg().Host, chrgCfgOut.DataDbCfg().Port,
chrgCfgOut.DataDbCfg().Name, chrgCfgOut.DataDbCfg().User,
chrgCfgOut.DataDbCfg().Password, chrgCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), chrgCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/derived_chargers_it_test.go
View File

@@ -78,18 +78,18 @@ func testStartDC(testName string, t *testing.T) {
}
func testDCITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(dcCfgIn.DataDbCfg().DataDbType,
dcCfgIn.DataDbCfg().DataDbHost, dcCfgIn.DataDbCfg().DataDbPort,
dcCfgIn.DataDbCfg().DataDbName, dcCfgIn.DataDbCfg().DataDbUser,
dcCfgIn.DataDbCfg().DataDbPass, dcCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(dcCfgIn.DataDbCfg().Type,
dcCfgIn.DataDbCfg().Host, dcCfgIn.DataDbCfg().Port,
dcCfgIn.DataDbCfg().Name, dcCfgIn.DataDbCfg().User,
dcCfgIn.DataDbCfg().Password, dcCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), dcCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(dcCfgOut.DataDbCfg().DataDbType,
dcCfgOut.DataDbCfg().DataDbHost, dcCfgOut.DataDbCfg().DataDbPort,
dcCfgOut.DataDbCfg().DataDbName, dcCfgOut.DataDbCfg().DataDbUser,
dcCfgOut.DataDbCfg().DataDbPass, dcCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(dcCfgOut.DataDbCfg().Type,
dcCfgOut.DataDbCfg().Host, dcCfgOut.DataDbCfg().Port,
dcCfgOut.DataDbCfg().Name, dcCfgOut.DataDbCfg().User,
dcCfgOut.DataDbCfg().Password, dcCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), dcCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/dispatchers_it_test.go
View File

@@ -124,18 +124,18 @@ func TestDispatcherITMoveEncoding2(t *testing.T) {
}
func testDspITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(dspCfgIn.DataDbCfg().DataDbType,
dspCfgIn.DataDbCfg().DataDbHost, dspCfgIn.DataDbCfg().DataDbPort,
dspCfgIn.DataDbCfg().DataDbName, dspCfgIn.DataDbCfg().DataDbUser,
dspCfgIn.DataDbCfg().DataDbPass, dspCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(dspCfgIn.DataDbCfg().Type,
dspCfgIn.DataDbCfg().Host, dspCfgIn.DataDbCfg().Port,
dspCfgIn.DataDbCfg().Name, dspCfgIn.DataDbCfg().User,
dspCfgIn.DataDbCfg().Password, dspCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), dspCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(dspCfgOut.DataDbCfg().DataDbType,
dspCfgOut.DataDbCfg().DataDbHost, dspCfgOut.DataDbCfg().DataDbPort,
dspCfgOut.DataDbCfg().DataDbName, dspCfgOut.DataDbCfg().DataDbUser,
dspCfgOut.DataDbCfg().DataDbPass, dspCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(dspCfgOut.DataDbCfg().Type,
dspCfgOut.DataDbCfg().Host, dspCfgOut.DataDbCfg().Port,
dspCfgOut.DataDbCfg().Name, dspCfgOut.DataDbCfg().User,
dspCfgOut.DataDbCfg().Password, dspCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), dspCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/filters_it_test.go
View File

@@ -100,18 +100,18 @@ func testFltrStart(testName, action string, t *testing.T) {
}
func testFltrITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(fltrCfgIn.DataDbCfg().DataDbType,
fltrCfgIn.DataDbCfg().DataDbHost, fltrCfgIn.DataDbCfg().DataDbPort,
fltrCfgIn.DataDbCfg().DataDbName, fltrCfgIn.DataDbCfg().DataDbUser,
fltrCfgIn.DataDbCfg().DataDbPass, fltrCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(fltrCfgIn.DataDbCfg().Type,
fltrCfgIn.DataDbCfg().Host, fltrCfgIn.DataDbCfg().Port,
fltrCfgIn.DataDbCfg().Name, fltrCfgIn.DataDbCfg().User,
fltrCfgIn.DataDbCfg().Password, fltrCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), fltrCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(fltrCfgOut.DataDbCfg().DataDbType,
fltrCfgOut.DataDbCfg().DataDbHost, fltrCfgOut.DataDbCfg().DataDbPort,
fltrCfgOut.DataDbCfg().DataDbName, fltrCfgOut.DataDbCfg().DataDbUser,
fltrCfgOut.DataDbCfg().DataDbPass, fltrCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(fltrCfgOut.DataDbCfg().Type,
fltrCfgOut.DataDbCfg().Host, fltrCfgOut.DataDbCfg().Port,
fltrCfgOut.DataDbCfg().Name, fltrCfgOut.DataDbCfg().User,
fltrCfgOut.DataDbCfg().Password, fltrCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), fltrCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/load_ids_it_test.go
View File

@@ -74,18 +74,18 @@ func testLoadIdsStart(testName string, t *testing.T) {
}
func testLoadIdsITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(loadCfgIn.DataDbCfg().DataDbType,
loadCfgIn.DataDbCfg().DataDbHost, loadCfgIn.DataDbCfg().DataDbPort,
loadCfgIn.DataDbCfg().DataDbName, loadCfgIn.DataDbCfg().DataDbUser,
loadCfgIn.DataDbCfg().DataDbPass, loadCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(loadCfgIn.DataDbCfg().Type,
loadCfgIn.DataDbCfg().Host, loadCfgIn.DataDbCfg().Port,
loadCfgIn.DataDbCfg().Name, loadCfgIn.DataDbCfg().User,
loadCfgIn.DataDbCfg().Password, loadCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), loadCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(loadCfgOut.DataDbCfg().DataDbType,
loadCfgOut.DataDbCfg().DataDbHost, loadCfgOut.DataDbCfg().DataDbPort,
loadCfgOut.DataDbCfg().DataDbName, loadCfgOut.DataDbCfg().DataDbUser,
loadCfgOut.DataDbCfg().DataDbPass, loadCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(loadCfgOut.DataDbCfg().Type,
loadCfgOut.DataDbCfg().Host, loadCfgOut.DataDbCfg().Port,
loadCfgOut.DataDbCfg().Name, loadCfgOut.DataDbCfg().User,
loadCfgOut.DataDbCfg().Password, loadCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), loadCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/rateprofiles_it_test.go
View File

@@ -123,18 +123,18 @@ func TestRatePrfITMoveEncoding2(t *testing.T) {
}
func testRatePrfITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(ratePrfCfgIn.DataDbCfg().DataDbType,
ratePrfCfgIn.DataDbCfg().DataDbHost, ratePrfCfgIn.DataDbCfg().DataDbPort,
ratePrfCfgIn.DataDbCfg().DataDbName, ratePrfCfgIn.DataDbCfg().DataDbUser,
ratePrfCfgIn.DataDbCfg().DataDbPass, ratePrfCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(ratePrfCfgIn.DataDbCfg().Type,
ratePrfCfgIn.DataDbCfg().Host, ratePrfCfgIn.DataDbCfg().Port,
ratePrfCfgIn.DataDbCfg().Name, ratePrfCfgIn.DataDbCfg().User,
ratePrfCfgIn.DataDbCfg().Password, ratePrfCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), ratePrfCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(ratePrfCfgOut.DataDbCfg().DataDbType,
ratePrfCfgOut.DataDbCfg().DataDbHost, ratePrfCfgOut.DataDbCfg().DataDbPort,
ratePrfCfgOut.DataDbCfg().DataDbName, ratePrfCfgOut.DataDbCfg().DataDbUser,
ratePrfCfgOut.DataDbCfg().DataDbPass, ratePrfCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(ratePrfCfgOut.DataDbCfg().Type,
ratePrfCfgOut.DataDbCfg().Host, ratePrfCfgOut.DataDbCfg().Port,
ratePrfCfgOut.DataDbCfg().Name, ratePrfCfgOut.DataDbCfg().User,
ratePrfCfgOut.DataDbCfg().Password, ratePrfCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), ratePrfCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/rating_plan_it_test.go
View File

@@ -123,18 +123,18 @@ func TestRatingPlanITMoveEncoding2(t *testing.T) {
}
func testRtPlITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(rtplCfgIn.DataDbCfg().DataDbType,
rtplCfgIn.DataDbCfg().DataDbHost, rtplCfgIn.DataDbCfg().DataDbPort,
rtplCfgIn.DataDbCfg().DataDbName, rtplCfgIn.DataDbCfg().DataDbUser,
rtplCfgIn.DataDbCfg().DataDbPass, rtplCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(rtplCfgIn.DataDbCfg().Type,
rtplCfgIn.DataDbCfg().Host, rtplCfgIn.DataDbCfg().Port,
rtplCfgIn.DataDbCfg().Name, rtplCfgIn.DataDbCfg().User,
rtplCfgIn.DataDbCfg().Password, rtplCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), ratePrfCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(rtplCfgOut.DataDbCfg().DataDbType,
rtplCfgOut.DataDbCfg().DataDbHost, rtplCfgOut.DataDbCfg().DataDbPort,
rtplCfgOut.DataDbCfg().DataDbName, rtplCfgOut.DataDbCfg().DataDbUser,
rtplCfgOut.DataDbCfg().DataDbPass, rtplCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(rtplCfgOut.DataDbCfg().Type,
rtplCfgOut.DataDbCfg().Host, rtplCfgOut.DataDbCfg().Port,
rtplCfgOut.DataDbCfg().Name, rtplCfgOut.DataDbCfg().User,
rtplCfgOut.DataDbCfg().Password, rtplCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), ratePrfCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/rating_profile_it_test.go
View File

@@ -124,18 +124,18 @@ func TestRatingProfileITMoveEncoding2(t *testing.T) {
}
func testRtPrfITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(rtprflCfgIn.DataDbCfg().DataDbType,
rtprflCfgIn.DataDbCfg().DataDbHost, rtprflCfgIn.DataDbCfg().DataDbPort,
rtprflCfgIn.DataDbCfg().DataDbName, rtprflCfgIn.DataDbCfg().DataDbUser,
rtprflCfgIn.DataDbCfg().DataDbPass, rtprflCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(rtprflCfgIn.DataDbCfg().Type,
rtprflCfgIn.DataDbCfg().Host, rtprflCfgIn.DataDbCfg().Port,
rtprflCfgIn.DataDbCfg().Name, rtprflCfgIn.DataDbCfg().User,
rtprflCfgIn.DataDbCfg().Password, rtprflCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), rtprflCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(rtprflCfgOut.DataDbCfg().DataDbType,
rtprflCfgOut.DataDbCfg().DataDbHost, rtprflCfgOut.DataDbCfg().DataDbPort,
rtprflCfgOut.DataDbCfg().DataDbName, rtprflCfgOut.DataDbCfg().DataDbUser,
rtprflCfgOut.DataDbCfg().DataDbPass, rtprflCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(rtprflCfgOut.DataDbCfg().Type,
rtprflCfgOut.DataDbCfg().Host, rtprflCfgOut.DataDbCfg().Port,
rtprflCfgOut.DataDbCfg().Name, rtprflCfgOut.DataDbCfg().User,
rtprflCfgOut.DataDbCfg().Password, rtprflCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), rtplCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/resource_it_test.go
View File

@@ -124,18 +124,18 @@ func TestResourceITMoveEncoding2(t *testing.T) {
}
func testResITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(resCfgIn.DataDbCfg().DataDbType,
resCfgIn.DataDbCfg().DataDbHost, resCfgIn.DataDbCfg().DataDbPort,
resCfgIn.DataDbCfg().DataDbName, resCfgIn.DataDbCfg().DataDbUser,
resCfgIn.DataDbCfg().DataDbPass, resCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(resCfgIn.DataDbCfg().Type,
resCfgIn.DataDbCfg().Host, resCfgIn.DataDbCfg().Port,
resCfgIn.DataDbCfg().Name, resCfgIn.DataDbCfg().User,
resCfgIn.DataDbCfg().Password, resCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), resCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(resCfgOut.DataDbCfg().DataDbType,
resCfgOut.DataDbCfg().DataDbHost, resCfgOut.DataDbCfg().DataDbPort,
resCfgOut.DataDbCfg().DataDbName, resCfgOut.DataDbCfg().DataDbUser,
resCfgOut.DataDbCfg().DataDbPass, resCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(resCfgOut.DataDbCfg().Type,
resCfgOut.DataDbCfg().Host, resCfgOut.DataDbCfg().Port,
resCfgOut.DataDbCfg().Name, resCfgOut.DataDbCfg().User,
resCfgOut.DataDbCfg().Password, resCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), resCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/routes_it_test.go
View File

@@ -123,18 +123,18 @@ func TestSuppliersITMoveEncoding2(t *testing.T) {
}
func testSupITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(supCfgIn.DataDbCfg().DataDbType,
supCfgIn.DataDbCfg().DataDbHost, supCfgIn.DataDbCfg().DataDbPort,
supCfgIn.DataDbCfg().DataDbName, supCfgIn.DataDbCfg().DataDbUser,
supCfgIn.DataDbCfg().DataDbPass, supCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(supCfgIn.DataDbCfg().Type,
supCfgIn.DataDbCfg().Host, supCfgIn.DataDbCfg().Port,
supCfgIn.DataDbCfg().Name, supCfgIn.DataDbCfg().User,
supCfgIn.DataDbCfg().Password, supCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), supCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(supCfgOut.DataDbCfg().DataDbType,
supCfgOut.DataDbCfg().DataDbHost, supCfgOut.DataDbCfg().DataDbPort,
supCfgOut.DataDbCfg().DataDbName, supCfgOut.DataDbCfg().DataDbUser,
supCfgOut.DataDbCfg().DataDbPass, supCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(supCfgOut.DataDbCfg().Type,
supCfgOut.DataDbCfg().Host, supCfgOut.DataDbCfg().Port,
supCfgOut.DataDbCfg().Name, supCfgOut.DataDbCfg().User,
supCfgOut.DataDbCfg().Password, supCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), supCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/sharedgroup_it_test.go
View File

@@ -142,18 +142,18 @@ func TestSharedGroupITMoveEncoding2(t *testing.T) {
}
func testShrGrpITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(shrGrpCfgIn.DataDbCfg().DataDbType,
shrGrpCfgIn.DataDbCfg().DataDbHost, shrGrpCfgIn.DataDbCfg().DataDbPort,
shrGrpCfgIn.DataDbCfg().DataDbName, shrGrpCfgIn.DataDbCfg().DataDbUser,
shrGrpCfgIn.DataDbCfg().DataDbPass, shrGrpCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(shrGrpCfgIn.DataDbCfg().Type,
shrGrpCfgIn.DataDbCfg().Host, shrGrpCfgIn.DataDbCfg().Port,
shrGrpCfgIn.DataDbCfg().Name, shrGrpCfgIn.DataDbCfg().User,
shrGrpCfgIn.DataDbCfg().Password, shrGrpCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), shrGrpCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(shrGrpCfgOut.DataDbCfg().DataDbType,
shrGrpCfgOut.DataDbCfg().DataDbHost, shrGrpCfgOut.DataDbCfg().DataDbPort,
shrGrpCfgOut.DataDbCfg().DataDbName, shrGrpCfgOut.DataDbCfg().DataDbUser,
shrGrpCfgOut.DataDbCfg().DataDbPass, shrGrpCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(shrGrpCfgOut.DataDbCfg().Type,
shrGrpCfgOut.DataDbCfg().Host, shrGrpCfgOut.DataDbCfg().Port,
shrGrpCfgOut.DataDbCfg().Name, shrGrpCfgOut.DataDbCfg().User,
shrGrpCfgOut.DataDbCfg().Password, shrGrpCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), shrGrpCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/stats_it_test.go
View File

@@ -106,18 +106,18 @@ func TestStatsQueueITMove(t *testing.T) {
}
func testStsITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(stsCfgIn.DataDbCfg().DataDbType,
stsCfgIn.DataDbCfg().DataDbHost, stsCfgIn.DataDbCfg().DataDbPort,
stsCfgIn.DataDbCfg().DataDbName, stsCfgIn.DataDbCfg().DataDbUser,
stsCfgIn.DataDbCfg().DataDbPass, stsCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(stsCfgIn.DataDbCfg().Type,
stsCfgIn.DataDbCfg().Host, stsCfgIn.DataDbCfg().Port,
stsCfgIn.DataDbCfg().Name, stsCfgIn.DataDbCfg().User,
stsCfgIn.DataDbCfg().Password, stsCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), stsCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(stsCfgOut.DataDbCfg().DataDbType,
stsCfgOut.DataDbCfg().DataDbHost, stsCfgOut.DataDbCfg().DataDbPort,
stsCfgOut.DataDbCfg().DataDbName, stsCfgOut.DataDbCfg().DataDbUser,
stsCfgOut.DataDbCfg().DataDbPass, stsCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(stsCfgOut.DataDbCfg().Type,
stsCfgOut.DataDbCfg().Host, stsCfgOut.DataDbCfg().Port,
stsCfgOut.DataDbCfg().Name, stsCfgOut.DataDbCfg().User,
stsCfgOut.DataDbCfg().Password, stsCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), stsCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/thresholds_it_test.go
View File

@@ -143,18 +143,18 @@ func TestThresholdsITMoveEncoding2(t *testing.T) {
}
func testTrsITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(trsCfgIn.DataDbCfg().DataDbType,
trsCfgIn.DataDbCfg().DataDbHost, trsCfgIn.DataDbCfg().DataDbPort,
trsCfgIn.DataDbCfg().DataDbName, trsCfgIn.DataDbCfg().DataDbUser,
trsCfgIn.DataDbCfg().DataDbPass, trsCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(trsCfgIn.DataDbCfg().Type,
trsCfgIn.DataDbCfg().Host, trsCfgIn.DataDbCfg().Port,
trsCfgIn.DataDbCfg().Name, trsCfgIn.DataDbCfg().User,
trsCfgIn.DataDbCfg().Password, trsCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), trsCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(trsCfgOut.DataDbCfg().DataDbType,
trsCfgOut.DataDbCfg().DataDbHost, trsCfgOut.DataDbCfg().DataDbPort,
trsCfgOut.DataDbCfg().DataDbName, trsCfgOut.DataDbCfg().DataDbUser,
trsCfgOut.DataDbCfg().DataDbPass, trsCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(trsCfgOut.DataDbCfg().Type,
trsCfgOut.DataDbCfg().Host, trsCfgOut.DataDbCfg().Port,
trsCfgOut.DataDbCfg().Name, trsCfgOut.DataDbCfg().User,
trsCfgOut.DataDbCfg().Password, trsCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), trsCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

16
migrator/user_it_test.go
View File

@@ -76,18 +76,18 @@ func testUsrStart(testName, inPath, outPath string, t *testing.T) {
}
func testUsrITConnect(t *testing.T) {
dataDBIn, err := NewMigratorDataDB(usrCfgIn.DataDbCfg().DataDbType,
usrCfgIn.DataDbCfg().DataDbHost, usrCfgIn.DataDbCfg().DataDbPort,
usrCfgIn.DataDbCfg().DataDbName, usrCfgIn.DataDbCfg().DataDbUser,
usrCfgIn.DataDbCfg().DataDbPass, usrCfgIn.GeneralCfg().DBDataEncoding,
dataDBIn, err := NewMigratorDataDB(usrCfgIn.DataDbCfg().Type,
usrCfgIn.DataDbCfg().Host, usrCfgIn.DataDbCfg().Port,
usrCfgIn.DataDbCfg().Name, usrCfgIn.DataDbCfg().User,
usrCfgIn.DataDbCfg().Password, usrCfgIn.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), usrCfgIn.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)
}
dataDBOut, err := NewMigratorDataDB(usrCfgOut.DataDbCfg().DataDbType,
usrCfgOut.DataDbCfg().DataDbHost, usrCfgOut.DataDbCfg().DataDbPort,
usrCfgOut.DataDbCfg().DataDbName, usrCfgOut.DataDbCfg().DataDbUser,
usrCfgOut.DataDbCfg().DataDbPass, usrCfgOut.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(usrCfgOut.DataDbCfg().Type,
usrCfgOut.DataDbCfg().Host, usrCfgOut.DataDbCfg().Port,
usrCfgOut.DataDbCfg().Name, usrCfgOut.DataDbCfg().User,
usrCfgOut.DataDbCfg().Password, usrCfgOut.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), usrCfgOut.DataDbCfg().Opts)
if err != nil {
log.Fatal(err)

10
migrator/versions_it_test.go
View File

@@ -64,7 +64,7 @@ func TestVersionITMongo(t *testing.T) {
if err != nil {
t.Fatal(err)
}
vrsCfg.StorDbCfg().Name = vrsCfg.DataDbCfg().DataDbName
vrsCfg.StorDbCfg().Name = vrsCfg.DataDbCfg().Name
vrsSameOutDB = true
for _, stest := range sTestsVrsIT {
t.Run("TestVrsionITMigrateMongo", stest)
@@ -73,10 +73,10 @@ func TestVersionITMongo(t *testing.T) {
}
func testVrsITConnect(t *testing.T) {
dataDBOut, err := NewMigratorDataDB(vrsCfg.DataDbCfg().DataDbType,
vrsCfg.DataDbCfg().DataDbHost, vrsCfg.DataDbCfg().DataDbPort,
vrsCfg.DataDbCfg().DataDbName, vrsCfg.DataDbCfg().DataDbUser,
vrsCfg.DataDbCfg().DataDbPass, vrsCfg.GeneralCfg().DBDataEncoding,
dataDBOut, err := NewMigratorDataDB(vrsCfg.DataDbCfg().Type,
vrsCfg.DataDbCfg().Host, vrsCfg.DataDbCfg().Port,
vrsCfg.DataDbCfg().Name, vrsCfg.DataDbCfg().User,
vrsCfg.DataDbCfg().Password, vrsCfg.GeneralCfg().DBDataEncoding,
config.CgrConfig().CacheCfg(), vrsCfg.DataDbCfg().Opts)
if err != nil {
t.Fatal(err)