diff options
author | unknown <mronstrom@build.mysql.com> | 2004-08-21 15:17:10 +0200 |
---|---|---|
committer | unknown <mronstrom@build.mysql.com> | 2004-08-21 15:17:10 +0200 |
commit | 3831c7a29461dc273bd1f97a6aa9feb5352f3127 (patch) | |
tree | 98ff463845962c8706c7de032ddc03581f7da5ea /ndb/include/ndbapi | |
parent | a443bee8041b29e39ec578172374a7c20638a46b (diff) | |
parent | 6d1eab0b0e8926ae98f9e87c6bbf92ab9573da5e (diff) | |
download | mariadb-git-3831c7a29461dc273bd1f97a6aa9feb5352f3127.tar.gz |
Merge build.mysql.com:/home/bk/mysql-4.1-ndb
into build.mysql.com:/users/mronstrom/wl2025
BitKeeper/etc/logging_ok:
auto-union
ndb/src/common/mgmcommon/ConfigInfo.cpp:
Auto merged
ndb/src/kernel/blocks/dblqh/Dblqh.hpp:
Auto merged
ndb/src/kernel/blocks/dblqh/DblqhInit.cpp:
Auto merged
ndb/src/kernel/blocks/dblqh/DblqhMain.cpp:
Auto merged
ndb/src/kernel/blocks/dbtc/Dbtc.hpp:
Auto merged
ndb/src/kernel/blocks/dbtc/DbtcMain.cpp:
Auto merged
ndb/src/kernel/blocks/suma/Suma.cpp:
Auto merged
ndb/src/kernel/vm/Configuration.cpp:
Auto merged
ndb/src/ndbapi/NdbScanOperation.cpp:
Auto merged
ndb/src/ndbapi/TransporterFacade.cpp:
Auto merged
ndb/src/ndbapi/TransporterFacade.hpp:
Auto merged
Diffstat (limited to 'ndb/include/ndbapi')
-rw-r--r-- | ndb/include/ndbapi/Ndb.hpp | 24 | ||||
-rw-r--r-- | ndb/include/ndbapi/NdbConnection.hpp | 11 |
2 files changed, 29 insertions, 6 deletions
diff --git a/ndb/include/ndbapi/Ndb.hpp b/ndb/include/ndbapi/Ndb.hpp index 951c36bade1..7904ecef305 100644 --- a/ndb/include/ndbapi/Ndb.hpp +++ b/ndb/include/ndbapi/Ndb.hpp @@ -1414,12 +1414,24 @@ public: * * @return tuple id or 0 on error */ - Uint64 getAutoIncrementValue(const char* aTableName, Uint32 cacheSize = 1); - bool setAutoIncrementValue(const char* aTableName, Uint64 val, bool increase = false); - Uint64 getTupleIdFromNdb(const char* aTableName, Uint32 cacheSize = 1000 ); - Uint64 getTupleIdFromNdb(Uint32 aTableId, Uint32 cacheSize = 1000 ); - bool setTupleIdInNdb(const char* aTableName, Uint64 val, bool increase = false); - bool setTupleIdInNdb(Uint32 aTableId, Uint64 val, bool increase = false); + Uint64 getAutoIncrementValue(const char* aTableName, + Uint32 cacheSize = 1); + Uint64 getAutoIncrementValue(NdbDictionary::Table * aTable, + Uint32 cacheSize = 1); + Uint64 readAutoIncrementValue(const char* aTableName); + Uint64 readAutoIncrementValue(NdbDictionary::Table * aTable); + bool setAutoIncrementValue(const char* aTableName, Uint64 val, + bool increase = false); + bool setAutoIncrementValue(NdbDictionary::Table * aTable, Uint64 val, + bool increase = false); + Uint64 getTupleIdFromNdb(const char* aTableName, + Uint32 cacheSize = 1000); + Uint64 getTupleIdFromNdb(Uint32 aTableId, + Uint32 cacheSize = 1000); + Uint64 readTupleIdFromNdb(Uint32 aTableId); + bool setTupleIdInNdb(const char* aTableName, Uint64 val, + bool increase); + bool setTupleIdInNdb(Uint32 aTableId, Uint64 val, bool increase); Uint64 opTupleIdOnNdb(Uint32 aTableId, Uint64 opValue, Uint32 op); #endif diff --git a/ndb/include/ndbapi/NdbConnection.hpp b/ndb/include/ndbapi/NdbConnection.hpp index 4e0330e3fda..c268f9aab04 100644 --- a/ndb/include/ndbapi/NdbConnection.hpp +++ b/ndb/include/ndbapi/NdbConnection.hpp @@ -19,6 +19,7 @@ #include <ndb_types.h> #include <NdbError.hpp> +#include <NdbDictionary.hpp> class NdbConnection; class NdbOperation; @@ -440,6 +441,14 @@ public: */ int executePendingBlobOps(Uint8 flags = 0xFF); + // Fast path calls for MySQL ha_ndbcluster + NdbOperation* getNdbOperation(NdbDictionary::Table * table); + NdbIndexOperation* getNdbIndexOperation(NdbDictionary::Index * index, + NdbDictionary::Table * table); + NdbScanOperation* getNdbScanOperation(NdbDictionary::Table * table); + NdbIndexScanOperation* getNdbIndexScanOperation(NdbDictionary::Index * index, + NdbDictionary::Table * table); + private: /** * Release completed operations @@ -553,6 +562,8 @@ private: NdbIndexOperation* getNdbIndexOperation(class NdbIndexImpl* anIndex, class NdbTableImpl* aTable, NdbOperation* aNextOp = 0); + NdbIndexScanOperation* getNdbIndexScanOperation(NdbIndexImpl* index, + NdbTableImpl* table); void handleExecuteCompletion(); |