Database Functions

Collaboration diagram for Database Functions:

Functions
switch_core_db_t *	switch_core_db_open_file (const char *filename)
	Open a core db (SQLite) file. More...
switch_core_db_t *	switch_core_db_open_in_memory (const char *uri)
	Open a core db (SQLite) in-memory. More...
switch_status_t	switch_core_db_persistant_execute (switch_core_db_t *db, char *sql, uint32_t retries)
	Execute a sql stmt until it is accepted. More...
switch_status_t	switch_core_db_persistant_execute_trans (switch_core_db_t *db, char *sql, uint32_t retries)
void	switch_core_db_test_reactive (switch_core_db_t *db, char *test_sql, char *drop_sql, char *reactive_sql)
	perform a test query then perform a reactive query if the first one fails More...

Detailed Description

Function Documentation

switch_core_db_open_file()

switch_core_db_t* switch_core_db_open_file

(

const char *

filename

)

Open a core db (SQLite) file.

Parameters

filename

the path to the db file to open

Returns

the db handle

Definition at line 230 of file switch_core_db.c.

References db_pick_path(), path, SWITCH_CHANNEL_LOG, switch_core_db_close(), switch_core_db_connection_setup(), switch_core_db_errmsg(), switch_core_db_open(), SWITCH_FALSE, SWITCH_LOG_ERROR, and switch_log_printf().

Referenced by _switch_cache_db_get_db_handle().

{
        switch_core_db_t *db;
        char path[1024];
        int db_ret;

        db_pick_path(filename, path, sizeof(path));
        if ((db_ret = switch_core_db_open(path, &db)) != SQLITE_OK) {
                goto end;
        }
        if ((db_ret = switch_core_db_connection_setup(db, SWITCH_FALSE)) != SQLITE_OK) {
                goto end;
        }

end:
        if (db_ret != SQLITE_OK) {
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "SQL ERR [%s]\n", switch_core_db_errmsg(db));
                switch_core_db_close(db);
                db = NULL;
        }
        return db;
}

switch_core_db_open_in_memory()

switch_core_db_t* switch_core_db_open_in_memory

(

const char *

uri

)

Open a core db (SQLite) in-memory.

Parameters

uri	to the db to open

Returns

the db handle

Definition at line 253 of file switch_core_db.c.

References SWITCH_CHANNEL_LOG, switch_core_db_close(), switch_core_db_connection_setup(), switch_core_db_errmsg(), switch_core_db_open_v2(), SWITCH_LOG_ERROR, switch_log_printf(), and SWITCH_TRUE.

Referenced by _switch_cache_db_get_db_handle().

{
        switch_core_db_t *db;
        int db_ret;

        if ((db_ret = switch_core_db_open_v2(uri, &db)) != SQLITE_OK) {
                goto end;
        }
        if ((db_ret = switch_core_db_connection_setup(db, SWITCH_TRUE)) != SQLITE_OK) {
                goto end;
        }

end:
        if (db_ret != SQLITE_OK) {
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "SQL ERR [%s]\n", switch_core_db_errmsg(db));
                switch_core_db_close(db);
                db = NULL;
        }
        return db;
}

switch_core_db_persistant_execute()

switch_status_t switch_core_db_persistant_execute	(	switch_core_db_t *	db,
		char *	sql,
		uint32_t	retries
	)

Execute a sql stmt until it is accepted.

Parameters

db	the db handle
sql	the sql to execute
retries	the number of retries to use

Returns

SWITCH_STATUS_SUCCESS if successful

Definition at line 388 of file switch_core_db.c.

References switch_core_db_exec(), switch_core_db_free(), SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, and switch_yield.

{
        char *errmsg;
        switch_status_t status = SWITCH_STATUS_FALSE;
        uint8_t forever = 0;

        if (!retries) {
                forever = 1;
                retries = 1000;
        }

        while (retries > 0) {
                switch_core_db_exec(db, sql, NULL, NULL, &errmsg);
                if (errmsg) {
                        //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "SQL ERR [%s]\n", errmsg);
                        switch_core_db_free(errmsg);
                        switch_yield(100000);
                        retries--;
                        if (retries == 0 && forever) {
                                retries = 1000;
                                continue;
                        }
                } else {
                        status = SWITCH_STATUS_SUCCESS;
                        break;
                }
        }

        return status;
}

