1
0
forked from blue/lmdbal
lmdbal/table.h

72 lines
1.9 KiB
C
Raw Normal View History

2022-09-05 20:25:39 +00:00
// Squawk messenger.
// Copyright (C) 2019 Yury Gubich <blue@macaw.me>
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
#ifndef CORE_TABLE_H
#define CORE_TABLE_H
#include "database.h"
2022-09-12 15:16:18 +00:00
#include "serializer.h"
2022-09-05 20:25:39 +00:00
class DataBase::_Table {
friend class DataBase;
protected:
2022-09-09 17:15:40 +00:00
_Table(const std::string& name, DataBase* parent);
2022-09-05 20:25:39 +00:00
virtual ~_Table();
2022-09-14 22:18:31 +00:00
virtual int createTable(MDB_txn * transaction) = 0;
virtual int drop(MDB_txn * transaction);
2022-09-05 20:25:39 +00:00
public:
virtual void drop();
virtual uint32_t count() const;
protected:
2022-09-05 20:25:39 +00:00
MDB_dbi dbi;
DataBase* db;
2022-09-09 17:15:40 +00:00
const std::string name;
2022-09-14 22:18:31 +00:00
protected:
template <class T>
int makeTable(MDB_txn* transaction);
template <class T>
static std::string toString(const T& value);
2022-09-05 20:25:39 +00:00
};
template <class K, class V>
class DataBase::Table : public DataBase::_Table {
2022-09-05 20:25:39 +00:00
friend class DataBase;
2022-09-20 17:16:48 +00:00
protected:
2022-09-09 17:15:40 +00:00
Table(const std::string& name, DataBase* parent);
2022-09-05 20:25:39 +00:00
~Table() override;
public:
2022-09-20 17:16:48 +00:00
virtual void addRecord(const K& key, const V& value);
virtual void changeRecord(const K& key, const V& value);
virtual void removeRecord(const K& key);
virtual V getRecord(const K& key) const;
2022-09-12 15:16:18 +00:00
2022-09-20 17:16:48 +00:00
protected:
2022-09-14 22:18:31 +00:00
Serializer<K>* keySerializer;
Serializer<V>* valueSerializer;
2022-09-05 20:25:39 +00:00
2022-09-14 22:18:31 +00:00
int createTable(MDB_txn* transaction) override;
};
2022-09-09 17:15:40 +00:00
2022-09-05 20:25:39 +00:00
#include "table.hpp"
#endif // CORE_TABLE_H