Initial commitv8.0

1 files changed, 329 insertions, 0 deletions

diff --git a/relblobif/dbtile.cc b/relblobif/dbtile.cc
new file mode 100644
index 0000000..4c9d928
--- /dev/null
+++ b/relblobif/dbtile.cc
@@ -0,0 +1,329 @@
+/*
+* 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>.
+*/
+#include "mymalloc/mymalloc.h"
+// This is -*- C++ -*-
+/*************************************************************
+ *
+ *
+ * PURPOSE:
+ *
+ *
+ * COMMENTS:
+ *   uses embedded SQL 
+ *
+ ************************************************************/
+
+static const char rcsid[] = "@(#)blobif,DBTile: $Id: dbtile.cc,v 1.12 2005/09/03 20:41:40 rasdev Exp $";
+
+#include "dbtile.hh"
+#include "raslib/rmdebug.hh"
+#include "reladminif/externs.h"
+#include "reladminif/sqlerror.hh"
+#include "raslib/error.hh"
+#include "reladminif/objectbroker.hh"
+#include "blobtile.hh"
+#include "inlinetile.hh"
+#include "reladminif/dbref.hh"
+#include "debug.hh"	// for ENTER/LEAVE/TALK macros
+
+#include "unistd.h"
+#include <iostream>
+#include <cstring>
+#include <vector>
+
+#ifdef BASEDB_ORACLE
+	#include <oratypes.h>
+	#include <oci.h>
+	#include <sqlca.h>	
+#endif
+
+
+r_Data_Format
+DBTile::getDataFormat() const
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "getDataFormat() const " << myOId << " " << dataFormat);
+	return dataFormat;
+	}
+
+r_Data_Format
+DBTile::getCurrentFormat() const
+	{
+	return currentFormat;
+	}
+
+void
+DBTile::setCurrentFormat(const r_Data_Format& dataformat) const
+	{
+	currentFormat = dataformat;
+	}
+
+void
+DBTile::setDataFormat(const r_Data_Format& dataformat)
+	{
+	dataFormat = dataformat;
+	setModified();
+	}
+
+r_Bytes
+DBTile::getMemorySize() const
+	{
+	return size * sizeof(char) + sizeof(char*) + sizeof(r_Data_Format) + DBObject::getMemorySize() + sizeof(r_Bytes);
+	}
+
+void
+DBTile::setCells(char* newCells)
+	{
+        if(cells != newCells) {
+		if(cells != NULL) {
+			TALK( "DBTile::setCells() freeing blob cells" );
+			free(cells);
+			// cells = NULL; 	// added PB 2005-jan-10
+		}
+		cells = newCells;
+		setModified();
+		}
+	}
+
+void
+DBTile::setNoModificationData(char* newCells) const
+	{
+        if(cells != newCells) {
+		if(cells != NULL) {
+			TALK( "DBTile::setNoModificationData() freeing blob cells" );
+			free(cells);
+			// cells = NULL; 	// added PB 2005-jan-10
+		}
+		cells = newCells;
+		}
+	}
+
+void
+DBTile::setNoModificationSize(r_Bytes newSize) const
+	{
+	size = newSize;
+	}
+
+char*
+DBTile::getCells()
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "getCells() " << myOId);
+	setModified();
+	return cells;
+	}
+
+const char*
+DBTile::getCells() const
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "getCells() const " << myOId);
+	return cells;
+	}
+
+char
+DBTile::getCell(r_Bytes index) const
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "getCell(" << index << ") const " << myOId);
+	return cells[index];
+	}
+
+r_Bytes 
+DBTile::getSize() const
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "getSize() const " << myOId << " " << size);
+	return size;
+	}
+
+void
+DBTile::setCell(r_Bytes index, char newCell)
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "setCell(" << index << ", " << (int)newCell << ") " << myOId);
+	setModified();
+	cells[index] = newCell;
+	}
+
+DBTile::DBTile(r_Data_Format dataformat)
+	:	DBObject(),
+		size(0),
+		cells(NULL),
+		dataFormat(dataformat),
+		currentFormat(r_Array)
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "DBTile(" << dataFormat << ")");
+	objecttype = OId::INVALID;
+	}
+
+DBTile::DBTile(r_Bytes newSize, char c, r_Data_Format dataformat) 
+	:	DBObject(),
+		size(newSize),
+		cells(NULL),
+		currentFormat(r_Array),
+		dataFormat(dataformat)
+	{
+	RMDBGENTER(3, RMDebug::module_blobif, "DBTile", "DBTile(" << newSize << ", '(int)" << (int) c << "', " << dataFormat << ")");
+
+	TALK( "DBTile::DBTile() allocating " << newSize << " bytes for blob cells, previous ptr was " << (long) cells );
+	cells = (char*)mymalloc(newSize * sizeof(char));
+	objecttype = OId::INVALID;
+	memset(cells, c, size);
+
+	RMDBGEXIT(3, RMDebug::module_blobif, "DBTile", "DBTile(" << newSize << ", '(int)" << (int) c << "', " << dataFormat << ") " << myOId);
+	}
+
+DBTile::DBTile(r_Bytes newSize, r_Bytes patSize, const char* pat, r_Data_Format dataformat)
+	:	DBObject(),
+		size(newSize),
+		cells(NULL),
+		currentFormat(r_Array),
+		dataFormat(dataformat)
+	{
+	RMDBGENTER(3, RMDebug::module_blobif, "DBTile", "DBTile(" << newSize << ", " << patSize << ", pattern, " << dataFormat << ")");
+	objecttype = OId::INVALID;
+
+	TALK( "DBTile::DBTile() allocating " << newSize << " bytes for blob cells, previous ptr was " << (long) cells );
+	cells = (char*)mymalloc(newSize * sizeof(char));
+
+	r_Bytes i = 0;
+	r_Bytes j = 0;
+
+	if (patSize >= size)
+		{
+		// fill cells with pattern
+		for (j = 0; j < size; j++)
+			{
+			cells[j] = pat[j];
+			}
+		}
+	else	{
+		if (patSize >= 0)
+			{
+			// fill cells with repeated pattern
+			for (i = 0; i < size; i += patSize)
+				{
+				for (j = 0; j < patSize; j++)
+					{
+					cells[(i+j)]= pat[j];
+					}
+				}
+			// pad end with 0
+			if (i != size)
+				{
+				// no padding necessary
+				i -= patSize;
+				for (; i < size; i++)
+					{
+					cells[i]=0;
+					}
+				}
+			}
+		else	{
+			// fill cells with 0
+			for (i = 0; i < size; i++)
+				{
+				cells[i] = 0;
+				}
+			}
+		}
+
+	RMDBGEXIT(3, RMDebug::module_blobif, "DBTile", "DBTile(" << newSize << ", " << patSize << ", pattern, " << dataFormat << ") " << myOId);
+	}
+
+DBTile::DBTile(r_Bytes newSize, const char* newCells, r_Data_Format dataformat) 
+	:	DBObject(),
+		size(newSize),
+		cells(0),
+		dataFormat(dataformat),
+		currentFormat(r_Array)
+	{
+	RMDBGENTER(3, RMDebug::module_blobif, "DBTile", "DBTile(" << size << ", data, " << dataFormat << ")");
+
+	TALK( "DBTile::DBTile() allocating " << newSize << " bytes for blob cells, previous ptr was " << (long) cells );
+
+	cells = (char*)mymalloc(size * sizeof(char));
+	objecttype = OId::INVALID;
+	memcpy(cells, newCells, newSize);
+
+	RMDBGEXIT(3, RMDebug::module_blobif, "DBTile", "DBTile(" << size << ", data, " << dataFormat << ") " << myOId);
+	}
+
+DBTile::DBTile(const OId& id) throw (r_Error)
+	:	DBObject(id),
+		size(0),
+		cells(NULL),
+		currentFormat(r_Array)
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "DBTile(" << id <<")");
+	}
+
+DBTile::~DBTile()
+	{
+	RMDBGENTER(3, RMDebug::module_blobif, "DBTile", "~DBTile() " << myOId);
+	if (cells)
+	{
+		TALK( "DBTile::~DBTile() freeing blob cells" );
+		free(cells);
+	}
+	cells = NULL;	
+	RMDBGEXIT(3, RMDebug::module_blobif, "DBTile", "~DBTile() " << myOId);
+	}
+
+void
+DBTile::resize(r_Bytes newSize)
+	{
+	RMDBGONCE(3, RMDebug::module_blobif, "DBTile", "resize(" << newSize << ") " << myOId);
+	if (size != newSize)
+		{
+		setModified();
+		if (cells)
+		{
+			TALK( "DBTile::resize() freeing blob cells" );
+			free(cells);
+			// cells = NULL; 	// added PB 2005-jan-10
+		}
+		TALK( "DBTile::resize() allocating " << newSize << " bytes for blob cells, previous ptr was " << (long) cells );
+		cells = (char*)mymalloc(newSize * sizeof(char));
+		size = newSize;
+		}
+	}
+
+void
+DBTile::printStatus(unsigned int level, std::ostream& stream) const
+	{
+	DBObject::printStatus(level, stream);
+	stream << " r_Data_Format " << dataFormat << " size " << size << " ";
+	RMDBGIF(20, RMDebug::module_blobif, "DBTile", for (int a = 0; a < size; a++)\
+		 stream << " " << (int)(cells[a]); stream << endl;)
+	}
+
+std::ostream&
+operator << (std::ostream& stream, DBTile& b)
+	{
+	stream << "\tDBTile at " << &b << endl;
+	stream << "\t\tOId\t\t:" << b.myOId << endl;
+	stream << "\t\tId\t\t:" << b.myOId.getCounter() << endl;
+	stream << "\t\tSize\t\t:" << b.size << endl;
+	stream << "\t\tModified\t:" << (int)b._isModified << endl;
+	stream << "\t\tCells\t\t:";
+	RMDBGIF(20, RMDebug::module_blobif, "DBTile", for (int a = 0; a < b.size; a++)\
+		 stream << " " << (int)(b.cells[a]); stream << endl;)
+	return stream;
+	}
+