Method aggExecute

src/dsql/AggNodes.cpp:723–782

}

dsc* AvgAggNode::aggExecute(thread_db* tdbb, Request* request) const
{
	impure_value_ex* impure = request->getImpure<impure_value_ex>(impureOffset);

	if (!impure->vlux_count)
		return NULL;

	dsc temp;
	SINT64 i;
	double d;
	Decimal128 dec;
	Decimal64 d64;
	Int128 i128;

	impure_value_ex* impureTemp = request->getImpure<impure_value_ex>(tempImpure);
	UCHAR dtype = impureTemp->vlu_desc.dsc_dtype;

	if (!dialect1 && impure->vlu_desc.dsc_dtype == dtype_int64)
	{
		i = *((SINT64*) impure->vlu_desc.dsc_address) / impure->vlux_count;
		temp.makeInt64(impure->vlu_desc.dsc_scale, &i);
	}
	else if (!dialect1 && impure->vlu_desc.dsc_dtype == dtype_int128)
	{
		i128.set(impure->vlux_count, 0);
		i128 = ((Int128*) impure->vlu_desc.dsc_address)->div(i128, 0);
		if (dtype == dtype_int128)
			temp.makeInt128(impure->vlu_desc.dsc_scale, &i128);
		else
		{
			fb_assert(dtype == dtype_int64);
			i = i128.toInt64(0);
			temp.makeInt64(impure->vlu_desc.dsc_scale, &i);
		}
	}
	else if (dtype == dtype_dec128)
	{
		DecimalStatus decSt = tdbb->getAttachment()->att_dec_status;
		dec.set(impure->vlux_count, decSt, 0);
		dec = MOV_get_dec128(tdbb, &impure->vlu_desc).div(decSt, dec);
		temp.makeDecimal128(&dec);
	}
	else if (dtype == dtype_dec64)
	{
		DecimalStatus decSt = tdbb->getAttachment()->att_dec_status;
		// use higher precision for division
		dec.set(impure->vlux_count, decSt, 0);
		d64 = MOV_get_dec128(tdbb, &impure->vlu_desc).div(decSt, dec).toDecimal64(decSt);
		temp.makeDecimal64(&d64);
	}
	else
	{
		d = MOV_get_double(tdbb, &impure->vlu_desc) / impure->vlux_count;
		temp.makeDouble(&d);
	}

	EVL_make_value(tdbb, &temp, impureTemp);