lgrPduDatabaseEncoder.h

Go to the documentation of this file.

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


#ifndef lgrPduDatabaseEncoder_H_
#define lgrPduDatabaseEncoder_H_

#if DtDIS

#include <lgrSqlExporter/lgrSqlExporter.h>

#include <vlDatabase/databaseTable.h>
#include <vector>
#include <vlutil/vlString.h>
#include <vlpi/disEnums.h>

class DtDatabaseColumn;
class DtPdu;

namespace MAKLogger
{
   class DtAbsoluteTime;

   class DT_DLL_SQLEXPORTER DtLgrPduDatabaseEncoder
   {
   public:
      DtLgrPduDatabaseEncoder();

      virtual ~DtLgrPduDatabaseEncoder();

      static void bin2HexString(DtString& output,const void* memory,size_t length);

      //@name Override per pdu.

      virtual const DtString& pduName() const = 0;

   protected:
      virtual void encodePdu(const DtPdu& pdu,std::vector<DtDatabaseTableSP>& tables) const = 0;

   public:
      virtual std::vector<DtDatabaseTableSP> getTableDefinitions() const;


      void encodeMessage(const MAKLogger::DtAbsoluteTime& arrivalTime,
         const DtPdu& pdu, std::vector<DtDatabaseTableSP>& tables) const ;

   protected:
      virtual DtDatabaseTable* createDefaultPrimaryTable(const DtString& tableName) const;

      virtual DtDatabaseTable* createSubTable(const DtString& tableName) const ;

      virtual void updateDefaultPrimaryTable(
         const MAKLogger::DtAbsoluteTime& arrivalTime, const DtPdu& pdu,
         DtDatabaseTableSP table)  const;

      virtual void updateDefaultSubTable(
         const MAKLogger::DtAbsoluteTime& arrivalTime, const DtPdu& pdu,
         const DtDatabaseTableSP primaryTable,  DtDatabaseTableSP table)  const;

      DtDatabaseColumn* myPrimaryTableIdColumn;
      DtDatabaseColumn* myPrimaryTableSizeColumn;
      DtDatabaseColumn* myArrivalTimeColumn;
      DtDatabaseColumn* myTimeStampColumn;
      DtDatabaseColumn* myTimeStampTypeColumn;
      DtDatabaseColumn* myExerciseIdColumn;
      DtDatabaseColumn* mySubTableArrivalPrimaryIdColumn;

      DtString myAbsoluteTimeStampEnumStr;
      DtString myRelativeTimeStampEnumStr;

   };
}

#endif
#endif