Function TEST

publication/source_code/bench_end_to_end/src/test/tpch.cpp:37–112

}

TEST(TPCH, q1) {
	configFromEnv();
	using namespace types;
	std::map<tuple<Char<1>, Char<1>>, tuple<Numeric<12, 2>, Numeric<12, 2>, Numeric<12, 4>, Numeric<12, 6>, int64_t>>
	    expected = {{make_tuple(Char<1>::castString("A"), Char<1>::castString("F")),
	                 make_tuple(Numeric<12, 2>::castString("37734107.00"),
	                            Numeric<12, 2>::castString("56586554400.73"),
	                            Numeric<12, 4>::castString("53758257134.8700"),
	                            Numeric<12, 6>::castString("55909065222.827692"),
	                            1478493)},

	                {make_tuple(Char<1>::castString("N"), Char<1>::castString("F")),
	                 make_tuple(Numeric<12, 2>::castString("991417.00"),
	                            Numeric<12, 2>::castString("1487504710.38"),
	                            Numeric<12, 4>::castString("1413082168.0541"),
	                            Numeric<12, 6>::castString("1469649223.194375"),
	                            38854)},

	                {make_tuple(Char<1>::castString("N"), Char<1>::castString("O")),
	                 make_tuple(Numeric<12, 2>::castString("74476040.00"),
	                            Numeric<12, 2>::castString("111701729697.74"),
	                            Numeric<12, 4>::castString("106118230307.6056"),
	                            Numeric<12, 6>::castString("110367043872.497010"),
	                            2920374)},

	                {make_tuple(Char<1>::castString("R"), Char<1>::castString("F")),
	                 make_tuple(Numeric<12, 2>::castString("37719753.00"),
	                            Numeric<12, 2>::castString("56568041380.90"),
	                            Numeric<12, 4>::castString("53741292684.6040"),
	                            Numeric<12, 6>::castString("55889619119.831932"),
	                            1478870)}};

	auto checkResult = [&](BlockRelation* result) {
		size_t found           = 0;
		auto   retAttr         = result->getAttribute("l_returnflag");
		auto   statusAttr      = result->getAttribute("l_linestatus");
		auto   qtyAttr         = result->getAttribute("sum_qty");
		auto   base_priceAttr  = result->getAttribute("sum_base_price");
		auto   disc_priceAttr  = result->getAttribute("sum_disc_price");
		auto   chargeAttr      = result->getAttribute("sum_charge");
		auto   count_orderAttr = result->getAttribute("count_order");
		for (auto& block : *result) {
			auto elementsInBlock = block.size();
			found += elementsInBlock;
			auto ret         = reinterpret_cast<Char<1>*>(block.data(retAttr));
			auto status      = reinterpret_cast<Char<1>*>(block.data(statusAttr));
			auto qty         = reinterpret_cast<Numeric<12, 2>*>(block.data(qtyAttr));
			auto base_price  = reinterpret_cast<Numeric<12, 2>*>(block.data(base_priceAttr));
			auto disc_price  = reinterpret_cast<Numeric<12, 4>*>(block.data(disc_priceAttr));
			auto charge      = reinterpret_cast<Numeric<12, 6>*>(block.data(chargeAttr));
			auto count_order = reinterpret_cast<int64_t*>(block.data(count_orderAttr));
			for (size_t i = 0; i < elementsInBlock; ++i) {
				auto& exValues = expected[make_tuple(ret[i], status[i])];
				ASSERT_EQ(qty[i], get<0>(exValues));
				ASSERT_EQ(base_price[i], get<1>(exValues));
				ASSERT_EQ(disc_price[i], get<2>(exValues));
				ASSERT_EQ(charge[i], get<3>(exValues));
				ASSERT_EQ(count_order[i], get<4>(exValues));