statistics_db.h 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. /**
  2. *
  3. */
  4. #ifndef CPP_PCAPREADER_STATISTICSDB_H
  5. #define CPP_PCAPREADER_STATISTICSDB_H
  6. // Aidmar
  7. #include <iostream>
  8. #include <memory>
  9. #include <string>
  10. #include "statistics.h"
  11. #include <SQLiteCpp/SQLiteCpp.h>
  12. class statistics_db {
  13. public:
  14. /*
  15. * Constructor: Creates new database / Opens existing database
  16. */
  17. statistics_db(std::string database_path);
  18. /*
  19. * Methods for writing values into database
  20. */
  21. void writeStatisticsIP(std::unordered_map<std::string, entry_ipStat> ipStatistics);
  22. void writeStatisticsTTL(std::unordered_map<ipAddress_ttl, int> ttlDistribution);
  23. void writeStatisticsProtocols(std::unordered_map<ipAddress_protocol, int> protocolDistribution);
  24. void writeStatisticsPorts(std::unordered_map<ipAddress_inOut_port, int> portsStatistics);
  25. void writeStatisticsIpMac(std::unordered_map<std::string, std::string> IpMacStatistics);
  26. // Aidmar - comment out
  27. //void writeStatisticsMss(std::unordered_map<std::string, int> mssStatistics);
  28. void writeStatisticsFile(int packetCount, float captureDuration, std::string timestampFirstPkt,
  29. std::string timestampLastPkt, float avgPacketRate, float avgPacketSize,
  30. float avgPacketsSentPerHost, float avgBandwidthIn, float avgBandwidthOut);
  31. // Aidmar - new tables
  32. void writeStatisticsMss_dist(std::unordered_map<ipAddress_mss, int> mssDistribution);
  33. void writeStatisticsWin(std::unordered_map<ipAddress_win, int> winDistribution);
  34. void writeStatisticsConv(std::unordered_map<conv, entry_convStat> convStatistics);
  35. void writeStatisticsInterval(std::unordered_map<std::string, entry_intervalStat> intervalStatistics);
  36. private:
  37. // Pointer to the SQLite database
  38. std::unique_ptr<SQLite::Database> db;
  39. };
  40. #endif //CPP_PCAPREADER_STATISTICSDB_H