switch_core_db_persistant_execute_trans()

switch_status_t switch_core_db_persistant_execute_trans	(	switch_core_db_t *	db,
		char *	sql,
		uint32_t	retries
	)

Definition at line 317 of file switch_core_db.c.

References SWITCH_CHANNEL_LOG, switch_core_db_exec(), switch_core_db_free(), SWITCH_LOG_DEBUG, SWITCH_LOG_ERROR, switch_log_printf(), SWITCH_STATUS_FALSE, SWITCH_STATUS_SUCCESS, and switch_yield.

{
        char *errmsg;
        switch_status_t status = SWITCH_STATUS_FALSE;
        uint8_t forever = 0;
        unsigned begin_retries = 100;
        uint8_t again = 0;

        if (!retries) {
                forever = 1;
                retries = 1000;
        }

  again:

        while (begin_retries > 0) {
                again = 0;

                switch_core_db_exec(db, "BEGIN", NULL, NULL, &errmsg);

                if (errmsg) {
                        begin_retries--;
                        if (strstr(errmsg, "cannot start a transaction within a transaction")) {
                                again = 1;
                        } else {
                                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "SQL Retry [%s]\n", errmsg);
                        }
                        switch_core_db_free(errmsg);
                        errmsg = NULL;

                        if (again) {
                                switch_core_db_exec(db, "COMMIT", NULL, NULL, NULL);
                                goto again;
                        }

                        switch_yield(100000);

                        if (begin_retries == 0) {
                                goto done;
                        }
                } else {
                        break;
                }

        }

        while (retries > 0) {
                switch_core_db_exec(db, sql, NULL, NULL, &errmsg);
                if (errmsg) {
                        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "SQL ERR [%s]\n", errmsg);
                        switch_core_db_free(errmsg);
                        errmsg = NULL;
                        switch_yield(100000);
                        retries--;
                        if (retries == 0 && forever) {
                                retries = 1000;
                                continue;
                        }
                } else {
                        status = SWITCH_STATUS_SUCCESS;
                        break;
                }
        }

  done:

        switch_core_db_exec(db, "COMMIT", NULL, NULL, NULL);

        return status;
}

switch_core_db_test_reactive()

void switch_core_db_test_reactive	(	switch_core_db_t *	db,
		char *	test_sql,
		char *	drop_sql,
		char *	reactive_sql
	)

perform a test query then perform a reactive query if the first one fails

Parameters

db	the db handle
test_sql	the test sql
drop_sql	the drop sql
reactive_sql	the reactive sql

Definition at line 274 of file switch_core_db.c.

References runtime, SCF_AUTO_SCHEMAS, SCF_CLEAR_SQL, SWITCH_CHANNEL_LOG, switch_core_db_exec(), switch_core_db_free(), SWITCH_LOG_DEBUG, switch_log_printf(), and switch_test_flag.

{
        char *errmsg;

        if (!switch_test_flag((&runtime), SCF_CLEAR_SQL)) {
                return;
        }

        if (!switch_test_flag((&runtime), SCF_AUTO_SCHEMAS)) {
                switch_core_db_exec(db, test_sql, NULL, NULL, NULL);
                return;
        }


        if (db) {
                if (test_sql) {
                        switch_core_db_exec(db, test_sql, NULL, NULL, &errmsg);

                        if (errmsg) {
                                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "SQL ERR [%s]\n[%s]\nAuto Generating Table!\n", errmsg, test_sql);
                                switch_core_db_free(errmsg);
                                errmsg = NULL;
                                if (drop_sql) {
                                        switch_core_db_exec(db, drop_sql, NULL, NULL, &errmsg);
                                }
                                if (errmsg) {
                                        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "SQL ERR [%s]\n[%s]\n", errmsg, reactive_sql);
                                        switch_core_db_free(errmsg);
                                        errmsg = NULL;
                                }
                                switch_core_db_exec(db, reactive_sql, NULL, NULL, &errmsg);
                                if (errmsg) {
                                        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "SQL ERR [%s]\n[%s]\n", errmsg, reactive_sql);
                                        switch_core_db_free(errmsg);
                                        errmsg = NULL;
                                }
                        }
                }
        }

}