mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
fix for storage interface nil
This commit is contained in:
@@ -21,6 +21,7 @@ package engine
|
||||
import (
|
||||
"database/sql"
|
||||
"fmt"
|
||||
|
||||
_ "github.com/go-sql-driver/mysql"
|
||||
)
|
||||
|
||||
@@ -33,8 +34,8 @@ func NewMySQLStorage(host, port, name, user, password string) (Storage, error) {
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if err := db.Ping(); err != nil {
|
||||
/*if err := db.Ping(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
}*/
|
||||
return &MySQLStorage{&SQLStorage{db}}, nil
|
||||
}
|
||||
|
||||
@@ -20,8 +20,9 @@ package engine
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
"strconv"
|
||||
|
||||
"github.com/cgrates/cgrates/utils"
|
||||
)
|
||||
|
||||
// Various helpers to deal with database
|
||||
@@ -100,24 +101,20 @@ func ConfigureLogStorage(db_type, host, port, name, user, pass, marshaler string
|
||||
host += ":" + port
|
||||
}
|
||||
d, err = NewRedisStorage(host, db_nb, pass, marshaler)
|
||||
db = d.(LogStorage)
|
||||
case utils.MONGO:
|
||||
d, err = NewMongoStorage(host, port, name, user, pass)
|
||||
db = d.(LogStorage)
|
||||
case utils.POSTGRES:
|
||||
d, err = NewPostgresStorage(host, port, name, user, pass)
|
||||
db = d.(LogStorage)
|
||||
*/
|
||||
case utils.MYSQL:
|
||||
d, err = NewMySQLStorage(host, port, name, user, pass)
|
||||
db = d.(LogStorage)
|
||||
default:
|
||||
err = errors.New("unknown db")
|
||||
}
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
return db, nil
|
||||
return db.(LogStorage), nil
|
||||
}
|
||||
|
||||
func ConfigureLoadStorage(db_type, host, port, name, user, pass, marshaler string) (db LoadStorage, err error) {
|
||||
|
||||
Reference in New Issue
Block a user