diff options
Diffstat (limited to 'reladminif/test/check.cc')
| -rw-r--r-- | reladminif/test/check.cc | 301 |
1 files changed, 301 insertions, 0 deletions
diff --git a/reladminif/test/check.cc b/reladminif/test/check.cc new file mode 100644 index 0000000..44e5892 --- /dev/null +++ b/reladminif/test/check.cc @@ -0,0 +1,301 @@ +/* +* This file is part of rasdaman community. +* +* Rasdaman community 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, either version 3 of the License, or +* (at your option) any later version. +* +* Rasdaman community 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 rasdaman community. If not, see <http://www.gnu.org/licenses/>. +* +* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann / +rasdaman GmbH. +* +* For more information please see <http://www.rasdaman.org> +* or contact Peter Baumann via <baumann@rasdaman.com>. +*/ +/* +get mddoid, iterate domain, dataformat + +select mdd +get domain + { + begin ta + iterate over domain + retrieve tiles + alter tiles + commit ta + } +*/ + +#ifdef EARLY_TEMPLATE +#define __EXECUTABLE__ +#include "server/template_inst.hh" +#endif + +#include "reladminif/adminif.hh" +#include "reladminif/databaseif.hh" +#include "reladminif/transactionif.hh" +#include "reladminif/oidif.hh" +#include "mddmgr/mddobj.hh" +#include "tilemgr/tile.hh" +#include "cmlparser.hh" +#include "raslib/mitera.hh" + +#define ALLDONE 0 +#define ERRORPARSINGCOMMANDLINE 1 +#define DOMAINMISSING 2 +#define OIDMISSING 3 +#define OIDINVALID 4 +#define DOMAINMISMATCH 5 +#define FAILED 6 +#define DOMAININVALID 7 +#define UNKNOWNDATAFORMAT 8 + +char globalConnectId[256]; + +RMINITGLOBALS('S') + +r_Minterval domain; +OId oid; + +int +main(int argc, char** argv) + { + RMInit::logOut.rdbuf(cout.rdbuf()); + RMInit::dbgOut.rdbuf(cout.rdbuf()); + int retval = 0; + CommandLineParser &cmlInter = CommandLineParser::getInstance(); + CommandLineParameter &clp_help = cmlInter.addFlagParameter('h', "help", "show command line switches"); + CommandLineParameter &clp_connect = cmlInter.addStringParameter(CommandLineParser::noShortName, "connect", "database connect string", "/"); + CommandLineParameter &clp_mdddomain = cmlInter.addStringParameter(CommandLineParser::noShortName, "mdddomain", "the domain to do the changes in."); + CommandLineParameter &clp_domain = cmlInter.addStringParameter(CommandLineParser::noShortName, "domain", "the extent to be used when selecting data from the mdd."); + CommandLineParameter &clp_oid = cmlInter.addStringParameter(CommandLineParser::noShortName, "oid", "the oid of the mdd to operate on"); + CommandLineParameter &clp_comptype = cmlInter.addStringParameter(CommandLineParser::noShortName, "storageformat", "name of storage format", "Array"); + CommandLineParameter &clp_readonly = cmlInter.addFlagParameter('r', "readonly", "read only check"); + try { + cmlInter.processCommandLine(argc, argv); + } + catch(CmlException& err) + { + cmlInter.printHelp(); + cout << "Error parsing command line:" << endl; + cout << err.what() << endl; + return ERRORPARSINGCOMMANDLINE; + } + if (cmlInter.isPresent('h')) + { + cmlInter.printHelp(); + return ALLDONE; + } + r_Data_Format storageFormat = r_Array; + if (cmlInter.isPresent("storageformat")) + { + storageFormat = get_data_format_from_name(cmlInter.getValueAsString("storageformat")); + if (storageFormat == r_Data_Format_NUMBER) + { + cout << "unknown data format " << cmlInter.getValueAsString("storageformat") << endl; + return UNKNOWNDATAFORMAT; + } + } + if (!cmlInter.isPresent("domain")) + { + cout << "domain is missing" << endl; + return DOMAINMISSING; + } + if (!cmlInter.isPresent("oid")) + { + cout << "oid is missing" << endl; + return OIDMISSING; + } + strcpy((char*)globalConnectId, cmlInter.getValueAsString("connect")); + cout << "connect " << globalConnectId << endl; + try { + domain = r_Minterval(cmlInter.getValueAsString("domain")); + } + catch (const r_Error& e) + { + cout << "domain is not valid: " << e.what() << " " << e.get_errorno() << endl; + return DOMAININVALID; + } + oid = OId(atol(cmlInter.getValueAsString("oid"))); + if (oid.getType() != OId::MDDOID) + { + cout << "oid is not a mdd oid" << endl; + return OIDINVALID; + } + bool readonly = cmlInter.isPresent("readonly"); + if (readonly) + { + cout << "performing read only check" << std::endl; + } + else { + cout << "performing recompression" << std::endl; + } + cout << "set up done" << endl; + AdminIf::instance(); + DatabaseIf d; + TransactionIf t; + MDDObj* mdd = NULL; + r_Minterval completeDomain; + r_MiterArea* miter = NULL; + try { + d.open("RASBASE"); + t.begin(&d, true); + mdd = new MDDObj(oid); + if (mdd->getCurrentDomain().dimension() == domain.dimension()) + { + completeDomain = mdd->getCurrentDomain(); + if (cmlInter.isPresent("mdddomain")) + { + try { + r_Minterval temp(cmlInter.getValueAsString("mdddomain")); + if (temp.dimension() == completeDomain.dimension()) + { + cout << "Not using complete mdd domain (" << completeDomain << ") but " << temp << endl; + completeDomain = temp; + } + else { + cout << "Domains do not have same number of dimensions" << endl; + delete mdd; + mdd = NULL; + t.commit(); + d.close(); + return DOMAINMISMATCH; + } + } + catch (const r_Error& e2) + { + cout << "mdddomain parameter is not correct: " << e2.get_errorno() << " " << e2.what() << endl; + delete mdd; + mdd = NULL; + t.commit(); + d.close(); + return DOMAININVALID; + } + } + miter = new r_MiterArea(&domain, &completeDomain); + } + else { + t.commit(); + d.close(); + return DOMAINMISMATCH; + } + delete mdd; + mdd = NULL; + t.commit(); + d.close(); + } + catch (const r_Error& e) + { + delete miter; + miter = NULL; + cout << "Caught exception " << e.get_errorno() << " " << e.what() << endl; + try { + t.abort(); + } + catch (const r_Error& ee) + { + cout << "Caugh exception while aborting " << ee.get_errorno() << " " << ee.what() << endl; + try { + t.abort(); + } + catch (const r_Error& eee) + { + cout << "Caugh exception while 2nd aborting " << eee.get_errorno() << " " << eee.what() << endl; + } + } + try { + d.close(); + } + catch (const r_Error& eeee) + { + cout << "Caugh exception while closing " << eeee.get_errorno() << " " << eeee.what() << endl; + } + return FAILED; + } + std::vector<Tile*>* tiles = NULL; + std::vector<Tile*>::iterator here; + std::vector<Tile*>::iterator end; + r_Minterval currentDomain; + while (!miter->isDone()) + { + currentDomain = miter->nextArea(); + try { + d.open("RASBASE"); + t.begin(&d, readonly); + mdd = new MDDObj(oid); + tiles = mdd->intersect(currentDomain); + end = tiles->end(); + if (tiles) + { + cout << "working on " << currentDomain << " with " << tiles->size() << " tiles" << endl; + for (here = tiles->begin(); here < end; here++) + { + cout << " tile " << (*here)->getDomain() << " " << (*here)->getDBTile()->getOId() << " " << (*here)->getDataFormat() << " " << (*here)->getCompressedSize(); + if (!(*here)->decompress()) + { + cout << " decompress failed"; + } + if (((*here)->getDataFormat() != storageFormat) && (!readonly)) + { + cout << " changing storage format"; + (*here)->setCompressionFormat(storageFormat); + cout << " compressed size " << (*here)->getCompressedSize(); + } + cout << endl; + } + } + else { + cout << currentDomain << " no tiles" << endl; + } + delete mdd; + mdd = NULL; + delete tiles; + tiles = NULL; + t.commit(); + d.close(); + } + catch (const r_Error& e) + { + delete miter; + miter = NULL; + delete tiles; + tiles = NULL; + cout << "Caught exception " << e.get_errorno() << " " << e.what() << endl; + try { + t.abort(); + } + catch (const r_Error& ee) + { + cout << "Caugh exception while aborting " << ee.get_errorno() << " " << ee.what() << endl; + try { + t.abort(); + } + catch (const r_Error& eee) + { + cout << "Caugh exception while 2nd aborting " << eee.get_errorno() << " " << eee.what() << endl; + } + } + try { + d.close(); + } + catch (const r_Error& eeee) + { + cout << "Caugh exception while closing " << eeee.get_errorno() << " " << eeee.what() << endl; + } + return FAILED; + } + } + delete tiles; + tiles = NULL; + delete miter; + miter = NULL; + return retval; + } |