Function sql_query

modules/sqlops/sqlops_db.c:427–471

int sql_query(struct db_url *url, struct sip_msg *msg, str *query,
											pvname_list_t* dest,  int one_row)
{
	db_res_t* db_res = NULL;

	if(query==NULL)
	{
		LM_ERR("bad parameter\n");
		return -1;
	}

	if(url->dbf.raw_query( url->hdl, query, &db_res)!=0)
	{
		const str *t = url->hdl&&url->hdl->table&&url->hdl->table->s
			? url->hdl->table : 0;
		LM_ERR("raw_query failed: db%d(%.*s) %.*s...\n",
		  url->idx, t?t->len:0, t?t->s:"", query->len > 40 ? 40 : query->len,
		  query->s);
		return -1;
	}

	if(db_res==NULL || RES_ROW_N(db_res)<=0 || RES_COL_N(db_res)<=0)
	{
		LM_DBG("no result after query\n");
		db_close_query( url, db_res );
		return 1;
	}

	if (one_row) {
		if (db_query_print_one_result(msg, db_res, dest) != 0) {
			LM_ERR("failed to print ONE result\n");
			db_close_query( url, db_res );
			return -1;
		}
	} else {
		if (db_query_print_results(msg, db_res, dest) != 0) {
			LM_ERR("failed to print results\n");
			db_close_query( url, db_res );
			return -1;
		}
	}

	db_close_query( url, db_res );
	return 0;
}


static inline int _json_to_cols(cJSON *Jcols, db_key_t** _c)