RDFValueBinaryMarshal.h

#include <kDB/Repository/AbstractBinaryMarshal.h>
 
#include <QSharedPointer>
 
namespace kDB::Repository::DatabaseInterface::PostgreSQL
{
  class RDFValueBinaryMarshal : public AbstractBinaryMarshal
  {
    friend class Repository::Connection;
    friend class Repository::GraphsManager;
  public:
    class FieldIO
    {
    public:
      FieldIO(const QString& _typename);
      virtual ~FieldIO();
    public:
      virtual knowCore::Value read(const char* _data, int _field_size, const kDB::Repository::Connection& _connection) const = 0;
      virtual bool accept(const knowCore::Value& _value) const = 0;
      virtual quint32 calculateSize(const knowCore::Value& _value) const = 0;
      virtual void write(char* _data, const knowCore::Value& _value, const kDB::Repository::Connection& _connection) const = 0;
      QString typeName() const;
    private:
      struct Private;
      Private* const d;
    };
    enum class Operator : quint64
    {
      None = 0,
      Addition = 1, Multiplication = 1 << 2, Substraction = 1 << 3, Division = 1 << 4, Minus = 1 << 5,
      AllArithmetic = Addition | Multiplication | Substraction | Division | Minus,
      Inferior = 1 << 6, InferiorEqual = 1 << 7, Superior = 1 << 8, SuperiorEqual = 1 << 9, Equal = 1 << 10, NotEqual = 1 << 11,
      AllComparison = Inferior | InferiorEqual | Superior | SuperiorEqual | Equal | NotEqual
    };
    enum class Feature : quint64
    {
      None = 0,
      Indexable = 1
    };
  private:
    RDFValueBinaryMarshal(const Connection& _connection); // Do not call directly, use create instead.
  public:
    static knowCore::ReturnValue<RDFValueBinaryMarshal*> create(const Connection& _connection);
    virtual ~RDFValueBinaryMarshal();
    
    knowCore::ReturnValue<knowCore::Value> toValue(const QByteArray& _source, const kDB::Repository::Connection& _connection) const override;
    knowCore::ReturnValue<QByteArray> toByteArray(const knowCore::Value& _source, QString& _oidName, const kDB::Repository::Connection& _connection) const override;
    
    static QStringList fields(const Connection& _connection);
    static knowCore::ReturnVoid registerField(const Connection& _connection, const knowCore::Uri& _defaultUri, const FieldIO* _fieldIO, quint64 _operators, quint64 _features);
    static knowCore::ReturnVoid registerTerm(const Connection& _connection, const knowCore::Uri& _defaultUri, const QString& _typename, const QString& _cast_typename = QString());
  private:
    knowCore::ReturnVoid setupIndexes(const TriplesStore& _store);
    knowCore::ReturnVoid finishInitialisation();
  private:
    inline quint32 calculateSize(const knowCore::Value& _number) const;
    struct Private;
    Private* const d;
  };
}