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

Added DSN params for sql exporter and storDB

Browse Source
This commit is contained in:
porosnicuadrian
2022-01-12 11:33:09 +02:00
committed by Dan Christian Bogos
parent e6ce4f8563
commit f204d474bd
14 changed files with 101 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
engine/storage_utils.go
View File

@@ -106,6 +106,7 @@ func NewStorDBConn(dbType, host, port, name, user, pass, marshaler string,
int(maxConn), int(maxIdleConn), int(connMaxLifetime))
case utils.MySQL:
var maxConn, maxIdleConn, connMaxLifetime int64
if maxConn, err = utils.IfaceAsTInt64(opts[utils.SQLMaxOpenConnsCfg]); err != nil {
return
}
@@ -115,8 +116,14 @@ func NewStorDBConn(dbType, host, port, name, user, pass, marshaler string,
if connMaxLifetime, err = utils.IfaceAsTInt64(opts[utils.SQLConnMaxLifetimeCfg]); err != nil {
return
}
optsDB := make(map[string]string)
if optsNew, has := opts[utils.MYSQLDSNParams]; has {
for key, val := range optsNew.(map[string]interface{}) {
optsDB[key] = utils.IfaceAsString(val)
}
}
db, err = NewMySQLStorage(host, port, name, user, pass, int(maxConn), int(maxIdleConn),
int(connMaxLifetime), utils.IfaceAsString(opts[utils.MysqlLocation]))
int(connMaxLifetime), utils.IfaceAsString(opts[utils.MysqlLocation]), optsDB)
case utils.Internal:
db = NewInternalDB(stringIndexedFields, prefixIndexedFields, false, itmsCfg)
default: