lgrDisObjectTableFactory.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved.
******************************************************************************/


#if DtDIS

#ifndef lgrDisObjectTableFactory_H_
#define lgrDisObjectTableFactory_H_

#include <lgrSqlExporter/lgrSqlExporter.h>
#include <vlDatabase/databaseTable.h>

#include <vlutil/vlString.h>
#include <vector>

class DtDatabaseColumn;
class DtDatabaseInterface;

namespace MAKLogger
{
   class DtAbsoluteTime;
   class DtConstLgrDisMessage;

   class DT_DLL_SQLEXPORTER DtLgrDisObjectTableFactory
   {
   public:

      DtLgrDisObjectTableFactory();

      virtual ~DtLgrDisObjectTableFactory();

   private:
      DtLgrDisObjectTableFactory(const DtLgrDisObjectTableFactory&);
      DtLgrDisObjectTableFactory& operator=(const DtLgrDisObjectTableFactory&);
   public:

      DtDatabaseTable& createObjectInstanceTable();


      DtDatabaseTable& addObjectInstance(const MAKLogger::DtAbsoluteTime& time,
         const MAKLogger::DtConstLgrDisMessage& message);

      DtDatabaseTable& removeObjectInstance(
         const DtString& id,
         const DtString& type,
         const MAKLogger::DtAbsoluteTime& time,
         bool isFinalPduBitSet,
         const std::vector<DtString>*& removalColumns,
         DtDatabaseInterface& db,
         const DtString*& removalCondition );


      bool isInstance(const MAKLogger::DtConstLgrDisMessage& message) const;

      DtString instanceId(const MAKLogger::DtConstLgrDisMessage& message) const;

      DtString instanceType(const MAKLogger::DtConstLgrDisMessage& message) const;

   protected:

      DtDatabaseTable& addEntityStateInstance(const MAKLogger::DtAbsoluteTime& time,
         const MAKLogger::DtConstLgrDisMessage& msg);

      DtString myTableBuffer;

      DtDatabaseTableSP myObjectInstanceTable;

      DtDatabaseColumn* myEntityIdColumn;
      DtDatabaseColumn* myEntityIdSiteColumn;
      DtDatabaseColumn* myEntityIdAppColumn;
      DtDatabaseColumn* myEntityIdEntityColumn;

      DtDatabaseColumn* myEntityTypeColumn;
      DtDatabaseColumn* myEntityTypeEntityKindColumn;
      DtDatabaseColumn* myEntityTypeDomainColumn;
      DtDatabaseColumn* myEntityTypeCountryColumn;
      DtDatabaseColumn* myEntityTypeCategoryColumn;
      DtDatabaseColumn* myEntityTypeSubcategoryColumn;
      DtDatabaseColumn* myEntityTypeSpecificColumn;
      DtDatabaseColumn* myEntityTypeExtraColumn;

      DtDatabaseColumn* myFirstPacketTimeColumn;
      DtDatabaseColumn* myLastPacketTimeColumn;
      DtDatabaseColumn* myFinalPduBitSetColumn;

      std::vector<DtString> myRemovalColumns;
      DtString myRemovalCondition;

   };

}

#endif
#endif