Function cc_load_db_data

modules/call_center/cc_db.c:607–839

int cc_load_db_data( struct cc_data *data)
{
	db_key_t columns[13];
	db_res_t* res;
	db_row_t* row;
	int i, j;
	str id,skill,cid;
	unsigned int priority, logstate, wrapup, wrapup_end_time;
	unsigned int diss_hangup, diss_ewt_th, diss_qsize_th, diss_onhold_th;
	str messages[MAX_AUDIO];

	cc_dbf.use_table( cc_db_handle, &cc_flow_table_name);

	columns[0]  = &ccf_flowid_column;
	columns[1]  = &ccf_priority_column;
	columns[2]  = &ccf_skill_column;
	columns[3]  = &ccf_cid_column;
	columns[4]  = &ccf_max_wrapup_column;
	columns[5]  = &ccf_dissuading_hangup_column;
	columns[6]  = &ccf_dissuading_ewt_th_column;
	columns[7]  = &ccf_dissuading_qsize_th_column;
	columns[8]  = &ccf_dissuading_onhold_th_column;
	columns[9]  = &ccf_m_welcome_column;
	columns[10] = &ccf_m_queue_column;
	columns[11] = &ccf_m_dissuading_column;
	columns[12] = &ccf_m_flow_id_column;

	if (0/*DB_CAPABILITY(cc_dbf, DB_CAP_FETCH))*/) {
		if ( cc_dbf.query( cc_db_handle, 0, 0, 0, columns, 0, 13, 0, 0 ) < 0) {
			LM_ERR("DB query failed\n");
			return -1;
		}
		if(cc_dbf.fetch_result( cc_db_handle, &res, CC_FETCH_ROWS)<0) {
			LM_ERR("Error fetching rows\n");
			return -1;
		}
	} else {
		if ( cc_dbf.query( cc_db_handle, 0, 0, 0, columns, 0, 13, 0, &res)<0) {
			LM_ERR("DB query failed\n");
			return -1;
		}
	}

	LM_DBG("%d records found in %.*s\n",
		RES_ROW_N(res), cc_flow_table_name.len,cc_flow_table_name.s );

	do {
		for(i=0; i < RES_ROW_N(res); i++) {
			row = RES_ROWS(res) + i;
			/* flowID column */
			check_val( ROW_VALUES(row), DB_STRING, 1, 1, "flowid");
			id.s = (char*)VAL_STRING(ROW_VALUES(row));
			id.len = strlen(id.s);
			/* PRIORITY column */
			check_val( ROW_VALUES(row)+1, DB_INT, 1, 0, "priority");
			priority = VAL_INT(ROW_VALUES(row)+1);
			/* SKILL column */
			check_val( ROW_VALUES(row)+2, DB_STRING, 1, 1, "skill");