summaryrefslogtreecommitdiffstats
path: root/rasodmg/test/system_insert.cc
diff options
context:
space:
mode:
Diffstat (limited to 'rasodmg/test/system_insert.cc')
-rw-r--r--rasodmg/test/system_insert.cc384
1 files changed, 384 insertions, 0 deletions
diff --git a/rasodmg/test/system_insert.cc b/rasodmg/test/system_insert.cc
new file mode 100644
index 0000000..f290778
--- /dev/null
+++ b/rasodmg/test/system_insert.cc
@@ -0,0 +1,384 @@
+/*
+* 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>.
+/
+/**
+ * SOURCE: system_insert.cc
+ *
+ * MODULE: rasodmg/test
+ *
+ * COMMENTS:
+ * None
+*/
+
+static const char rcsid[] = "@(#)rasodmg/test,SystemInsert: $Id: system_insert.cc,v 1.10 2002/03/13 13:48:17 coman Exp $";
+
+#ifdef EARLY_TEMPLATE
+#define __EXECUTABLE__
+#include "raslib/template_inst.hh"
+#endif
+
+#include "system_insert.hh"
+#include "raslib/rminit.hh"
+#include "raslib/rmdebug.hh"
+#include "raslib/primitivetype.hh"
+#include "rasodmg/tiling.hh"
+#include "rasodmg/stattiling.hh"
+#include "rasodmg/storagelayout.hh"
+
+int main(int argc, const char** argv)
+ {
+ return SystemInsert::doStuff(argc, argv);
+ }
+
+int
+SystemInsert::doStuff(int argc, const char** argv)
+ {
+ RMInit::logOut.rdbuf(cout.rdbuf());
+ RMInit::dbgOut.rdbuf(cout.rdbuf());
+ RMDebug::level = 10;
+ r_Base_Type* conversionType = 0;
+ int retval = 0;
+
+ if ((argc == 1) || checkArguments(argc, argv, "-h", optionValueIndex) || checkArguments(argc, argv, "--help", optionValueIndex))
+ {
+ printUsage();
+ }
+ else {
+ retval = readArgs(argc, argv);
+ /*
+ what can we do:
+ create mdd:
+ requires
+ mddType
+ optional
+ collName ok
+ collOId ok
+ create coll:
+ requires
+ settype ok
+ optional
+ collName ok
+ insert existing mdd into coll:
+ requires
+ mddOId
+ collName/collOId
+ */
+ if (retval == 0)
+ {
+ if (mddTypeDef)
+ {//create mdd
+ if (mddOIdDef)
+ {//cannot create mdd with a user specified oid
+ retval = CREATEMDDWITHOID;
+ }
+ else {
+ if (fileNameDef)
+ {
+ if (mddDomainDef)
+ {
+ if (collNameDef)
+ {//create mdd, lookup coll by name, insert mdd into coll
+ //open stuff
+ try {
+ openTransaction();
+ //get collection
+ try {
+ collection = db.lookup_object(collName);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing collection " << collName << ": " << obj.what() << endl;
+ retval = COLLECTIONINACCESSIBLE;
+ }
+ //create mddObject
+ if (retval == 0)
+ {
+ r_Storage_Layout* stl = new r_Storage_Layout(theTiling->clone());
+ //stl->set_storage_format(storageFormat, storageFormatParams);
+ mddObject = new (&db, mddTypeName) r_GMarray(mddDomain, 0, stl);
+ retval = initGMarray(mddObject, filePointer, inputFormat, mddDomain, inputFormatParams);
+ if (retval == 0)
+ {
+ collection->insert_element(mddObject);
+ ta.commit();
+ }
+ else
+ ta.abort();
+ }
+ else {
+ ta.abort();
+ }
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ else {//no collname
+ if (collOIdDef)
+ {//create mdd, lookup coll by oid, insert mdd into coll
+ try {
+ openTransaction();
+ //get collection
+ try {
+ collection = db.lookup_object(collOId);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing collection " << collOId << ": " << obj.what() << endl;
+ retval = COLLECTIONINACCESSIBLE;
+ }
+ //create mddObject
+ if (retval == 0)
+ {
+ r_Storage_Layout* stl = new r_Storage_Layout(theTiling->clone());
+ //stl->set_storage_format(dataFormat, dataFormatParams);
+ mddObject = new (&db, mddTypeName) r_GMarray(mddDomain, 0, stl);
+ retval = initGMarray(mddObject, filePointer, inputFormat, mddDomain, inputFormatParams);
+ if (retval == 0)
+ {
+ collection->insert_element(mddObject);
+ ta.commit();
+ }
+ else
+ ta.abort();
+ }
+ else {
+ ta.abort();
+ }
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ else {//no collname, no collOId, create mdd
+ try {
+ openTransaction();
+ r_Storage_Layout* stl = new r_Storage_Layout(theTiling->clone());
+ //stl->set_storage_format(storageFormat, storageFormatParams);
+ mddObject = new (&db, mddTypeName) r_GMarray(mddDomain, 0, stl);
+ retval = initGMarray(mddObject, filePointer, inputFormat, mddDomain, inputFormatParams);
+ if (retval == 0)
+ {
+ collection->insert_element(mddObject);
+ ta.commit();
+ }
+ else
+ ta.abort();
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ }
+ }
+ else {
+ retval = MDDDOMAINNOTSPECIFIED;
+ }
+ }
+ else {
+ retval = FILENAMENOTSPECIFIED;
+ }
+ }
+ }
+ else {//create coll or insert existing mdd into existing coll
+ if (mddOIdDef)
+ {//insert existing mdd into existing coll
+ if (collOIdDef)
+ {//lookup mdd by oid, lookup coll by oid, insert mdd into coll
+ try {
+ openTransaction();
+ //get collection
+ try {
+ collection = db.lookup_object(collOId);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing collection " << collOId << ": " << obj.what() << endl;
+ retval = COLLECTIONINACCESSIBLE;
+ }
+ if (retval == 0)
+ {
+ //lookup mddObject
+ try {
+ mddObject = db.lookup_object(mddOId);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing mdd " << mddOId << ": " << obj.what() << endl;
+ retval = MDDINACCESSIBLE;
+ }
+ if (retval == 0)
+ {
+ collection->insert_element(mddObject);
+ ta.commit();
+ }
+ else {
+ ta.abort();
+ }
+ }
+ else {
+ ta.abort();
+ }
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ else {
+ if (collNameDef)
+ {//lookup mdd by oid, lookup coll by name
+ try {
+ openTransaction();
+ //get collection
+ try {
+ collection = db.lookup_object(collName);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing collection " << collName << ": " << obj.what() << endl;
+ retval = COLLECTIONINACCESSIBLE;
+ }
+ if (retval == 0)
+ {
+ //lookup mddObject
+ try {
+ mddObject = db.lookup_object(mddOId);
+ }
+ catch (r_Error& obj)
+ {
+ RMInit::logOut << "Error (" << obj.get_errorno() << ") accessing mdd " << mddOId << ": " << obj.what() << endl;
+ retval = MDDINACCESSIBLE;
+ }
+ if (retval == 0)
+ {
+ collection->insert_element(mddObject);
+ ta.commit();
+ }
+ else {
+ ta.abort();
+ }
+ }
+ else {
+ ta.abort();
+ }
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ else {//no coll name, no coll oid, error
+ retval = NOCOLLNAMENOCOLLOID;
+ }
+ }
+ }
+ else {//do not create mdd, do not insert mdd into coll
+ if (setTypeDef)
+ {//create coll
+ //open stuff
+ try {
+ openTransaction();
+ try {
+ collection = new (&db, setTypeName) r_Set< r_Ref< r_GMarray > >;
+ if (collNameDef)
+ {//object.cc insert in db will throw r_error without name
+ db.set_object_name(*collection, collName);
+ }
+ ta.commit();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at creating collection: " << obj.what() << endl;
+ retval = EXCEPTIONCREATECOLL;
+ ta.abort();
+ }
+ //create mddObject
+ db.close();
+ }
+ catch (r_Error& obj)
+ {
+ cout << "Exception (" << obj.get_errorno() << ") at administrative action: " << obj.what() << endl;
+ retval = EXCEPTIONADMIN;
+ ta.abort();
+ db.close();
+ }
+ }
+ else {
+ retval = NOCOLLTYPE;
+ }
+ }
+ }
+ }
+ else {
+ //errors occured in check arguments
+ }
+ }
+ explainRetval(retval);
+ return retval;
+ }
+
+void
+SystemInsert::printUsage()
+ {
+ cout << "Insert program for extended systemtest" << endl << endl;
+ SystemBasic::printOptions();
+ cout << "Actions: Create and insert MDD object" << endl;
+ cout << " required information: MDD type" << endl;
+ cout << " Collection name or oid" << endl;
+ cout << " MDD domain" << endl;
+ cout << " File name with data" << endl;
+ cout << " Create MDD object (is not supported by rasdaman)" << endl;
+ cout << " required information: MDD type" << endl;
+ cout << " MDD domain" << endl;
+ cout << " File name with data" << endl;
+ cout << " Create Collection object" << endl;
+ cout << " required information: Collection type" << endl;
+ cout << " optional information: Collection name" << endl;
+ cout << " Insert existing MDD in existing Collection (is not supported by rasdaman)" << endl;
+ cout << " required information: MDD oid" << endl;
+ cout << " Collection name or oid" << endl;
+ cout << endl;
+ }
generated by cgit (git 2.34.1) at 2024-04-26 14:16:26 +0000