database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

The codegen function of VecAgg adapts to unique_check.

Browse Source 
Offering: openGaussDev

More detail: The codegen function of VecAgg adapts to unique_check.

Match-id-4314cb63a4c79ae386cfe88a1681216111c9e14f
This commit is contained in:
openGaussDev
2022-03-10 10:34:13 +08:00
committed by yanghao
parent 2483136618
commit 87eeb92227
1 changed files with 18 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/gausskernel/runtime/codegen/vecexecutor/vechashaggcodegen.cpp
View File

@ -81,9 +81,7 @@ int VecHashAggCodeGen::GetAlignedScale(Expr* node)
} else if (opexpr->opno == NUMERICMULOID)
resscale = lscale + rscale;
else
ereport(ERROR,
(errcode(ERRCODE_UNRECOGNIZED_NODE_TYPE),
errmodule(MOD_LLVM),
ereport(ERROR, (errcode(ERRCODE_UNRECOGNIZED_NODE_TYPE), errmodule(MOD_LLVM),
errmsg("Unsupported operation %u in FastAgg.", opexpr->opno)));
} break;
case T_Var: {
@ -478,6 +476,17 @@ void VecHashAggCodeGen::SonicHashAggCodeGen(VecAggState* node)
llvmCodeGen->addFunctionToMCJit(jitted_sonicbatchagg, reinterpret_cast<void**>(&(node->jitted_sonicbatchagg)));
}
/* Check if existing tuple is unique */
static void VecAggCheckUnique(VecAgg* vecagg, GsCodeGen::LlvmBuilder* builder)
{
const char* errorstr = "more than one row returned by a subquery used as an expression";
if (vecagg->unique_check) {
/* If uniqueness is not checked, the result is incorrect. */
DebugerCodeGen::CodeGenElogInfo(builder, ERROR, errorstr);
}
}
template <bool isSglTbl>
llvm::Function* VecHashAggCodeGen::AgghashingCodeGenorSglTbl(VecAggState* node)
{
@ -656,9 +665,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingCodeGenorSglTbl(VecAggState* node)
llvm::Function* func_hashbatch = HashBatchCodeGen(node, i, rehash);
if (func_hashbatch == NULL) {
ereport(ERROR,
(errcode(ERRCODE_UNEXPECTED_NULL_VALUE),
errmodule(MOD_LLVM),
ereport(ERROR, (errcode(ERRCODE_UNEXPECTED_NULL_VALUE), errmodule(MOD_LLVM),
errmsg("Failed on generating HashBatchCodeGen!\n")));
}
@ -777,9 +784,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingCodeGenorSglTbl(VecAggState* node)
for (i = 0; i < numkeys; i++) {
llvm::Function* func_matchonekey = MatchOneKeyCodeGen(node, i);
if (NULL == func_matchonekey) {
ereport(ERROR,
(errcode(ERRCODE_UNEXPECTED_NULL_VALUE),
errmodule(MOD_LLVM),
ereport(ERROR, (errcode(ERRCODE_UNEXPECTED_NULL_VALUE), errmodule(MOD_LLVM),
errmsg("Failed on generating MatchOneKey Function!\n")));
}
@ -806,6 +811,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingCodeGenorSglTbl(VecAggState* node)
* hash cell and go to next tuple.
*/
builder.SetInsertPoint(key_match);
VecAggCheckUnique(vecagg, &builder);
/* get hashAggRunner.BaseAggRunner.m_Loc[phi_idx] */
Vals4[0] = Datum_0;
Vals4[1] = int32_0;
@ -1041,9 +1047,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingWithPrefetchCodeGenorSglTbl(VecAggS
llvm::Function* func_hashbatch = HashBatchCodeGen(node, i, rehash);
if (func_hashbatch == NULL) {
ereport(ERROR,
(errcode(ERRCODE_UNEXPECTED_NULL_VALUE),
errmodule(MOD_LLVM),
ereport(ERROR, (errcode(ERRCODE_UNEXPECTED_NULL_VALUE), errmodule(MOD_LLVM),
errmsg("Failed on generating HashBatchCodeGen!\n")));
}
@ -1204,8 +1208,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingWithPrefetchCodeGenorSglTbl(VecAggS
for (i = 0; i < numkeys; i++) {
llvm::Function* func_matchonekey = MatchOneKeyCodeGen(node, i);
if (NULL == func_matchonekey) {
ereport(ERROR,
(errcode(ERRCODE_UNEXPECTED_NULL_VALUE),
ereport(ERROR, (errcode(ERRCODE_UNEXPECTED_NULL_VALUE),
errmodule(MOD_LLVM),
errmsg("Failed on generating MatchOneKey Function!\n")));
}
@ -1233,6 +1236,7 @@ llvm::Function* VecHashAggCodeGen::AgghashingWithPrefetchCodeGenorSglTbl(VecAggS
* hash cell and go to next tuple.
*/
builder.SetInsertPoint(key_match);
VecAggCheckUnique(vecagg, &builder);
/* get hashAggRunner.BaseAggRunner.m_Loc[phi_idx] */
Vals4[0] = Datum_0;
Vals4[1] = int32_0;