E:/Projetos_Primeiro_Semestre_2012/TerraView/terralib/src/terralib/drivers/PostgreSQL/TePostgreSQL.h

Go to the documentation of this file.

/************************************************************************************
TerraLib - a library for developing GIS applications.
Copyright � 2001-2007 INPE and Tecgraf/PUC-Rio.

This code is part of the TerraLib library.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.

You should have received a copy of the GNU Lesser General Public
License along with this library.

The authors reassure the license terms regarding the warranties.
They specifically disclaim any warranties, including, but not limited to,
the implied warranties of merchantability and fitness for a particular purpose.
The library provided hereunder is on an "as is" basis, and the authors have no
obligation to provide maintenance, support, updates, enhancements, or modifications.
In no event shall INPE and Tecgraf / PUC-Rio be held liable to any party for direct,
indirect, special, incidental, or consequential damages arising out of the use
of this library and its documentation.
*************************************************************************************/
/*
 * TODO: 01. Implementar o alterTable que nao pode simplesmente alterar o tipo da coluna
 *                     02. No metodo query do portal, determinar os campos que fazem parte da chave primaria
 *
 */

#ifndef  __TERRALIB_INTERNAL_POSTGRESQL_H
#define  __TERRALIB_INTERNAL_POSTGRESQL_H

#include "../../kernel/TeDatabase.h"
#include "../../kernel/TeDatabaseFactory.h"
#include "TePostgreSQLDefines.h"

class TePostgreSQLPortal;
class TePGConnection;
class TePGRecordset;

struct pg_conn;


class TLPOSTGRESQL_DLL TePostgreSQL : public TeDatabase
{
           friend class TePostgreSQLPortal;

           public:
                      
                      TePostgreSQL();

                      virtual ~TePostgreSQL();


        virtual void setConnection(TeConnection* c);

        virtual TeConnection* getConnection();


                      string errorMessage();

                      virtual bool newDatabase(const string& database, const string& user, const string& password, const string& host, const int& port = -1, bool terralibModel=true, const std::string& characterSet = "");

                      virtual bool connect(const string& host, const string& user, const string& password, const string& database, int port = -1);

                      virtual bool connect(pg_conn* conn);

                      virtual bool showDatabases(const string& host, const string& user, const string& password, vector<string>& dbNames, int port = -1);

                      void close(void);

                      bool listTables(vector<string>& tableList);

                      virtual bool listDatabases(std::vector<std::string> &databaseList);

                      virtual bool dropDatabase(const std::string &databaseName);

                      bool tableExist(const string& table);

                      virtual bool deleteTable (const string& table);

               bool columnExist(const string& table, const string& column, TeAttribute& attr);

                      virtual bool createTable(const string& table, TeAttributeList &attr);

                      virtual bool addColumn(const string& table, TeAttributeRep &rep);

                      bool createRelation(const string& relName, const string& table, const string& fieldName, const string& relatedTable, const string& relatedField, bool cascadeDeletion);

                      TeDBRelationType existRelation(const string& tableName, const string& relName);

                      bool execute(const string &sql);

                      virtual TeDatabasePortal* getPortal();

                      bool insertTable(TeTable &table);

                      bool updateTable      (TeTable &table);
                      
                      bool insertRelationInfo(const int tableId, const string& tField, const string& rTable, const string& rField, int& relId);

               bool insertTableInfo(int layerId, TeTable& table, const string& user = "");

                      bool alterTable(const string& tableName, TeAttributeRep& rep, const string& oldColName="");

                      bool alterTable(const string& oldTableName, const string& newTableName);

                      bool insertBlob (const string& tableName, const string& columnBlob, const string& whereClause, unsigned char* data, int size);
                      
                      bool insertProjection(TeProjection *proj);

                      bool insertLayer(TeLayer *layer);

                      bool insertProject(TeProject *proj);

                      bool insertRepresentation(int layerId, TeRepresentation& rep);

                      bool insertView(TeView *view);

                      bool insertViewTree(TeViewTree *tree);

                      bool insertThemeGroup(TeViewTree* tree);

                      bool insertTheme(TeAbstractTheme *theme);

                      bool insertThemeTable(int themeId, int tableId, int relationId, int tableOrder);

