57 lines
1.2 KiB
C
57 lines
1.2 KiB
C
|
#ifndef DATABASE_H
|
||
|
|
#define DATABASE_H
|
||
|
|
|
||
|
|
#include "lmdb++.h"
|
||
|
|
|
||
|
|
#include <map>
|
||
|
|
#include <set>
|
||
|
|
|
||
|
|
#include <wModel/icatalogue.h>
|
||
|
|
|
||
|
|
#include <wType/string.h>
|
||
|
|
#include <wType/address.h>
|
||
|
|
|
||
|
|
class Database: public M::ICatalogue
|
||
|
|
{
|
||
|
|
Q_OBJECT
|
||
|
|
class AbstractIndex;
|
||
|
|
public:
|
||
|
|
Database(const W::String& dbName, QObject* parent = 0);
|
||
|
|
~Database();
|
||
|
|
|
||
|
|
void open();
|
||
|
|
|
||
|
|
uint64_t addElement(const W::Vocabulary& record) override;
|
||
|
|
W::Vocabulary* getElement(uint64_t id) override;
|
||
|
|
void removeElement(uint64_t id) override;
|
||
|
|
void clear() override;
|
||
|
|
void modifyElement(uint64_t id, const W::Vocabulary & newValue) override;
|
||
|
|
uint64_t size() const override;
|
||
|
|
|
||
|
|
void addIndex(const W::String& fieldName, W::Object::objectType fieldType) override;
|
||
|
|
|
||
|
|
void addModel(M::Model* model);
|
||
|
|
void removeModel(M::Model* model);
|
||
|
|
|
||
|
|
protected:
|
||
|
|
std::set<uint64_t> getAll() const override;
|
||
|
|
|
||
|
|
private:
|
||
|
|
void checkDirAndOpenEnvironment();
|
||
|
|
void index();
|
||
|
|
|
||
|
|
private slots:
|
||
|
|
void onChildSubscribersCountChange(uint64_t count);
|
||
|
|
|
||
|
|
public:
|
||
|
|
const W::String name;
|
||
|
|
|
||
|
|
private:
|
||
|
|
bool opened;
|
||
|
|
lmdb::env environment;
|
||
|
|
lmdb::dbi dbi;
|
||
|
|
std::set<uint64_t> elements;
|
||
|
|
};
|
||
|
|
|
||
|
|
#endif // DATABASE_H
|