1 files changed, 324 insertions, 0 deletions
diff --git a/mddmgr/test/test_extendobjs.cc b/mddmgr/test/test_extendobjs.cc
new file mode 100644
index 0000000..73f82b3
--- /dev/null
+++ b/mddmgr/test/test_extendobjs.cc
@@ -0,0 +1,324 @@
+/*
+* 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: test_extendobjs.cc
+ *
+ * MODULE: cachetamgr 
+ *
+ * PURPOSE:
+ *   Extends the objects created by the test of directional tiling
+ *   rasodmg/test/test_dir1 (the resulting objects have 4 times more 
+ *   products and 2 times more stores than the original ones ).
+ *   Needed because rasodmg doens't support updating of MDDobjects
+ *   at the time this was created.
+ *   
+ *
+ * COMMENTS:
+ *   none
+ *
+*/
+
+#define TEST_PROTECTED 
+#define TEST_PRIVATE
+
+#include <stdlib.h>
+#include <iostream>
+
+#include "ulongtype.hh"
+
+#include "mddmgr/persmddcoll.hh"
+#include "mddmgr/persmddobj.hh"
+#include "mddmgr/perstile.hh"
+
+#include "mddmgr/persmddcolliter.hh"
+
+#include "adminif.hh"
+#include "databaseif.hh"
+#include "transactionif.hh"
+#include "oidif.hh"
+
+#include "raslib/rminit.hh"
+#include "typefactory.hh"
+
+#include "mddif/dbmddobj.hh"
+#include "mddif/dbmddcoll.hh"
+
+#include "mddbasetype.hh"
+#include "mdddomaintype.hh"
+#include "settype.hh"
+
+
+/* 
+  Global Variables 
+*/
+extern char* myExecArgv0 = "";
+
+RMINITGLOBALS('C')
+
+static char* O2DBName;
+char *collName;
+char defaultCollName[]= "ObjsContainer";
+
+TransactionIf ta;
+
+/* 
+  Functions
+*/
+
+// 2 - Populate collection with MDD objects
+static void testConstructors( char* cn , int s, int p);
+
+// 3 - Retrieves an MDD collection with name cn and prints contents:
+static void testAccessing( char* cn );
+
+
+/*************************************************************
+ * Function name.: int main( int argc, char** argv)
+ *
+ * Arguments.....: 
+ *   argc: number of arguments given to program
+ *   argv: array of char* with arguments
+ * Return value..: exit status
+ * Description...: none
+ ************************************************************/
+int
+main( int argc, char** argv)
+{
+  // variables representing O2 database, ta and session
+  DatabaseIf database;
+
+  if( argc < 2 ) {
+    cout << "Usage: test_persmddcoll <database> [collName]" << endl;
+    return -1;
+  }
+  O2DBName = strdup( argv[1] );
+  if ( argc == 3 ) collName = strdup( argv[2] );
+  else 
+    collName = defaultCollName;
+
+  // don't forget to initialize before using AdminIf!
+  myExecArgv0 = argv[0];
+  AdminIf* myAdmin = AdminIf::instance();
+  
+  
+  // connect to the database
+  cout << "Connecting to database " << O2DBName 
+       << "..." << endl;
+  int errorDBOpen;
+  try{
+    errorDBOpen =  database.open( O2DBName );
+  }
+  catch( ...) 
+  {
+     cout << "Caught Exception " << endl;
+     errorDBOpen = -6;
+  }
+  if ( errorDBOpen < 0 )
+  {
+    cout << "Database doesn't exist. Create it new ... " << endl;
+    cout << "Creating new database " << O2DBName
+       << "..." << endl;
+    database.create( O2DBName, "TestSMSchema" );
+    cout << "Connecting to database " << O2DBName 
+       << "..." << endl;
+    try{
+      errorDBOpen =  database.open( O2DBName );
+    }
+    catch(...)
+    {
+       errorDBOpen = -6;
+    }
+  }    
+  if ( errorDBOpen < 0 )
+  {
+    cout << "Failed at opening newly created database " << errorDBOpen << endl;
+    cout << "Exiting " << endl;
+    return errorDBOpen;
+  }
+  
+  char c;
+ 
+  for( int p = 0; p < 4; p++ )
+  {
+    for ( int s = 0; s < 2 ; s++) 
+    {
+      ta.begin( &database );	
+      cout << endl << "Populate collection " << s <<" " << p << " ..." << endl;
+      testConstructors( collName, s, p );
+      cout <<"Transaction abort (A/a) or commit (default)? ";
+      cin >> c;
+      if ( c == 'A' || c == 'a' )
+     {
+        ta.abort( );
+        cout <<"End of Transaction Abort..."<<endl;
+      }
+      else 
+      {
+	ta.commit( );  
+        cout <<"End of transaction commit... "<<endl;
+      }
+    }
+  }
+  
+  
+  ta.begin(&database );
+   // read coll and print contents 
+  cout << endl << "Read collection " << collName << " and print contents..." << endl;
+  testAccessing( collName );
+  ta.commit( );
+  cout <<"End of transaction commit... "<<endl;
+  
+  cout << endl << "Ending O2 session..." << endl;
+  database.close( );
+  delete myAdmin;
+  
+  free( O2DBName );
+  if ( collName != defaultCollName ) free( collName );
+  return 0;
+ 
+}
+
+/*************************************************************
+ * Functions......: 
+ *
+ *    static void 
+ *    testConstructors( char* collName )
+ *
+ ************************************************************/
+static void testConstructors( char* collName, int s, int p )
+{
+
+  const BaseType* mddType;
+  char* uLongCells;
+  
+  cout << "....testConstructors"<< endl;
+
+
+  PersMDDObj* accessedObj;
+  
+  try{
+    PersMDDColl objsSet(collName);
+
+    cout << "Iterating through the collection with PersMDDCollIter " << endl;
+    MDDCollIter* objsIt = objsSet.createIterator( );
+  
+    for( int i = 1 ; objsIt->notDone( ); i++, objsIt->advance( ))
+    {
+      cout << endl << i<<". MDD object in set:" << endl;
+      accessedObj = (PersMDDObj*) objsIt->getElement();
+      // accessedObj->printStatus();
+      EOId eoid;
+      if ( accessedObj->getEOId( &eoid ) ==0 )
+       cout <<"EOId: " << eoid;
+      cout << endl << endl;
+
+      mddType = accessedObj->getCellType( );
+      
+      r_Minterval firstYear("[1:365,1:60,1:100]");
+
+      vector< Tile* >* firstYearTiles = accessedObj->intersect( firstYear );    
+     
+      for ( int j = 0; j < firstYearTiles->size( ); j++ )
+      {
+        r_Minterval dom = (*firstYearTiles)[j]->getDomain( );
+	
+/*
+        for( int p = 0; p < 4; p++ )
+        {
+          for ( int s = 0; s < 2 ; s++) 
+          {
+*/
+            r_Point desl( (r_Range) 730, (p+1)*60, (s+1)* 100 ); 
+
+	    r_Minterval newDom( dom.dimension( ) );
+	    newDom.intersection_of( dom, "[1:365,1:60,1:100]");
+            newDom.translate( desl );
+	    cout << "dom" << dom << "newDom " << newDom << endl;
+
+            int sz = mddType->getSize( ) * newDom.cell_count( );
+            uLongCells = new char[sz];
+            PersTile* tile1Obj1 = new PersTile( newDom, mddType, uLongCells );
+            accessedObj->insertTile(tile1Obj1);
+	    
+/*
+          }
+        }
+	
+*/
+      }
+      delete firstYearTiles;
+    }
+
+    delete objsIt;
+ 
+    cout << "Release all " << endl;
+    objsSet.releaseAll( );
+  }
+  catch ( r_Error& errObj)
+  {
+   cout << "Error caught when opening collection" << endl;
+  }
+
+}
+
+
+/*************************************************************
+ * Function......: testAccessing( char* cn )
+ ************************************************************/
+
+static void testAccessing( char* cn )
+{
+  PersMDDObj* accessedObj;
+  
+  cout << "....testAccessing collection "<< cn << endl;
+  
+  try{
+    PersMDDColl objsSet( cn );
+
+    // To test PersMDDColl::printStatus( )
+    // objsSet.printStatus( );
+  
+    // To test PersMDDObj::printStatus( ), MDDCollIter::createIterator( ) and
+    // MDDCollIter methods :
+
+    cout << "Iterating through the collection with PersMDDCollIter " << endl;
+    MDDCollIter* objsIt = objsSet.createIterator( );
+  
+    for( int i = 1 ; objsIt->notDone( ); i++, objsIt->advance( ))
+    {
+      cout << i<<". MDD object in set:" << endl;
+      accessedObj = (PersMDDObj*) objsIt->getElement();
+      accessedObj->printStatus();
+      EOId eoid;
+      if ( accessedObj->getEOId( &eoid ) ==0 )
+       cout <<"EOId: " << eoid;
+    }
+    delete objsIt;
+    objsSet.releaseAll( );
+  }
+  catch ( r_Error& errObj)
+  {
+    cout <<"Error caught ................."<< endl;
+  } 
+}
+