Function db_query_print_results

modules/sqlops/sqlops_db.c:1108–1227

int db_query_print_results(struct sip_msg *msg, const db_res_t *db_res,
								pvname_list_t *dest)
{
	int_str avp_val;
	int_str avp_name;
	unsigned short avp_type;
	int i, j;
	pvname_list_t* crt;

	LM_DBG("rows [%d]\n", RES_ROW_N(db_res));
	/* reverse order of rows so that first row get's in front of avp list */
	for(i = RES_ROW_N(db_res)-1; i >= 0; i--)
	{
		LM_DBG("row [%d]\n", i);
		crt = dest;
		for(j = 0; j < RES_COL_N(db_res); j++)
		{
			avp_type = 0;
			if(crt==NULL)
			{
				avp_name.s.s = int2str(j+1, &avp_name.s.len);
				avp_name.n = get_avp_id(&avp_name.s);
				if (avp_name.n < 0) {
					LM_ERR("cannot convert avp %d\n", j+1);
					goto next_avp;
				}
			} else {
				if(pv_get_avp_name(msg, &crt->sname.pvp, &avp_name.n,
							&avp_type)!=0)
				{
					LM_ERR("cant get avp name [%d/%d]\n", i, j);
					goto next_avp;
				}
			}
			if(RES_ROWS(db_res)[i].values[j].nul) {
				avp_type |= AVP_VAL_STR;
				/* keep the NULL value in sync with str_null as
				 * defined in pvar.c !! */
				avp_val.s.s = "<null>";
				avp_val.s.len = 6;
			} else {
				switch(RES_ROWS(db_res)[i].values[j].type) {
				case DB_STRING:
					avp_type |= AVP_VAL_STR;
					avp_val.s.s=
						(char*)RES_ROWS(db_res)[i].values[j].val.string_val;
					avp_val.s.len=strlen(avp_val.s.s);
					if(avp_val.s.len<0)
						goto next_avp;
				break;
				case DB_STR:
					avp_type |= AVP_VAL_STR;
					avp_val.s.len=
						RES_ROWS(db_res)[i].values[j].val.str_val.len;
					avp_val.s.s=
						(char*)RES_ROWS(db_res)[i].values[j].val.str_val.s;
					if(avp_val.s.len<0)
						goto next_avp;