mirror of
https://github.com/MariaDB/server.git
synced 2025-01-23 23:34:34 +01:00
9e54eeee2e
(recommit for correct merge order) storage/ndb/src/kernel/blocks/ERROR_codes.txt: new error code storage/ndb/src/kernel/blocks/cmvmi/Cmvmi.cpp: add error inserts storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp: add error insert storage/ndb/src/kernel/blocks/pgman.cpp: add error inserts storage/ndb/test/include/HugoTransactions.hpp: add - loadTableStartFrom - scanUpdate with scanflags - fillTableStartFrom storage/ndb/test/include/UtilTransactions.hpp: add - clearTable with scan flags storage/ndb/test/ndbapi/testSystemRestart.cpp: add new testcases storage/ndb/test/run-test/daily-basic-tests.txt: add new testcases storage/ndb/test/src/HugoTransactions.cpp: add new functions storage/ndb/test/src/UtilTransactions.cpp: add new functions
154 lines
3.9 KiB
C++
154 lines
3.9 KiB
C++
/* Copyright (C) 2003 MySQL AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
#ifndef HUGO_TRANSACTIONS_HPP
|
|
#define HUGO_TRANSACTIONS_HPP
|
|
|
|
|
|
#include <NDBT.hpp>
|
|
#include <HugoCalculator.hpp>
|
|
#include <HugoOperations.hpp>
|
|
class NDBT_Stats;
|
|
|
|
class HugoTransactions : public HugoOperations {
|
|
public:
|
|
HugoTransactions(const NdbDictionary::Table&,
|
|
const NdbDictionary::Index* idx = 0);
|
|
~HugoTransactions();
|
|
int loadTable(Ndb*,
|
|
int records,
|
|
int batch = 512,
|
|
bool allowConstraintViolation = true,
|
|
int doSleep = 0,
|
|
bool oneTrans = false,
|
|
int updateValue = 0,
|
|
bool abort = false);
|
|
|
|
int loadTableStartFrom(Ndb*,
|
|
int startFrom,
|
|
int records,
|
|
int batch = 512,
|
|
bool allowConstraintViolation = true,
|
|
int doSleep = 0,
|
|
bool oneTrans = false,
|
|
int updateValue = 0,
|
|
bool abort = false);
|
|
|
|
int scanReadRecords(Ndb*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0,
|
|
NdbOperation::LockMode = NdbOperation::LM_Read,
|
|
int scan_flags = 0);
|
|
|
|
int scanReadRecords(Ndb*,
|
|
const NdbDictionary::Index*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0,
|
|
NdbOperation::LockMode = NdbOperation::LM_Read,
|
|
int scan_flags = 0);
|
|
|
|
int pkReadRecords(Ndb*,
|
|
int records,
|
|
int batchsize = 1,
|
|
NdbOperation::LockMode = NdbOperation::LM_Read);
|
|
|
|
int scanUpdateRecords(Ndb*, NdbScanOperation::ScanFlag,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0);
|
|
|
|
int scanUpdateRecords(Ndb*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0);
|
|
|
|
int scanUpdateRecords1(Ndb*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0);
|
|
int scanUpdateRecords2(Ndb*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0);
|
|
int scanUpdateRecords3(Ndb*,
|
|
int records,
|
|
int abort = 0,
|
|
int parallelism = 0);
|
|
|
|
int pkUpdateRecords(Ndb*,
|
|
int records,
|
|
int batchsize = 1,
|
|
int doSleep = 0);
|
|
int pkInterpretedUpdateRecords(Ndb*,
|
|
int records,
|
|
int batchsize = 1);
|
|
int pkDelRecords(Ndb*,
|
|
int records = 0,
|
|
int batch = 1,
|
|
bool allowConstraintViolation = true,
|
|
int doSleep = 0);
|
|
int lockRecords(Ndb*,
|
|
int records,
|
|
int percentToLock = 1,
|
|
int lockTime = 1000);
|
|
|
|
int fillTable(Ndb*,
|
|
int batch=512);
|
|
|
|
int fillTableStartFrom(Ndb*, int startFrom, int batch=512);
|
|
|
|
/**
|
|
* Reading using UniqHashIndex with key = pk
|
|
*/
|
|
int indexReadRecords(Ndb*,
|
|
const char * idxName,
|
|
int records,
|
|
int batchsize = 1);
|
|
|
|
int indexUpdateRecords(Ndb*,
|
|
const char * idxName,
|
|
int records,
|
|
int batchsize = 1);
|
|
|
|
void setRetryMax(int retryMax = 100) { m_retryMax = retryMax; }
|
|
|
|
Uint32 m_latest_gci;
|
|
|
|
void setStatsLatency(NDBT_Stats* stats) { m_stats_latency = stats; }
|
|
|
|
// allows multiple threads to update separate batches
|
|
void setThrInfo(int thr_count, int thr_no) {
|
|
m_thr_count = thr_count;
|
|
m_thr_no = thr_no;
|
|
}
|
|
|
|
protected:
|
|
NDBT_ResultRow row;
|
|
int m_defaultScanUpdateMethod;
|
|
int m_retryMax;
|
|
|
|
NDBT_Stats* m_stats_latency;
|
|
|
|
int m_thr_count; // 0 if no separation between threads
|
|
int m_thr_no;
|
|
};
|
|
|
|
|
|
|
|
|
|
#endif
|
|
|