Loading storage/ndb/src/kernel/blocks/dbtup/DbtupRoutines.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -784,7 +784,8 @@ int Dbtup::updateAttributes(KeyReqStruct *req_struct, req_struct->m_tuple_ptr->m_header_bits |= Tuple_header::DISK_PART; memcpy(req_struct->m_tuple_ptr->get_disk_ref_ptr(regTabPtr), inBuffer+inBufIndex+1, sz << 2); req_struct->in_buf_index = inBufIndex += 1 + sz; inBufIndex += 1 + sz; req_struct->in_buf_index = inBufIndex; } else { Loading storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp +6 −2 Original line number Diff line number Diff line Loading @@ -2302,7 +2302,7 @@ NdbDictionaryImpl::createTable(NdbTableImpl &t) } // blob tables - use "t2" to get values set by kernel if (t2->m_noOfBlobs != 0 && createBlobTables(*t2) != 0) { if (t2->m_noOfBlobs != 0 && createBlobTables(t, *t2) != 0) { int save_code = m_error.code; (void)dropTableGlobal(*t2); m_error.code = save_code; Loading @@ -2316,7 +2316,7 @@ NdbDictionaryImpl::createTable(NdbTableImpl &t) } int NdbDictionaryImpl::createBlobTables(NdbTableImpl &t) NdbDictionaryImpl::createBlobTables(NdbTableImpl& orig, NdbTableImpl &t) { DBUG_ENTER("NdbDictionaryImpl::createBlobTables"); for (unsigned i = 0; i < t.m_columns.size(); i++) { Loading @@ -2325,6 +2325,10 @@ NdbDictionaryImpl::createBlobTables(NdbTableImpl &t) continue; NdbTableImpl bt; NdbBlob::getBlobTable(bt, &t, &c); NdbDictionary::Column::StorageType d = NdbDictionary::Column::StorageTypeDisk; if (orig.m_columns[i]->getStorageType() == d) bt.getColumn("DATA")->setStorageType(d); if (createTable(bt) != 0) { DBUG_RETURN(-1); } Loading storage/ndb/src/ndbapi/NdbDictionaryImpl.hpp +1 −1 Original line number Diff line number Diff line Loading @@ -582,7 +582,7 @@ public: bool setTransporter(class TransporterFacade * tf); int createTable(NdbTableImpl &t); int createBlobTables(NdbTableImpl& t); int createBlobTables(NdbTableImpl& org, NdbTableImpl& created); int alterTable(NdbTableImpl &t); int dropTable(const char * name); int dropTable(NdbTableImpl &); Loading Loading
storage/ndb/src/kernel/blocks/dbtup/DbtupRoutines.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -784,7 +784,8 @@ int Dbtup::updateAttributes(KeyReqStruct *req_struct, req_struct->m_tuple_ptr->m_header_bits |= Tuple_header::DISK_PART; memcpy(req_struct->m_tuple_ptr->get_disk_ref_ptr(regTabPtr), inBuffer+inBufIndex+1, sz << 2); req_struct->in_buf_index = inBufIndex += 1 + sz; inBufIndex += 1 + sz; req_struct->in_buf_index = inBufIndex; } else { Loading
storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp +6 −2 Original line number Diff line number Diff line Loading @@ -2302,7 +2302,7 @@ NdbDictionaryImpl::createTable(NdbTableImpl &t) } // blob tables - use "t2" to get values set by kernel if (t2->m_noOfBlobs != 0 && createBlobTables(*t2) != 0) { if (t2->m_noOfBlobs != 0 && createBlobTables(t, *t2) != 0) { int save_code = m_error.code; (void)dropTableGlobal(*t2); m_error.code = save_code; Loading @@ -2316,7 +2316,7 @@ NdbDictionaryImpl::createTable(NdbTableImpl &t) } int NdbDictionaryImpl::createBlobTables(NdbTableImpl &t) NdbDictionaryImpl::createBlobTables(NdbTableImpl& orig, NdbTableImpl &t) { DBUG_ENTER("NdbDictionaryImpl::createBlobTables"); for (unsigned i = 0; i < t.m_columns.size(); i++) { Loading @@ -2325,6 +2325,10 @@ NdbDictionaryImpl::createBlobTables(NdbTableImpl &t) continue; NdbTableImpl bt; NdbBlob::getBlobTable(bt, &t, &c); NdbDictionary::Column::StorageType d = NdbDictionary::Column::StorageTypeDisk; if (orig.m_columns[i]->getStorageType() == d) bt.getColumn("DATA")->setStorageType(d); if (createTable(bt) != 0) { DBUG_RETURN(-1); } Loading
storage/ndb/src/ndbapi/NdbDictionaryImpl.hpp +1 −1 Original line number Diff line number Diff line Loading @@ -582,7 +582,7 @@ public: bool setTransporter(class TransporterFacade * tf); int createTable(NdbTableImpl &t); int createBlobTables(NdbTableImpl& t); int createBlobTables(NdbTableImpl& org, NdbTableImpl& created); int alterTable(NdbTableImpl &t); int dropTable(const char * name); int dropTable(NdbTableImpl &); Loading