db_matrix.c

Go to the documentation of this file.

#include "db_matrix.h"

/* database variables */
/* TODO assign read-write or read-only URI, introduce a parameter in XML */

//extern str matrix_db_url;
db1_con_t * matrix_dbh = NULL;
db_func_t matrix_dbf;

str matrix_table = str_init("matrix");

/* column names */
str matrix_first_col = str_init("first");
str matrix_second_col = str_init("second");
str matrix_res_col = str_init("res");

/* table version */
const unsigned int matrix_version = 1;


/*
 * Closes the DB connection.
 */
void matrix_db_close(void) {
        if (matrix_dbh) {
                matrix_dbf.close(matrix_dbh);
                matrix_dbh = NULL;
        }
}


int matrix_db_init(void) {
        if (!matrix_db_url.s || !matrix_db_url.len) {
                LM_ERR("you have to set the db_url module parameter.\n");
                return -1;
        }
        if (db_bind_mod(&matrix_db_url, &matrix_dbf) < 0) {
                LM_ERR("can't bind database module.\n");
                return -1;
        }
        if ((matrix_dbh = matrix_dbf.init(&matrix_db_url)) == NULL) {
                LM_ERR("can't connect to database.\n");
                return -1;
        }
        if (
        (db_check_table_version(&matrix_dbf, matrix_dbh, &matrix_table, matrix_version) < 0)
        ) {
                LM_ERR("during table version check.\n");
                matrix_db_close();
                return -1;
        }
        matrix_db_close();
        return 0;
}


int matrix_db_open(void) {
        if (matrix_dbh) {
                matrix_dbf.close(matrix_dbh);
        }
        if ((matrix_dbh = matrix_dbf.init(&matrix_db_url)) == NULL) {
                LM_ERR("can't connect to database.\n");
                return -1;
        }
        return 0;
}


void matrix_db_vars(void) {
        if (matrix_db_url.s) matrix_db_url.len = strlen(matrix_db_url.s);
        matrix_table.len = strlen(matrix_table.s);
        matrix_first_col.len = strlen(matrix_first_col.s);
        matrix_second_col.len = strlen(matrix_second_col.s);
        matrix_res_col.len = strlen(matrix_res_col.s);
}