Function dp_load_db

modules/dialplan/dp_db.c:246–444

load rules from DB*/

/*load rules from DB*/
int dp_load_db(dp_connection_list_p dp_conn, int initial)
{
	int i, nr_rows;
	db_res_t * res = 0;
	db_val_t * values;
	db_row_t * rows;
	db_key_t query_cols[DP_TABLE_COL_NO] = {
		&dpid_column,		&pr_column,
		&match_op_column,	&match_exp_column,	&match_flags_column,
		&subst_exp_column,	&repl_exp_column,	&attrs_column,	&timerec_column };
	db_key_t order = &pr_column;
	/* disabled condition */
	db_key_t cond_cols[1] = { &disabled_column };
	db_val_t cond_val[1];

	dpl_node_t *rule;
	int no_rows = 10;
	int loaded_rl=0, discarded_rl=0;


	lock_start_write( dp_conn->ref_lock );

	if( dp_conn->crt_index != dp_conn->next_index){
		LM_WARN("a load command already in-progress for partition <%.*s>, "
			"aborting reload...\n", dp_conn->partition.len, dp_conn->partition.s);
		lock_stop_write( dp_conn->ref_lock );
		return 0;
	}

	dp_conn->next_index = dp_conn->crt_index == 0 ? 1 : 0;

	lock_stop_write( dp_conn->ref_lock );

	sr_add_report( dp_srg, STR2CI(dp_conn->partition),
		CHAR_INT("starting DB data loading"), 0);
	if (initial)
		sr_set_status( dp_srg,  STR2CI(dp_conn->partition),
			SR_STATUS_LOADING_DATA, CHAR_INT("startup data loading"), 0);
	else 
		sr_set_status( dp_srg,  STR2CI(dp_conn->partition),
			SR_STATUS_RELOADING_DATA, CHAR_INT("data re-loading"), 0);

	if (dp_conn->dp_dbf.use_table(*dp_conn->dp_db_handle, &dp_conn->table_name) < 0){
		LM_ERR("error in use_table\n");
		goto err1;
	}

	VAL_TYPE(cond_val) = DB_INT;
	VAL_NULL(cond_val) = 0;
	VAL_INT(cond_val) = 0;

	if (DB_CAPABILITY(dp_conn->dp_dbf, DB_CAP_FETCH)) {
		if(dp_conn->dp_dbf.query(*dp_conn->dp_db_handle,cond_cols,
				0,cond_val,query_cols,1,
					DP_TABLE_COL_NO, order, 0) < 0){
			LM_ERR("failed to query database!\n");

			goto err1;