Function w_cache_raw_query

core_cmds.c:1376–1446

}

static int w_cache_raw_query(struct sip_msg *msg, str *id, str *raw_query_s,
				pvname_list_t *avp_list)
{
	cdb_raw_entry **cdb_reply = NULL;
	int num_cols=0,i,j;
	int num_rows=0;
	pvname_list_t *it;
	int_str avp_val;
	int_str avp_name;
	unsigned short avp_type;
	int ret;

	if (!raw_query_s || !raw_query_s->s || !raw_query_s->len) {
		LM_ERR("raw query cannot be empty\n");
		return E_UNSPEC;
	}

	if (!avp_list)
		return cachedb_raw_query(id, raw_query_s, NULL,0,NULL);

	for (it=avp_list;it;it=it->next)
		num_cols++;

	LM_DBG("The query expects %d fields per result\n", num_cols);

	ret = cachedb_raw_query(id, raw_query_s, &cdb_reply, num_cols, &num_rows);
	if (ret >= 0 && num_cols > 0) {
		for (i=num_rows-1; i>=0;i--) {
			it=avp_list;
			for (j=0;j < num_cols;j++) {
				avp_type = 0;
				if (pv_get_avp_name(msg,&it->sname.pvp,&avp_name.n,
					&avp_type) != 0) {
					LM_ERR("cannot get avp name [%d/%d]\n",i,j);
					goto next_avp;
				}

				switch (cdb_reply[i][j].type) {
					case CDB_INT32:
						avp_val.n = cdb_reply[i][j].val.n;
						break;
					case CDB_STR:
						avp_type |= AVP_VAL_STR;
						avp_val.s = cdb_reply[i][j].val.s;
						break;
					case CDB_NULL:
						avp_type |= AVP_VAL_NULL;
						avp_val.s = cdb_reply[i][j].val.s;
						break;
					default:
						LM_WARN("Unknown type %d\n",cdb_reply[i][j].type);
						goto next_avp;
				}
				if (add_avp(avp_type,avp_name.n,avp_val) != 0) {
					LM_ERR("Unable to add AVP\n");
					free_raw_fetch(cdb_reply,num_cols,num_rows);
					return -1;
				}