                      virtual bool generateLabelPositions(TeTheme *theme, const std::string& objectId = "");

                      bool insertLegend(TeLegendEntry *legend);              

                      virtual bool loadPolygonSet(const string& table, TeBox& box, TePolygonSet& ps);

                      virtual TeDatabasePortal* loadPolygonSet(const string& table, TeBox& box);

               virtual bool locatePolygon(const string& table, TeCoord2D& pt, TePolygon& polygon, const double& tol = 0.0);                    

                      virtual bool locatePolygonSet  (const string& table, TeCoord2D &pt, double tol, TePolygonSet &polygons);

                      virtual bool insertPolygon(const string& table, TePolygon& p);

                      virtual bool updatePolygon(const string& table, TePolygon& p);

                      virtual bool loadLineSet(const string& table, TeBox& box, TeLineSet& linSet);

                      virtual TeDatabasePortal* loadLineSet(const string& table, TeBox& box);

                      virtual bool insertLine(const string& table, TeLine2D& l);

                      virtual bool updateLine(const string& table, TeLine2D& l);

                      virtual bool locateLine(const string& table, TeCoord2D& pt, TeLine2D& line, const double& tol = 0.0);

                      virtual bool insertPoint(const string& table, TePoint& p);

                      virtual bool updatePoint(const string& table, TePoint& p);

                      virtual bool locatePoint(const string& table, TeCoord2D& pt, TePoint& point, const double& tol = 0.0);

                      bool insertText(const string& table, TeText& t);

                      bool insertArc(const string& table,TeArc& arc);

                      virtual bool insertNode(const string& table, TeNode& node);
                      virtual bool updateNode(const string& table, TeNode &node);

                      virtual bool insertCell(const string& table, TeCell& c);
                      virtual bool updateCell(const string& table, TeCell &c);

                      // Locates a cell
                      virtual bool locateCell(const string& table, TeCoord2D& pt, TeCell& c, const double& tol = 0.0);

                      virtual bool insertRasterBlock(const string& table, const string& blockId, const TeCoord2D& ll, const TeCoord2D& ur, unsigned char* buf,unsigned long size, int band = 0, unsigned int res = 1, unsigned int subband = 0);

                      string getSQLStatistics(TeGroupingAttr& attrs);

                      string getSQLTemporalWhere(TeTimeInterval& timeInterval, TeTemporalRelation timeOperator, const string& initialTime, const string& finalTime);

                      string getSQLTemporalWhere(int time1, int time2, TeChronon chr, TeTemporalRelation rel, const string& initialTime, const string& finalTime);

                      string getAutoNumberSQL(const string& table);

                      string getSQLTime(const TeTime& t) const;

               string concatValues(vector<string>& values, const string& unionString);

               string toUpper(const string& value);

        string leftString(const string& name, const int& length);

                      virtual bool createSpatialIndex(const string& table, const string& column, TeSpatialIndexType type = TeRTREE, short level = 0, short tile = 0);

                      virtual string getSQLBoxWhere(const TeBox& box, const TeGeomRep rep, const std::string& tableName);

                      virtual string getSQLBoxWhere(const string& table1, const string& table2, TeGeomRep rep2, TeGeomRep rep1 = TePOLYGONS);

                      virtual string getSQLBoxSelect(const string& tableName, TeGeomRep rep);

                      virtual bool getMBRGeom(string tableGeom, string object_id, TeBox& box, string colGeom);

                      virtual bool getMBRSelectedObjects(string geomTable, string colGeom, string fromClause, string whereClause, string afterWhereClause, TeGeomRep repType, TeBox& bout, const double& tol = 0.0);

                      virtual string getSpatialIdxColumn(TeGeomRep rep);

                      bool beginTransaction(); 

                      bool commitTransaction();

                      bool rollbackTransaction();

                      virtual std::string getClientEncoding();

                      virtual bool setClientEncoding(const std::string& characterSet);

                      virtual bool getEncodingList(std::vector<std::string>& vecEncodingList);
                       
                      virtual bool getEncodingList(const std::string& host, const std::string& user, const std::string& password, const int& port, std::vector<std::string>& vecEncodingList);

                      virtual bool getIndexesFromTable(const string& tableName, std::vector<TeDatabaseIndex>& vecIndexes);

