diff --git a/ndb/src/ndbapi/NdbDictionaryImpl.cpp b/ndb/src/ndbapi/NdbDictionaryImpl.cpp index b104a5dc18b..e7a3a1f8e86 100644 --- a/ndb/src/ndbapi/NdbDictionaryImpl.cpp +++ b/ndb/src/ndbapi/NdbDictionaryImpl.cpp @@ -212,12 +212,15 @@ NdbColumnImpl::create_psuedo(const char * name){ } else if(!strcmp(name, "NDB$ROW_COUNT")){ col->setType(NdbDictionary::Column::Bigunsigned); col->m_impl.m_attrId = AttributeHeader::ROW_COUNT; + col->m_impl.m_attrSize = 8; } else if(!strcmp(name, "NDB$COMMIT_COUNT")){ col->setType(NdbDictionary::Column::Bigunsigned); col->m_impl.m_attrId = AttributeHeader::COMMIT_COUNT; + col->m_impl.m_attrSize = 8; } else { abort(); } + return col; } /** @@ -642,7 +645,9 @@ NdbDictionaryImpl::setTransporter(class Ndb* ndb, NdbColumnImpl::create_psuedo("NDB$COMMIT_COUNT"); } m_globalHash->unlock(); + return true; } + return false; } NdbTableImpl * diff --git a/ndb/tools/select_count.cpp b/ndb/tools/select_count.cpp index 9037ba01c9d..bb7c9dea49b 100644 --- a/ndb/tools/select_count.cpp +++ b/ndb/tools/select_count.cpp @@ -144,7 +144,7 @@ select_count(Ndb* pNdb, const NdbDictionary::Table* pTab, return NDBT_FAILED; } - Uint32 tmp; + Uint64 tmp; pOp->getValue(NdbDictionary::Column::ROW_COUNT, (char*)&tmp); check = pTrans->execute(NoCommit);