Hawkin
/
arangodb
mirror of https://gitee.com/bigwinds/arangodb
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Added an otion to extract the collection type in a cluster with the CollectionNameResolcer

This commit is contained in:
Michael Hackstein 2015-11-16 19:47:50 +01:00
parent 21cf784cbc
commit 3926e82247
1 changed files with 44 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
arangod/Utils/CollectionNameResolver.h
View File

@ -94,6 +94,25 @@ namespace triagens {
return 0;
}
////////////////////////////////////////////////////////////////////////////////
/// @brief look up a collection type for a collection name (local case)
////////////////////////////////////////////////////////////////////////////////
TRI_col_type_t const getCollectionType (std::string const& name) const {
if (name[0] >= '0' && name[0] <= '9') {
// name is a numeric id
return getCollectionType(getCollectionName(static_cast<TRI_voc_cid_t>(triagens::basics::StringUtils::uint64(name))));
}
TRI_vocbase_col_t const* collection = getCollectionStruct(name);
if (collection != nullptr) {
return collection->_type;
}
return TRI_COL_TYPE_UNKNOWN;
}
////////////////////////////////////////////////////////////////////////////////
/// @brief look up a collection struct for a collection name
////////////////////////////////////////////////////////////////////////////////
@ -138,6 +157,31 @@ namespace triagens {
return cinfo->id();
}
////////////////////////////////////////////////////////////////////////////////
/// @brief look up a cluster collection type for a cluster collection name
////////////////////////////////////////////////////////////////////////////////
TRI_col_type_t const getCollectionTypeCluster (std::string const& name) const {
if (! ServerState::instance()->isRunningInCluster()) {
return getCollectionType(name);
}
if (name[0] >= '0' && name[0] <= '9') {
// name is a numeric id
return getCollectionTypeCluster(getCollectionName(static_cast<TRI_voc_cid_t>(triagens::basics::StringUtils::uint64(name))));
}
// We have to look up the collection info:
ClusterInfo* ci = ClusterInfo::instance();
std::shared_ptr<CollectionInfo> cinfo
= ci->getCollection(DatabaseID(_vocbase->_name),
name);
if (cinfo->empty()) {
return TRI_COL_TYPE_UNKNOWN;
}
return cinfo->type();
}
////////////////////////////////////////////////////////////////////////////////
/// @brief look up a collection name for a collection id, this implements
/// some magic in the cluster case: a DBserver in a cluster will automatically