                      virtual bool getAttributeList(const string& tableName,TeAttributeList& attList);

           protected:

                      virtual void getInsertRasterBlock(const string& table, const string& blockId, const TeCoord2D& ll, const TeCoord2D& ur, const int& band, const unsigned int& res, const unsigned int& subband, char* buf, const unsigned long& size, string& sql);

                      virtual void getUpdateRasterBlock(const string& table, const string& blockId, const TeCoord2D& ll, const TeCoord2D& ur, const int& band, const unsigned int& res, const unsigned int& subband, char* buf, const unsigned long& size, string& sql);
                      
                      string escapeSequence(const string& from);
                      

                      bool realConnect(const string& host, const string& user, const string& password, const string& database, int port = -1);

                      TePGConnection* tepg_connection_;
        TePGConnection* tepg_connection_ref;

                std::string gistBoxOps_;

                      int transactionCounter_;

};



class TLPOSTGRESQL_DLL TePostgreSQLPortal : public TeDatabasePortal
{
           public:

                      TePostgreSQLPortal();

                      TePostgreSQLPortal(TeDatabase *pDatabase);
                      
                      virtual ~TePostgreSQLPortal();

                      virtual bool query(const string &qry, TeCursorLocation l = TeSERVERSIDE, TeCursorType t = TeUNIDIRECTIONAL, TeCursorEditType e = TeREADONLY, TeCursorDataType dt = TeTEXTCURSOR);

                      bool fetchRow();

                      bool fetchRow(int i);

                      void freeResult();

                      string errorMessage();

                      char* getData(int i);

                      char* getData(const string& s);

                      double getDouble(int i);

                      double getDouble(const string& s);

                      int        getInt(int i);

                      int        getInt(const string& s);

                      bool getBool(const string& s);

                      bool getBool(int i);

               TeTime getDate(int i);

               TeTime getDate(const string& s);

                      string getDateAsString(int i);

                      string getDateAsString(const string& s);

                      bool getBlob(const string& s, unsigned char*& data, long& size);

                      virtual bool getRasterBlock(unsigned long& size, unsigned char* ptData);

                      virtual bool fetchGeometry(TePolygon& pol);
                      virtual bool fetchGeometry(TeLine2D& line);
                      virtual bool fetchGeometry(TeNode& n);
                      virtual bool fetchGeometry(TePoint& p);
                      virtual    bool fetchGeometry (TeCell& cell);
                      virtual bool fetchGeometry(TePolygon& pol, const unsigned int& initIndex);
                      virtual bool fetchGeometry(TeLine2D& line, const unsigned int& initIndex);
                      virtual bool fetchGeometry(TeNode& n, const unsigned int& initIndex);
                      virtual bool fetchGeometry(TePoint& p, const unsigned int& initIndex);
                      virtual    bool fetchGeometry (TeCell& cell, const unsigned int& initIndex);


           protected:

                      TeLinearRing getLinearRing(int& numberOfHoles);

                      TeLinearRing getLinearRing(int& numberOfHoles, const unsigned int& i);

                      string escapeSequence(const string& from);

                      // Protected data members
                      TePGConnection *con_;
                      TePGRecordset* tepg_recordset_;

                      long curRow_;                    

};


class TLPOSTGRESQL_DLL TePostgreSQLFactory : public TeDatabaseFactory
{
  public :
      
    TePostgreSQLFactory() : TeDatabaseFactory( 
      std::string( "PostgreSQL" ) ) {};      
      
    ~TePostgreSQLFactory() {};
      
  protected :  
  
    TeDatabase* build( const TeDatabaseFactoryParams& arg )
    {
      TePostgreSQL* instance_ptr = new TePostgreSQL();
      
      if( arg.host_ != "" ) {
        instance_ptr->connect( arg.host_, arg.user_, arg.password_,
          arg.database_, arg.port_ );
      }
  
      return (TeDatabase*)instance_ptr;
    }
};

namespace {
  static TePostgreSQLFactory TePostgreSQLFactory_instance;
}; 

#endif     // __TERRALIB_INTERNAL_TePOSTGRESQL_H

/*
 *  Updates:
 *      - 2007/03/26: Mario Rocco Added new method - string leftString(const string& name, const int& length);
 */