lgrHlaTableFactory.h

Go to the documentation of this file.

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


#if DtHLA

#ifndef lgrHlaTableFactory_H_
#define lgrHlaTableFactory_H_

#include <lgrSqlExporter/lgrSqlExporter.h>

#include <vlDatabase/databaseTable.h>
#include <set>
#include <vector>
#include <vlutil/vlPrint.h>


class DtDatabaseColumn;
class DtDatatypeFedNode;
class DtDatatypeRep;
class DtDatabaseColumn;
class DtDatatypeManager;
class DtOMTTree;
class DtString;
class DtStringTree;
class DtVariantDatatypeNode;

namespace MAKLogger
{
   class DtBaseHlaValue;
   class DtLgrVariableLengthData;
   class DtConstLgrHlaMessage;

   class DT_DLL_SQLEXPORTER DtLgrHlaTableFactory
   {
   private:
      DtLgrHlaTableFactory(const DtLgrHlaTableFactory&);
      DtLgrHlaTableFactory& operator=(const DtLgrHlaTableFactory&);

   public:
      DtLgrHlaTableFactory(DtOMTTree*,DtDatatypeManager*);

      virtual ~DtLgrHlaTableFactory();

      virtual void setUseShortTableNames(bool shortNames);

      virtual void setLog(DtOutputStream& log);

      virtual DtOutputStream& log();

      virtual void createAttributeColumn( const DtDatatypeFedNode* attrDatatypeNode,
         DtDatabaseTableSP primaryTable, std::vector<DtDatabaseTableSP>& tables);

      virtual DtDatabaseTableSP createSubTable(
         const DtDatabaseTable& primaryTable, const DtString& subName,
         std::vector<DtDatabaseTableSP>& tables ) = 0;

      virtual DtDatabaseTableSP createVariantSubTable(
         const DtDatabaseTable& primaryTable, const DtString& variantName, const DtString& alternativeName,
         std::vector<DtDatabaseTableSP>& tables) = 0;

      virtual void setGenerateLargeSubcomponentTables(bool generate);
      virtual bool generateLargeSubcomponentTables() const;


      virtual int largeSubcomponentThreshold() const;
      virtual void setLargeSubcomponentThreshold(int threshold);

   protected:
      typedef std::set<DtString> ShortNameSet;

      virtual void makeTableName( DtString& stringToSet,
         const MAKLogger::DtBaseHlaValue& hlaClass,
         const char* baseNameToRemove);

      virtual void createColumns( const DtString& currentType, DtDatabaseTableSP primaryTable,
         const DtString& currentName, const DtString& cardinality, bool isVariantTable = false);

      virtual void addSimpleTypeColumn( const DtDatatypeRep* typeRep,
         const DtString& cardinality, DtDatabaseTableSP primaryTable,
         const DtString& currentName ) const;

      virtual void createArrayTable( const DtDatatypeFedNode* attrDatatypeNode,
         DtDatabaseTableSP primaryTable, std::vector<DtDatabaseTableSP>& tables);

      // Create ARRAY type columns
      virtual void createArrayColumns( const DtString& arrayDataType,
         const DtString& currentName, DtDatabaseTableSP table );

      virtual void createVariantTables(const DtDatatypeFedNode* attrDatatypeNode,
         DtDatabaseTableSP primaryTable, std::vector<DtDatabaseTableSP>& tables);

      virtual void updateTableValues(const DtStringTree* node,
         std::vector<DtDatabaseTableSP>& tables, DtDatabaseTableSP currentTable,
         const DtString& parentName, bool skipNode);

      virtual void setColumnValue( const DtString& columnDataType,
         const DtString& columnValue, DtDatabaseColumn &column );

      virtual void updateArrayValues(DtDatabaseTableSP currentTable,
         const DtStringTree* node, const DtString& columnName);

      virtual DtString getSubTableName( const DtString& primaryTableName,
         const DtString& attributeName,const DtString& rootName  );

      virtual DtString getVariantSubTableName(const DtString& primaryTableName,
         const DtString& attributeName, const DtString& alternativeName, const DtString& rootName);

      virtual void updateTablesWithAttribute(std::vector<DtDatabaseTableSP>& tables,
         DtDatabaseTableSP primaryTable, const DtString& rootName,
         const DtConstLgrHlaMessage& hlaMessage, const DtLgrVariableLengthData& attributeValue,
         const DtDatatypeFedNode* attributeNode);

      virtual void updateSubTableDefaultColumns(const DtDatabaseTable& primaryTable,
         DtDatabaseTable& currentTable, const MAKLogger::DtConstLgrHlaMessage& hlaMessage);

      virtual DtDatabaseTableSP findTable(
         const std::vector<DtDatabaseTableSP>& tables, const DtString& tableName);

      virtual int numberOfSubcomponents(const DtString& dataTypeName);

      virtual bool isVariantConsistent(DtVariantDatatypeNode* variantNode,
         DtDatabaseColumn::DataType& variantType);

   protected:

      static void appendName( DtString &name, const DtString& suffix );

   protected:

      DtOMTTree* myOMTTree;
      DtDatatypeManager* myDatatypeManager;
      bool myUseShortNames;
      ShortNameSet myShortNames;
      int myThreshold;
      DtOutputStream myDefaultLog;
      DtOutputStream* myLog;
      DtDatabaseColumn* myIndexColumn;

      typedef std::set<DtString> ColumnLog;
      ColumnLog myErrorColumnLog;
      bool myGenerateLargeSubcomponentTables;
      int myLargeSubcomponentThreshold;

      DtDatabaseColumn* myUniqueIdentifierColumn;
      DtDatabaseColumn* myArrivalTimeColumn;
      DtDatabaseColumn* myParentEntryIdColumn;
      DtDatabaseColumn* myTagColumn;

      unsigned int myMaxColumnNameLength;
   };
}

#endif
#endif