mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-23 23:34:34 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

ndb - TUP interpreter: use byte length in attr OP const

Browse source 
ndb/src/kernel/blocks/dbtup/DbtupExecQuery.cpp:
  TUP interpreter: use byte length in attr OP const
ndb/src/ndbapi/NdbOperationInt.cpp:
  TUP interpreter: use byte length in attr OP const
This commit is contained in:
unknown 2005-02-18 12:42:59 +01:00
parent a4f190511d
commit 9ab62ea5ca
2 changed files with 32 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
ndb/src/kernel/blocks/dbtup/DbtupExecQuery.cpp
View file

@ -1837,12 +1837,8 @@ int Dbtup::interpreterNextLab(Signal* signal,
tmpHabitant = attrId;
}
// get type
attrId >>= 16;
AttributeHeader ah(tmpArea[0]);
const char* s1 = (char*)&tmpArea[1];
const char* s2 = (char*)&TcurrentProgram[TprogramCounter+1];
Uint32 attrLen = (4 * ah.getDataSize());
Uint32 TattrDescrIndex = tabptr.p->tabDescriptor +
(attrId << ZAD_LOG_SIZE);
Uint32 TattrDesc1 = tableDescriptor[TattrDescrIndex].tabDescr;
@ -1855,27 +1851,32 @@ int Dbtup::interpreterNextLab(Signal* signal,
cs = tabptr.p->charsetArray[pos];
}
const NdbSqlUtil::Type& sqlType = NdbSqlUtil::getType(typeId);
// get data
AttributeHeader ah(tmpArea[0]);
const char* s1 = (char*)&tmpArea[1];
const char* s2 = (char*)&TcurrentProgram[TprogramCounter+1];
// fixed length in 5.0
Uint32 attrLen = AttributeDescriptor::getSizeInBytes(TattrDesc1);
bool r1_null = ah.isNULL();
bool r2_null = argLen == 0;
int res;
if(r1_null || r2_null)
{
res = r1_null && r2_null ? 0 : r1_null ? -1 : 1;
}
else if (cond != Interpreter::LIKE &&
cond != Interpreter::NOT_LIKE)
{
/* --------------------------------------------------------- */
// If length of argument rounded to nearest word is
// the same as attribute size, use that as argument size
/* --------------------------------------------------------- */
if ((((argLen + 3) >> 2) << 2) == attrLen) argLen= attrLen;
res = (*sqlType.m_cmp)(cs, s1, attrLen, s2, argLen, true);
}
else
{
res = (*sqlType.m_like)(cs, s1, attrLen, s2, argLen);
if (cond != Interpreter::LIKE &&
cond != Interpreter::NOT_LIKE) {
if (r1_null || r2_null) {
// NULL==NULL and NULL<not-NULL
res = r1_null && r2_null ? 0 : r1_null ? -1 : 1;
} else {
res = (*sqlType.m_cmp)(cs, s1, attrLen, s2, argLen, true);
}
} else {
if (r1_null || r2_null) {
// NULL like NULL is true (has no practical use)
res = r1_null && r2_null ? 0 : -1;
} else {
res = (*sqlType.m_like)(cs, s1, attrLen, s2, argLen);
}
}
switch ((Interpreter::BinaryCondition)cond) {

14
ndb/src/ndbapi/NdbOperationInt.cpp
View file

@ -1027,13 +1027,15 @@ NdbOperation::branch_col(Uint32 type,
}
Uint32 sizeInBytes = col->m_attrSize * col->m_arraySize;
if(len != 0 && len != sizeInBytes)
{
setErrorCodeAbort(4209);
return -1;
if (! col->getCharType()) {
// prevent assert in NdbSqlUtil on length error
if(len != 0 && len != sizeInBytes)
{
setErrorCodeAbort(4209);
return -1;
}
len = sizeInBytes;
}
len = sizeInBytes;
if (insertATTRINFO(Interpreter::BranchCol(c, 0, 0, false)) == -1)
return -1;