FileJoinManager.h

Go to the documentation of this file.

//
// Created by Nico Schäfer on 02/04/18.
//
 
#ifndef JODA_FILEJOINMANAGER_H
#define JODA_FILEJOINMANAGER_H
 
#include <unordered_map>
#include "JoinManager.h"
 
class FileJoinManager : public JoinManager {
 public:
  FileJoinManager(const std::string& name,
                  std::unique_ptr<joda::query::IValueProvider>&& valProv);
  ~FileJoinManager() override;
 
  void join(const RapidJsonDocument& doc) override;
 
  const std::string& getBaseDir() const;
 
 protected:
  bool createFile(const std::string& file, bool val);
  bool createFile(const std::string& file, long val);
  bool createFile(const std::string& file, const std::string& val);
  std::string getFile(JODA_JOINID id);
  JODA_JOINID getJoinVal(const RJValue& val);
  bool appendDocToFile(const RapidJsonDocument& doc, const std::string& file);
 
  std::string baseDir;
  std::mutex mut;
 
  JODA_JOINID currID = STARTNORMAL_VAL;
  std::unordered_map<long, JODA_JOINID> lMap;         // Integer as long
  std::unordered_map<std::string, JODA_JOINID> sMap;  // String as String
  std::unordered_map<JODA_JOINID, std::mutex> fLock;  // file-lock
 
  bool trueValCreated = false;
  bool falseValCreated = false;
};
 
#endif  // JODA_FILEJOINMANAGER_H