Initial commitv8.0

1 files changed, 720 insertions, 0 deletions

diff --git a/rasodmg/test/deletecollection.cc b/rasodmg/test/deletecollection.cc
new file mode 100644
index 0000000..6cade1e
--- /dev/null
+++ b/rasodmg/test/deletecollection.cc
@@ -0,0 +1,720 @@
+/*
+* 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: deletecollection.cc
+ *
+ * MODULE: rasodmg
+ *
+ * PURPOSE:
+ *
+ *
+ ************************************************************/
+
+#ifdef EARLY_TEMPLATE
+#define __EXECUTABLE__
+#include "raslib/template_inst.hh"
+#endif
+
+#ifdef __VISUALC__
+#include <strstrea.h>
+#else
+#include <strstream.h>
+#endif
+
+#include <iostream>
+#include <iomanip.h>
+#include <string.h>
+#include <fstream.h>
+
+#include <math.h>
+
+#ifdef __VISUALC__
+  #define __EXECUTABLE__
+#endif
+
+#include "include/basictypes.hh"
+#include "raslib/type.hh"
+#include "rasodmg/storagelayout.hh"
+#include "rasodmg/alignedtiling.hh"  
+
+#ifdef __VISUALC__
+  #undef  __EXECUTABLE__
+#endif
+
+static int INIT = 0;
+
+static long minNo = 0;
+static long maxNo = 0;
+static ifstream fileStream;
+
+r_ULong initWithCounter( const r_Point& /*pt*/ )
+{
+  return INIT++;
+}
+
+
+r_Char initWithCounterChar( const r_Point& /*pt*/ )
+{
+  return (r_Char) INIT++;
+}
+
+
+r_UShort initWithCounterUShort( const r_Point& /*pt*/ )
+{
+  return (r_UShort) INIT++;
+}
+
+
+
+r_ULong initWithCrossfoot( const r_Point& pt )
+{
+  r_ULong value=0;
+  
+  for( r_Dimension i=0; i< pt.dimension(); i++ )
+    value += (r_ULong)pt[i];
+  
+  return value;
+}
+
+
+r_ULong initWithCoordinates( const r_Point& pt )
+{
+   r_ULong value=0;
+   r_ULong factor=1;
+  
+  for( int i=pt.dimension()-1; i >= 0; i-- )
+  {   
+    value  += (r_ULong)(factor * pt[i]);
+    factor *= 100;
+  }
+    
+  return value;
+}
+
+
+
+r_Char initWithCurve( const r_Point& pt )
+{
+  r_ULong value=0;
+  
+  for( r_Dimension i=0; i < pt.dimension(); i++ )
+    value  += (r_Char)( 255* sin( .25 * (float)pt[i] ) );
+    
+  return (r_Char)value;
+}
+
+
+
+r_ULong initWithColorCube( const r_Point& pt )
+{
+   r_ULong value=0;
+  
+  if( pt.dimension() == 3 )
+    value = ((unsigned long)(pt[0]) << 16) + ((unsigned long)(pt[1]) << 8) + (unsigned long)(pt[2]);
+    
+  return value;
+}
+
+
+r_Char initWithRandomChar( const r_Point& /*pt*/ )
+{
+  // rand creates numbers between 0 and 32767
+  unsigned long number = rand();
+  double        factor = (maxNo - minNo)/32767.0;
+
+  return (r_Char)(minNo + (number * factor));
+}
+
+r_ULong initWithRandomULong( const r_Point& /*pt*/ )
+{
+  // rand creates numbers between 0 and 32767
+  unsigned long number = rand();
+  double        factor = (maxNo - minNo)/32767.0;
+
+  return (r_ULong)(minNo + (number * factor));
+}
+
+
+r_Char initFromFile( const r_Point& /*pt*/ )
+{
+  char ch;
+
+  if( fileStream.get(ch) )
+    return ch;
+  else
+    return 0;
+}
+
+/*
+r_Ref< r_Marray<r_ULong> > readFile( r_Database& db )
+{
+  r_Ref< r_Marray<r_ULong> > image;
+  r_Minterval            domain(3);
+  long                   dx, dy, dz, depth, cx, cy, cz;
+  int                    i;
+  
+  ifstream fileStream( "hw8.full.vol" );
+  if( !fileStream )
+  {
+    cout << "Error: File not found." << endl;
+    exit(-1);
+  }
+ 
+  // read the first 16 bytes
+  char charDummy;
+  for( i=0; i<16; i++ )
+    fileStream >> charDummy;
+  
+  dx    = 256;
+  dy    = 256;
+  dz    = 20;
+  depth = 8;
+
+  domain << r_Sinterval( 0l, (long)(dx-1) ) << r_Sinterval( 0l, (long)(dy-1) ) << r_Sinterval( 0l, (long)(dz-1) );
+
+  cout << domain << "... "; cout.flush();
+  
+  image = new( &db ) r_Marray<r_ULong>( domain );  
+
+  unsigned long* dataPtr = (unsigned long*)image->get_array();
+  
+  r_Point pt(3);
+  
+  //  for( i=0; i<dx*dy*(221-dz); i++ )
+  //    fileStream >> charDummy;    
+  
+  for( cz = 0; cz < dz; cz++ )
+  {
+    pt[2] = cz;
+    for( cy = 0; cy < dy; cy++ )
+    {
+      pt[1] = cy;
+      for( cx = 0; cx < dx; cx++ )
+      {
+        unsigned char ch;
+        fileStream.get(ch);
+
+	pt[0] = cx;	
+        dataPtr[domain.cell_offset(pt)] = ((unsigned long)ch << 16) +
+                                          ((unsigned long)ch << 8) +
+                                          ((unsigned long)ch);
+      }
+    }
+  }
+  
+  fileStream.close();
+  
+  return image;
+}
+*/	       
+		       
+		       
+void printColl( r_Ref< r_Set< r_Ref< r_GMarray > > >& image_set, int output, int hexOutput )
+{
+  cout << "Collection" << endl;
+  cout << "  Oid...................: " << image_set->get_oid() << endl;
+  cout << "  Type Name.............: " << image_set->get_object_name() << endl;
+  cout << "  Type Structure........: " 
+       << ( image_set->get_type_structure() ? image_set->get_type_structure() : "<nn>" ) << endl;
+  cout << "  Type Schema...........: " << flush;
+  if( image_set->get_type_schema() )
+    image_set->get_type_schema()->print_status( cout );
+  else
+    cout << "<nn>" << flush;
+  cout << endl;
+  cout << "  Number of entries.....: " << image_set->cardinality() << endl;
+  cout << "  Element Type Schema...: " << flush;
+  if( image_set->get_element_type_schema() )
+    image_set->get_element_type_schema()->print_status( cout );
+  else
+    cout << "<nn>" << flush;
+  cout << endl;
+
+  r_Iterator< r_Ref< r_GMarray > > iter = image_set->create_iterator();
+  
+  cout << endl;
+  for ( int i=1 ; iter.not_done(); iter++, i++ )
+  {
+    // do not dereference the object
+    cout << "Image " << i << " oid: " << (*iter).get_oid() << endl;
+
+    if( output )
+    {
+      (*iter)->print_status( cout, hexOutput );   
+      cout << endl;
+    }
+  }
+  cout << endl;
+}
+
+
+
+int checkArguments( int argc, char** argv, const char* searchText, int& optionValueIndex )
+{
+  int found = 0;
+  int i=1;
+
+  while( !found && i<argc )
+    found = !strcmp( searchText, argv[i++] );   
+
+  if( found && i<argc && !strchr(argv[i],'-') )
+    optionValueIndex = i;
+  else
+    optionValueIndex = 0;
+  
+  return found;
+}
+
+
+
+int main( int argc, char** argv )
+{   
+  int  optionValueIndex=0; 
+  int  testbed = 0;
+  unsigned long tileSize=0;
+  r_Minterval   tileConfig;
+  int  compressed=0;
+
+  char serverName[255];
+  char baseName[255];
+  char collName[255];
+  char setTypeName[255] = "";
+  char mddTypeName[255] = "";
+  char fileName[255]="";
+   
+  if( argc < 4 || checkArguments( argc, argv, "-h", optionValueIndex ) )
+  {
+    cout << "Usage:   test_insert3 server_name base_name collection_name [options]" << endl << endl;
+    cout << "Options: -h                  ... this help" << endl;
+    cout << "         -settype <typename> ... type name used for creation of a new set." << endl;
+    cout << "         -mddtype <typename> ... type name used for creation of a new mdd object." << endl;
+    cout << "         -testbed            ... turn on output for testbed" << endl;
+    cout << "         -tileconf           ... tile configuration" << endl;
+    cout << "         -tilesize           ... tile size" << endl;
+    cout << "         -file <filename>    ... file name used to read data from a file" << endl;
+    cout << "         -compressed         ... inserts MDD in compressed format" << endl;
+    cout << endl;
+    return 0;
+  }
+
+  strcpy( serverName, argv[1] );
+  strcpy( baseName, argv[2] );
+  strcpy( collName, argv[3] );
+
+  if( checkArguments( argc, argv, "-settype", optionValueIndex ) && optionValueIndex )
+    strcpy( setTypeName, argv[optionValueIndex] );
+
+  if( checkArguments( argc, argv, "-mddtype", optionValueIndex ) && optionValueIndex )
+    strcpy( mddTypeName, argv[optionValueIndex] );
+
+  testbed   =  checkArguments( argc, argv, "-testbed", optionValueIndex );
+
+  if( checkArguments( argc, argv, "-tileconf", optionValueIndex ) && optionValueIndex )
+    tileConfig = r_Minterval( argv[optionValueIndex] );
+
+  if( checkArguments( argc, argv, "-tilesize", optionValueIndex ) && optionValueIndex )
+    tileSize = strtoul( argv[optionValueIndex], (char **)NULL, 10 ) ;
+
+  if( checkArguments( argc, argv, "-file", optionValueIndex ) && optionValueIndex )
+    strcpy( fileName, argv[optionValueIndex] );
+
+  compressed =  checkArguments( argc, argv, "-compressed", optionValueIndex );
+
+  cout << endl << endl;
+  cout << "Insertion of one MDD into the database" << endl;
+  cout << "======================================" << endl << endl;
+    
+  r_Database db;
+  r_Transaction ta;
+  r_Ref< r_Set< r_Ref< r_GMarray > > >  image_set;
+  r_Ref< r_GMarray >                    image;
+  r_Minterval                           domain;
+  r_Dimension                           dim;
+  r_Range                               low, high;
+  unsigned long                         initMode, initValue;
+
+  RGBPixel                              rgbValue = { 1, 2, 3 };
+
+  db.set_servername( serverName );
+  
+  try
+  {
+    /*
+    cout << "MDD Initialization:  0 - Marray<r_ULong> with constant" << endl;
+    cout << "                     1 - Marray<r_ULong> with counter" << endl;
+    cout << "                     2 - Marray<r_ULong> with coordinates" << endl;
+    cout << "                     3 - Marray<r_ULong> with crossfoot" << endl;
+    cout << "                     4 - Marray<r_ULong> with color cube" << endl << endl;
+    
+    cout << "                     5 - Marray<r_Char> with constant" << endl;
+    cout << "                     6 - insert RGBImage with constant" << endl;
+    cout << "                     7 - Marray<r_Char>  with 255*( sin(.25*x1) + ... + sin(.25*xn) )" << endl;
+    
+    cout << "                     8 - Marray<r_ULong> read a file (hw8.full.vol)" << endl;
+    cout << "                     9 - Create just an empty collection of type Marray<r_ULong>" << endl;
+    cout << "                    10 - Delete collection of type GMarray" << endl;
+    cout << "                    11 - Delete an object of collection" << endl;
+
+    cout << "                    13 - Marray<r_Char> with counter" << endl;
+    cout << "                    14 - Marray<r_Char> with random numbers" << endl;
+    cout << "                    15 - Marray<r_UShort> with counter" << endl;
+    cout << "                    16 - Marray<r_ULong>  with random numbers" << endl;
+    cout << "                    17 - Marray<r_Boolean>" << endl;
+    cout << "                    18 - Marray<r_Char> from file" << endl;
+
+    cin  >> initMode;
+    cout << endl;
+    */
+    initMode = 10;
+
+    if( initMode == 18 )
+    {
+      fileStream.open( fileName );
+      if( !fileStream )
+      {
+        cout << "Error: File " << fileName << " not found." << endl;
+        exit(-1);
+      }
+    }
+
+    if( initMode == 0 || initMode == 5 || initMode == 17 )
+    {
+      cout << "Constant value : ";
+      cin  >> initValue;
+      cout << endl;
+    }
+    if( initMode <= 7 || initMode >= 13 )
+    {
+      cout << "Number of dimensions : ";
+      cin  >> dim;
+      cout << endl;
+    
+      domain = r_Minterval(dim);
+    
+      for( r_Dimension i = 1; i<=dim ; i++ )
+      {
+        cout << "Dimension " << setw(2) << i << " lower bound ";
+        cin  >> low;
+        cout << "             upper bound ";
+        cin  >> high;
+      
+        domain << r_Sinterval( low, high );
+      }
+    
+      cout << endl;
+    }
+     
+    if( initMode == 14 || initMode == 16 )
+    {
+      cout << "Minimum number : ";
+      cin  >> minNo;
+      cout << endl;
+
+      cout << "Maximum number : ";
+      cin  >> maxNo;
+      cout << endl;
+    }
+
+    cout << "Opening Database " << baseName << " on " << serverName << "... "; cout.flush();
+    db.open( baseName );
+    cout << "OK" << endl;
+  
+    cout << "Starting Transaction ... " << flush;
+    ta.begin();
+    cout << "OK" << endl;
+
+    cout << "Opening the set ... " << flush;
+
+    if( initMode == 10 || initMode == 11 )
+    {
+      //
+      // get the set
+      //
+
+      try{
+        image_set = db.lookup_object( collName );
+      }
+      catch( r_Error &obj )
+      {
+        cout << "FAILED" << endl;
+        cout << obj.what() << endl;
+        return -1;
+      }
+
+      cout << "OK" << endl;
+
+      if( initMode == 10 )
+      {
+        // delete the set
+
+        if( !image_set.is_null() )
+	  image_set.delete_object();
+        // delete image_set; (not implemented yet)
+      }
+      else
+      {
+        int imageNo=0;
+
+        printColl( image_set, 0, 0 );
+
+        cout << "Please enter the image number to delete: ";
+        cin  >> imageNo;
+        cout << endl;
+
+        r_Iterator< r_Ref< r_GMarray > > iter = image_set->create_iterator();
+  
+        for ( int i=1; iter.not_done() && i<imageNo; iter++, i++ );
+ 
+        if( imageNo && iter.not_done() )
+	{
+          image_set->remove_element( *iter );
+	  cout << "MDD removed." << endl;
+	}
+        else
+          cout << "Number not valid." << endl << endl;
+      }
+    }
+    else
+    {    
+      //
+      // get set
+      //
+
+      try{
+        image_set = db.lookup_object( collName );
+      }
+      catch( r_Error& /*obj*/ )
+      {
+        cout << "FAILED" << endl;
+        // cout << obj.what() << endl;
+
+        //
+        // set doesn't exist -> create the set
+        //
+
+        cout << "Create the set ... " << flush;
+
+        if( initMode == 5 || initMode == 7 || initMode == 13 || initMode == 14 || initMode == 18 )
+	{
+          if( !strlen( setTypeName ) )
+            strcpy( setTypeName, "GreySet" );
+
+          image_set = new( &db, setTypeName  ) r_Set< r_Ref< r_Marray<r_Char> > >;
+        }
+        else if( initMode == 6 )
+	{
+          if( !strlen( setTypeName ) )
+            strcpy( setTypeName, "RGBSet" );
+
+          image_set = new( &db, setTypeName  ) r_Set< r_Ref< r_Marray<RGBPixel> > >;
+        }
+        else if( initMode == 15 )
+	{
+          if( !strlen( setTypeName ) )
+            strcpy( setTypeName, "UShortSet" );
+
+          image_set = new( &db, setTypeName  ) r_Set< r_Ref< r_Marray<r_UShort> > >;
+        }
+        else if( initMode == 17 )
+        {
+          if( !strlen( setTypeName ) )
+            strcpy( setTypeName, "BoolSet" );
+     
+          image_set = new( &db, setTypeName ) r_Set< r_Ref< r_Marray<r_Boolean> > >;
+        }
+        else
+	{       
+          if( !strlen( setTypeName ) )
+            strcpy( setTypeName, "ULongSet" );
+
+          image_set = new( &db, setTypeName  ) r_Set< r_Ref< r_Marray<r_ULong> > >;
+        }
+
+        // create a name for the persistent set in order to be able to look it up again
+        db.set_object_name( *image_set, collName );
+      }
+
+      cout << " with type name " << setTypeName << " ... OK" << endl;
+
+      cout << "OId of the set is " << image_set->get_oid() << " ... " << endl;
+
+      if( initMode <= 9 || initMode >= 13 )
+      {
+        cout << "Creating an image ..." << flush;
+
+        // create storage layout object
+        r_Storage_Layout* stl = 0;
+        if( tileSize )
+          stl = new r_Storage_Layout( new r_Aligned_Tiling( tileConfig, tileSize ) );
+
+        if( compressed )
+	{
+          if( !stl )
+	    stl = new r_Storage_Layout();
+
+          db.set_storage_format( r_ZLib );
+        }
+
+        // create the image
+        switch( initMode )
+        {
+          case 0:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, (r_ULong)initValue, stl );
+            break;
+          case 1:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, &initWithCounter, stl );
+            break;
+          case 2:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, &initWithCoordinates, stl );
+            break;
+          case 3:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, &initWithCrossfoot, stl );
+            break;
+          case 4:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, &initWithColorCube, stl );
+            break;
+          case 5:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "GreyImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_Char>( domain, (r_Char)initValue, stl );
+            break;
+          case 6:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "RGBImage" );
+
+            image = new( &db, mddTypeName  )  RGBImage( domain, rgbValue, stl );
+            break;
+          case 7:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "GreyImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_Char>( domain, &initWithCurve, stl );
+            break;
+          case 13:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "GreyImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_Char>( domain, &initWithCounterChar, stl );
+            break;
+          case 14:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "GreyImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_Char>( domain, &initWithRandomChar, stl );
+            break;
+          case 15:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "UShortImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_UShort>( domain, &initWithCounterUShort, stl );
+            break;
+          case 16:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, &initWithRandomULong, stl );
+            break;
+          case 17:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "BoolImage" );
+
+            image = new( &db, mddTypeName ) r_Marray<r_Boolean>( domain, (r_Boolean)initValue, stl );
+            break;
+          case 18:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "GreyImage" );
+
+            image = new( &db, mddTypeName ) r_Marray<r_Char>( domain, &initFromFile, stl );
+            break;
+          default:
+            if( !strlen( mddTypeName ) )
+              strcpy( mddTypeName, "ULongImage" );
+
+            image = new( &db, mddTypeName  ) r_Marray<r_ULong>( domain, (r_ULong)0, stl );	 
+        }
+    
+        cout << "OId of the new image is " << image->get_oid() << endl;
+
+        cout << "Inserting one image with domain " << domain << " into collection " << collName << "..." << flush;
+        // put in into the persistent list
+        image_set->insert_element( image );      
+        cout << "OK" << endl << endl;
+
+        if( testbed )
+        {
+          cout << endl << "Testbed output:" << endl;
+          cout << "-- Testbed: set_oid=" << image_set->get_oid() << endl;
+          cout << "-- Testbed: image_oid=" << image->get_oid() << endl;
+          cout << endl;
+        }
+  
+      }
+    }
+       
+    try
+    {
+      cout << "Committing Transaction ... " << flush;
+      ta.commit();
+      cout << "OK" << endl;
+    }
+    catch( r_Error &obj )
+    {
+      cerr << obj.what() << endl;
+      return -1;
+    }
+   
+    cout << "Closing Database ... " << flush;
+    db.close();
+    cout << "OK" << endl; 
+
+    if( initMode == 18 )
+      fileStream.close();
+  }
+  catch( r_Error& errorObj )
+  {
+     cerr << errorObj.what() << endl;
+     return -1;
+  }
+    
+  return 0;
+}
+
+
+