replacing non-meta constants for storage types

This commit is contained in:
gezimbll
2023-03-02 10:50:58 -05:00
committed by Dan Christian Bogos
parent c5acb15d4a
commit 7dcbd09a1f
41 changed files with 164 additions and 139 deletions

View File

@@ -82,7 +82,7 @@ func (mgSQL *migratorSQL) setV1CDR(v1Cdr *v1Cdrs) (err error) {
func (mgSQL *migratorSQL) renameV1SMCosts() (err error) {
qry := "RENAME TABLE sm_costs TO session_costs;"
if mgSQL.StorDB().GetStorageType() == utils.POSTGRES {
if mgSQL.StorDB().GetStorageType() == utils.MetaPostgres {
qry = "ALTER TABLE sm_costs RENAME TO session_costs"
}
if _, err := mgSQL.sqlStorage.Db.Exec(qry); err != nil {
@@ -93,7 +93,7 @@ func (mgSQL *migratorSQL) renameV1SMCosts() (err error) {
func (mgSQL *migratorSQL) createV1SMCosts() (err error) {
qry := fmt.Sprint("CREATE TABLE sm_costs ( id int(11) NOT NULL AUTO_INCREMENT, cgrid varchar(40) NOT NULL, run_id varchar(64) NOT NULL, origin_host varchar(64) NOT NULL, origin_id varchar(128) NOT NULL, cost_source varchar(64) NOT NULL, `usage` BIGINT NOT NULL, cost_details MEDIUMTEXT, created_at TIMESTAMP NULL,deleted_at TIMESTAMP NULL, PRIMARY KEY (`id`),UNIQUE KEY costid (cgrid, run_id),KEY origin_idx (origin_host, origin_id),KEY run_origin_idx (run_id, origin_id),KEY deleted_at_idx (deleted_at));")
if mgSQL.StorDB().GetStorageType() == utils.POSTGRES {
if mgSQL.StorDB().GetStorageType() == utils.MetaPostgres {
qry = `
CREATE TABLE sm_costs (
id SERIAL PRIMARY KEY,