diff options
Diffstat (limited to 'include/sord/sordmm.hpp')
| -rw-r--r-- | include/sord/sordmm.hpp | 988 |
1 files changed, 497 insertions, 491 deletions
diff --git a/include/sord/sordmm.hpp b/include/sord/sordmm.hpp index 1cb34e7..d404684 100644 --- a/include/sord/sordmm.hpp +++ b/include/sord/sordmm.hpp @@ -23,15 +23,15 @@ #define SORD_SORDMM_HPP #if defined(__clang__) -# pragma clang diagnostic push -# pragma clang diagnostic ignored "-Wzero-as-null-pointer-constant" +# pragma clang diagnostic push +# pragma clang diagnostic ignored "-Wzero-as-null-pointer-constant" #endif #include "serd/serd.h" #include "sord/sord.h" #if defined(__clang__) -# pragma clang diagnostic pop +# pragma clang diagnostic pop #endif #include <cassert> @@ -49,511 +49,538 @@ namespace Sord { /** Utility base class to prevent copying or moving. */ -class Noncopyable { +class Noncopyable +{ public: - Noncopyable() = default; - ~Noncopyable() = default; + Noncopyable() = default; + ~Noncopyable() = default; - Noncopyable(const Noncopyable&) = delete; - const Noncopyable& operator=(const Noncopyable&) = delete; + Noncopyable(const Noncopyable&) = delete; + const Noncopyable& operator=(const Noncopyable&) = delete; - Noncopyable(Noncopyable&&) = delete; - Noncopyable& operator=(Noncopyable&&) = delete; + Noncopyable(Noncopyable&&) = delete; + Noncopyable& operator=(Noncopyable&&) = delete; }; /** C++ wrapper for a Sord object. */ -template <typename T> -class Wrapper { +template<typename T> +class Wrapper +{ public: - inline Wrapper(T* c_obj = nullptr) : _c_obj(c_obj) {} + inline Wrapper(T* c_obj = nullptr) + : _c_obj(c_obj) + {} - inline T* c_obj() { return _c_obj; } - inline const T* c_obj() const { return _c_obj; } + inline T* c_obj() { return _c_obj; } + inline const T* c_obj() const { return _c_obj; } protected: - T* _c_obj; + T* _c_obj; }; /** Collection of RDF namespaces with prefixes. */ -class Namespaces : public Wrapper<SerdEnv> { +class Namespaces : public Wrapper<SerdEnv> +{ public: - Namespaces() : Wrapper<SerdEnv>(serd_env_new(nullptr)) {} - ~Namespaces() { serd_env_free(_c_obj); } - - static inline SerdNode string_to_node(SerdType type, const std::string& s) { - SerdNode ret = {reinterpret_cast<const uint8_t*>(s.c_str()), - s.length(), - s.length(), - 0, - type}; - return ret; - } - - inline void add(const std::string& name, - const std::string& uri) { - const SerdNode name_node = string_to_node(SERD_LITERAL, name); - const SerdNode uri_node = string_to_node(SERD_URI, uri); - serd_env_set_prefix(_c_obj, &name_node, &uri_node); - } - - inline std::string qualify(std::string uri) const { - const SerdNode uri_node = string_to_node(SERD_URI, uri); - SerdNode prefix; - SerdChunk suffix; - if (serd_env_qualify(_c_obj, &uri_node, &prefix, &suffix)) { - std::string ret(reinterpret_cast<const char*>(prefix.buf), - prefix.n_bytes); - ret.append(":").append(reinterpret_cast<const char*>(suffix.buf), - suffix.len); - return ret; - } - return uri; - } - - inline std::string expand(const std::string& curie) const { - assert(curie.find(':') != std::string::npos); - SerdNode curie_node = string_to_node(SERD_CURIE, curie); - SerdChunk uri_prefix; - SerdChunk uri_suffix; - if (!serd_env_expand(_c_obj, &curie_node, &uri_prefix, &uri_suffix)) { - std::string ret(reinterpret_cast<const char*>(uri_prefix.buf), - uri_prefix.len); - ret.append(reinterpret_cast<const char*>(uri_suffix.buf), - uri_suffix.len); - return ret; - } - std::cerr << "CURIE `" << curie << "' has unknown prefix." << std::endl; - return curie; - } + Namespaces() + : Wrapper<SerdEnv>(serd_env_new(nullptr)) + {} + + ~Namespaces() { serd_env_free(_c_obj); } + + static inline SerdNode string_to_node(SerdType type, const std::string& s) + { + SerdNode ret = {reinterpret_cast<const uint8_t*>(s.c_str()), + s.length(), + s.length(), + 0, + type}; + return ret; + } + + inline void add(const std::string& name, const std::string& uri) + { + const SerdNode name_node = string_to_node(SERD_LITERAL, name); + const SerdNode uri_node = string_to_node(SERD_URI, uri); + serd_env_set_prefix(_c_obj, &name_node, &uri_node); + } + + inline std::string qualify(std::string uri) const + { + const SerdNode uri_node = string_to_node(SERD_URI, uri); + SerdNode prefix; + SerdChunk suffix; + if (serd_env_qualify(_c_obj, &uri_node, &prefix, &suffix)) { + std::string ret(reinterpret_cast<const char*>(prefix.buf), + prefix.n_bytes); + ret.append(":").append(reinterpret_cast<const char*>(suffix.buf), + suffix.len); + return ret; + } + return uri; + } + + inline std::string expand(const std::string& curie) const + { + assert(curie.find(':') != std::string::npos); + SerdNode curie_node = string_to_node(SERD_CURIE, curie); + SerdChunk uri_prefix; + SerdChunk uri_suffix; + if (!serd_env_expand(_c_obj, &curie_node, &uri_prefix, &uri_suffix)) { + std::string ret(reinterpret_cast<const char*>(uri_prefix.buf), + uri_prefix.len); + ret.append(reinterpret_cast<const char*>(uri_suffix.buf), uri_suffix.len); + return ret; + } + std::cerr << "CURIE `" << curie << "' has unknown prefix." << std::endl; + return curie; + } }; /** Sord library state. */ -class World : public Noncopyable, public Wrapper<SordWorld> { +class World + : public Noncopyable + , public Wrapper<SordWorld> +{ public: - inline World() - : _next_blank_id(0) - { - _c_obj = sord_world_new(); - } + inline World() + : _next_blank_id(0) + { + _c_obj = sord_world_new(); + } - inline ~World() { - sord_world_free(_c_obj); - } + inline ~World() { sord_world_free(_c_obj); } - inline uint64_t blank_id() { return _next_blank_id++; } + inline uint64_t blank_id() { return _next_blank_id++; } - inline void add_prefix(const std::string& prefix, const std::string& uri) { - _prefixes.add(prefix, uri); - } + inline void add_prefix(const std::string& prefix, const std::string& uri) + { + _prefixes.add(prefix, uri); + } - inline const Namespaces& prefixes() const { return _prefixes; } - inline Namespaces& prefixes() { return _prefixes; } - inline SordWorld* world() { return _c_obj; } + inline const Namespaces& prefixes() const { return _prefixes; } + inline Namespaces& prefixes() { return _prefixes; } + inline SordWorld* world() { return _c_obj; } private: - Namespaces _prefixes; - std::set<std::string> _blank_ids; - uint64_t _next_blank_id; + Namespaces _prefixes; + std::set<std::string> _blank_ids; + uint64_t _next_blank_id; }; /** An RDF Node (resource, literal, etc) */ -class Node : public Wrapper<SordNode> { +class Node : public Wrapper<SordNode> +{ public: - enum Type { - UNKNOWN = 0, - URI = SORD_URI, - BLANK = SORD_BLANK, - LITERAL = SORD_LITERAL - }; - - inline Node() : Wrapper<SordNode>(nullptr), _world(nullptr) {} - - inline Node(World& world, Type t, const std::string& s); - inline Node(World& world); - inline Node(World& world, const SordNode* node); - inline Node(World& world, SordNode* node, bool copy=false); - inline Node(const Node& other); - inline ~Node(); - - inline Type type() const { - return _c_obj ? static_cast<Type>(sord_node_get_type(_c_obj)) : UNKNOWN; - } - - inline const SordNode* get_node() const { return _c_obj; } - inline SordNode* get_node() { return _c_obj; } - - const SerdNode* to_serd_node() const { - return sord_node_to_serd_node(_c_obj); - } - - inline bool is_valid() const { return type() != UNKNOWN; } - - inline bool operator<(const Node& other) const { - if (type() != other.type()) { - return type() < other.type(); - } else { - return to_string() < other.to_string(); - } - } - - Node& operator=(const Node& other) { - if (&other != this) { - if (_c_obj) { - sord_node_free(_world->c_obj(), _c_obj); - } - _world = other._world; - _c_obj = other._c_obj ? sord_node_copy(other._c_obj) : nullptr; - } - return *this; - } - - inline bool operator==(const Node& other) const { - return sord_node_equals(_c_obj, other._c_obj); - } - - inline const uint8_t* to_u_string() const; - inline const char* to_c_string() const; - inline std::string to_string() const; - - inline bool is_literal_type(const char* type_uri) const; - - inline bool is_uri() const { return _c_obj && type() == URI; } - inline bool is_blank() const { return _c_obj && type() == BLANK; } - inline bool is_int() const { return is_literal_type(SORD_NS_XSD "integer"); } - inline bool is_float() const { return is_literal_type(SORD_NS_XSD "decimal"); } - inline bool is_bool() const { return is_literal_type(SORD_NS_XSD "boolean"); } - - inline int to_int() const; - inline float to_float() const; - inline bool to_bool() const; - - inline static Node blank_id(World& world, const std::string& base="b") { - const uint64_t num = world.blank_id(); - std::ostringstream ss; - ss << base << num; - return Node(world, Node::BLANK, ss.str()); - } + enum Type { + UNKNOWN = 0, + URI = SORD_URI, + BLANK = SORD_BLANK, + LITERAL = SORD_LITERAL + }; + + inline Node() + : Wrapper<SordNode>(nullptr) + , _world(nullptr) + {} + + inline Node(World& world, Type t, const std::string& s); + inline Node(World& world); + inline Node(World& world, const SordNode* node); + inline Node(World& world, SordNode* node, bool copy = false); + inline Node(const Node& other); + inline ~Node(); + + inline Type type() const + { + return _c_obj ? static_cast<Type>(sord_node_get_type(_c_obj)) : UNKNOWN; + } + + inline const SordNode* get_node() const { return _c_obj; } + inline SordNode* get_node() { return _c_obj; } + + const SerdNode* to_serd_node() const + { + return sord_node_to_serd_node(_c_obj); + } + + inline bool is_valid() const { return type() != UNKNOWN; } + + inline bool operator<(const Node& other) const + { + if (type() != other.type()) { + return type() < other.type(); + } else { + return to_string() < other.to_string(); + } + } + + Node& operator=(const Node& other) + { + if (&other != this) { + if (_c_obj) { + sord_node_free(_world->c_obj(), _c_obj); + } + _world = other._world; + _c_obj = other._c_obj ? sord_node_copy(other._c_obj) : nullptr; + } + return *this; + } + + inline bool operator==(const Node& other) const + { + return sord_node_equals(_c_obj, other._c_obj); + } + + inline const uint8_t* to_u_string() const; + inline const char* to_c_string() const; + inline std::string to_string() const; + + inline bool is_literal_type(const char* type_uri) const; + + inline bool is_uri() const { return _c_obj && type() == URI; } + inline bool is_blank() const { return _c_obj && type() == BLANK; } + inline bool is_int() const { return is_literal_type(SORD_NS_XSD "integer"); } + inline bool is_float() const + { + return is_literal_type(SORD_NS_XSD "decimal"); + } + inline bool is_bool() const { return is_literal_type(SORD_NS_XSD "boolean"); } + + inline int to_int() const; + inline float to_float() const; + inline bool to_bool() const; + + inline static Node blank_id(World& world, const std::string& base = "b") + { + const uint64_t num = world.blank_id(); + std::ostringstream ss; + ss << base << num; + return Node(world, Node::BLANK, ss.str()); + } private: - World* _world; + World* _world; }; inline std::ostream& operator<<(std::ostream& os, const Node& node) { - return os << node.to_string(); + return os << node.to_string(); } -class URI : public Node { +class URI : public Node +{ public: - inline URI(World& world, const std::string& s) - : Node(world, Node::URI, s) {} - inline URI(World& world, const std::string& s, const std::string& base) - : Node(world, - sord_new_relative_uri( - world.world(), - reinterpret_cast<const uint8_t*>(s.c_str()), - reinterpret_cast<const uint8_t*>(base.c_str()))) - { - } + inline URI(World& world, const std::string& s) + : Node(world, Node::URI, s) + {} + + inline URI(World& world, const std::string& s, const std::string& base) + : Node( + world, + sord_new_relative_uri(world.world(), + reinterpret_cast<const uint8_t*>(s.c_str()), + reinterpret_cast<const uint8_t*>(base.c_str()))) + {} }; -class Curie : public Node { +class Curie : public Node +{ public: - inline Curie(World& world, const std::string& s) - : Node(world, Node::URI, world.prefixes().expand(s)) {} + inline Curie(World& world, const std::string& s) + : Node(world, Node::URI, world.prefixes().expand(s)) + {} }; -class Literal : public Node { +class Literal : public Node +{ public: - inline Literal(World& world, const std::string& s) - : Node(world, Node::LITERAL, s) {} - - static inline Node decimal(World& world, double d, unsigned frac_digits) { - const SerdNode val = serd_node_new_decimal(d, frac_digits); - const SerdNode type = serd_node_from_string( - SERD_URI, reinterpret_cast<const uint8_t*>(SORD_NS_XSD "decimal")); - - return Node( - world, - sord_node_from_serd_node( - world.c_obj(), world.prefixes().c_obj(), &val, &type, nullptr), - false); - } - - static inline Node integer(World& world, int64_t i) { - const SerdNode val = serd_node_new_integer(i); - const SerdNode type = serd_node_from_string( - SERD_URI, reinterpret_cast<const uint8_t*>(SORD_NS_XSD "integer")); - - return Node( - world, - sord_node_from_serd_node( - world.c_obj(), world.prefixes().c_obj(), &val, &type, nullptr), - false); - } + inline Literal(World& world, const std::string& s) + : Node(world, Node::LITERAL, s) + {} + + static inline Node decimal(World& world, double d, unsigned frac_digits) + { + const SerdNode val = serd_node_new_decimal(d, frac_digits); + const SerdNode type = serd_node_from_string( + SERD_URI, reinterpret_cast<const uint8_t*>(SORD_NS_XSD "decimal")); + + return Node( + world, + sord_node_from_serd_node( + world.c_obj(), world.prefixes().c_obj(), &val, &type, nullptr), + false); + } + + static inline Node integer(World& world, int64_t i) + { + const SerdNode val = serd_node_new_integer(i); + const SerdNode type = serd_node_from_string( + SERD_URI, reinterpret_cast<const uint8_t*>(SORD_NS_XSD "integer")); + + return Node( + world, + sord_node_from_serd_node( + world.c_obj(), world.prefixes().c_obj(), &val, &type, nullptr), + false); + } }; -inline -Node::Node(World& world, Type type, const std::string& s) - : _world(&world) -{ - switch (type) { - case URI: - _c_obj = - sord_new_uri(world.world(), - reinterpret_cast<const unsigned char*>(s.c_str())); - break; - case LITERAL: - _c_obj = - sord_new_literal(world.world(), - nullptr, - reinterpret_cast<const unsigned char*>(s.c_str()), - nullptr); - break; - case BLANK: - _c_obj = - sord_new_blank(world.world(), - reinterpret_cast<const unsigned char*>(s.c_str())); - break; - default: - _c_obj = nullptr; - } - - assert(this->type() == type); +inline Node::Node(World& world, Type type, const std::string& s) + : _world(&world) +{ + switch (type) { + case URI: + _c_obj = sord_new_uri(world.world(), + reinterpret_cast<const unsigned char*>(s.c_str())); + break; + case LITERAL: + _c_obj = sord_new_literal(world.world(), + nullptr, + reinterpret_cast<const unsigned char*>(s.c_str()), + nullptr); + break; + case BLANK: + _c_obj = sord_new_blank(world.world(), + reinterpret_cast<const unsigned char*>(s.c_str())); + break; + default: + _c_obj = nullptr; + } + + assert(this->type() == type); } -inline -Node::Node(World& world) - : _world(&world) +inline Node::Node(World& world) + : _world(&world) { - Node me = blank_id(world); - *this = me; + Node me = blank_id(world); + *this = me; } -inline -Node::Node(World& world, const SordNode* node) - : _world(&world) +inline Node::Node(World& world, const SordNode* node) + : _world(&world) { - _c_obj = sord_node_copy(node); + _c_obj = sord_node_copy(node); } -inline -Node::Node(World& world, SordNode* node, bool copy) - : _world(&world) +inline Node::Node(World& world, SordNode* node, bool copy) + : _world(&world) { - _c_obj = copy ? sord_node_copy(node) : node; + _c_obj = copy ? sord_node_copy(node) : node; } -inline -Node::Node(const Node& other) // NOLINT(bugprone-copy-constructor-init) - : Wrapper<SordNode>() - , _world(other._world) +inline Node::Node(const Node& other) // NOLINT(bugprone-copy-constructor-init) + : Wrapper<SordNode>() + , _world(other._world) { - if (_world) { - _c_obj = other._c_obj ? sord_node_copy(other._c_obj) : nullptr; - } + if (_world) { + _c_obj = other._c_obj ? sord_node_copy(other._c_obj) : nullptr; + } - assert((!_c_obj && !other._c_obj) || to_string() == other.to_string()); + assert((!_c_obj && !other._c_obj) || to_string() == other.to_string()); } -inline -Node::~Node() +inline Node::~Node() { - if (_world) { - sord_node_free(_world->c_obj(), _c_obj); - } + if (_world) { + sord_node_free(_world->c_obj(), _c_obj); + } } inline std::string Node::to_string() const { - return _c_obj ? reinterpret_cast<const char*>(sord_node_get_string(_c_obj)) - : ""; + return _c_obj ? reinterpret_cast<const char*>(sord_node_get_string(_c_obj)) + : ""; } inline const char* Node::to_c_string() const { - return reinterpret_cast<const char*>(sord_node_get_string(_c_obj)); + return reinterpret_cast<const char*>(sord_node_get_string(_c_obj)); } inline const uint8_t* Node::to_u_string() const { - return sord_node_get_string(_c_obj); + return sord_node_get_string(_c_obj); } inline bool Node::is_literal_type(const char* type_uri) const { - if (_c_obj && sord_node_get_type(_c_obj) == SORD_LITERAL) { - const SordNode* datatype = sord_node_get_datatype(_c_obj); - if (datatype && !strcmp(reinterpret_cast<const char*>( - sord_node_get_string(datatype)), - type_uri)) { - return true; - } - } - return false; + if (_c_obj && sord_node_get_type(_c_obj) == SORD_LITERAL) { + const SordNode* datatype = sord_node_get_datatype(_c_obj); + if (datatype && + !strcmp(reinterpret_cast<const char*>(sord_node_get_string(datatype)), + type_uri)) { + return true; + } + } + return false; } inline int Node::to_int() const { - assert(is_int()); - char* endptr = nullptr; - return strtol(reinterpret_cast<const char*>(sord_node_get_string(_c_obj)), - &endptr, - 10); + assert(is_int()); + char* endptr = nullptr; + return strtol( + reinterpret_cast<const char*>(sord_node_get_string(_c_obj)), &endptr, 10); } inline float Node::to_float() const { - assert(is_float()); - return serd_strtod(reinterpret_cast<const char*>( - sord_node_get_string(_c_obj)), - nullptr); + assert(is_float()); + return serd_strtod( + reinterpret_cast<const char*>(sord_node_get_string(_c_obj)), nullptr); } inline bool Node::to_bool() const { - assert(is_bool()); - return !strcmp(reinterpret_cast<const char*>(sord_node_get_string(_c_obj)), - "true"); + assert(is_bool()); + return !strcmp(reinterpret_cast<const char*>(sord_node_get_string(_c_obj)), + "true"); } struct Iter : public Wrapper<SordIter> { - inline Iter(World& world, SordIter* c_obj) - : Wrapper<SordIter>(c_obj), _world(world) {} - - Iter(const Iter&) = delete; - Iter& operator=(const Iter&) = delete; - - inline Iter(Iter&& iter) noexcept - : Wrapper<SordIter>(iter) - , _world(iter._world) - {} - - inline ~Iter() { sord_iter_free(_c_obj); } - - inline bool end() const { return sord_iter_end(_c_obj); } - inline bool next() const { return sord_iter_next(_c_obj); } - inline Iter& operator++() { - assert(!end()); - next(); - return *this; - } - inline Node get_subject() const { - SordQuad quad; - sord_iter_get(_c_obj, quad); - return Node(_world, quad[SORD_SUBJECT]); - } - inline Node get_predicate() const { - SordQuad quad; - sord_iter_get(_c_obj, quad); - return Node(_world, quad[SORD_PREDICATE]); - } - inline Node get_object() const { - SordQuad quad; - sord_iter_get(_c_obj, quad); - return Node(_world, quad[SORD_OBJECT]); - } - World& _world; + inline Iter(World& world, SordIter* c_obj) + : Wrapper<SordIter>(c_obj) + , _world(world) + {} + + Iter(const Iter&) = delete; + Iter& operator=(const Iter&) = delete; + + inline Iter(Iter&& iter) noexcept + : Wrapper<SordIter>(iter) + , _world(iter._world) + {} + + inline ~Iter() { sord_iter_free(_c_obj); } + + inline bool end() const { return sord_iter_end(_c_obj); } + inline bool next() const { return sord_iter_next(_c_obj); } + inline Iter& operator++() + { + assert(!end()); + next(); + return *this; + } + inline Node get_subject() const + { + SordQuad quad; + sord_iter_get(_c_obj, quad); + return Node(_world, quad[SORD_SUBJECT]); + } + inline Node get_predicate() const + { + SordQuad quad; + sord_iter_get(_c_obj, quad); + return Node(_world, quad[SORD_PREDICATE]); + } + inline Node get_object() const + { + SordQuad quad; + sord_iter_get(_c_obj, quad); + return Node(_world, quad[SORD_OBJECT]); + } + World& _world; }; /** An RDF Model (collection of triples). */ -class Model : public Noncopyable, public Wrapper<SordModel> { +class Model + : public Noncopyable + , public Wrapper<SordModel> +{ public: - inline Model(World& world, - const std::string& base_uri, - unsigned indices = (SORD_SPO | SORD_OPS), - bool graphs = true); - - inline ~Model(); - - inline const Node& base_uri() const { return _base; } - - size_t num_quads() const { return sord_num_quads(_c_obj); } - - inline void load_file(SerdEnv* env, - SerdSyntax syntax, - const std::string& uri, - const std::string& base_uri=""); - - inline void load_string(SerdEnv* env, - SerdSyntax syntax, - const char* str, - size_t len, - const std::string& base_uri); - - inline SerdStatus write_to_file( - const std::string& uri, - SerdSyntax syntax = SERD_TURTLE, - SerdStyle style = static_cast<SerdStyle>( - SERD_STYLE_ABBREVIATED - |SERD_STYLE_CURIED - |SERD_STYLE_RESOLVED)); - - inline std::string write_to_string( - const std::string& base_uri, - SerdSyntax syntax = SERD_TURTLE, - SerdStyle style = static_cast<SerdStyle>( - SERD_STYLE_ABBREVIATED - |SERD_STYLE_CURIED - |SERD_STYLE_RESOLVED)); - - inline void add_statement(const Node& subject, - const Node& predicate, - const Node& object); - - inline Iter find(const Node& subject, - const Node& predicate, - const Node& object); - - inline Node get(const Node& subject, - const Node& predicate, - const Node& object); - - inline World& world() const { return _world; } + inline Model(World& world, + const std::string& base_uri, + unsigned indices = (SORD_SPO | SORD_OPS), + bool graphs = true); + + inline ~Model(); + + inline const Node& base_uri() const { return _base; } + + size_t num_quads() const { return sord_num_quads(_c_obj); } + + inline void load_file(SerdEnv* env, + SerdSyntax syntax, + const std::string& uri, + const std::string& base_uri = ""); + + inline void load_string(SerdEnv* env, + SerdSyntax syntax, + const char* str, + size_t len, + const std::string& base_uri); + + inline SerdStatus write_to_file(const std::string& uri, + SerdSyntax syntax = SERD_TURTLE, + SerdStyle style = static_cast<SerdStyle>( + SERD_STYLE_ABBREVIATED | SERD_STYLE_CURIED | + SERD_STYLE_RESOLVED)); + + inline std::string write_to_string( + const std::string& base_uri, + SerdSyntax syntax = SERD_TURTLE, + SerdStyle style = static_cast<SerdStyle>(SERD_STYLE_ABBREVIATED | + SERD_STYLE_CURIED | + SERD_STYLE_RESOLVED)); + + inline void add_statement(const Node& subject, + const Node& predicate, + const Node& object); + + inline Iter find(const Node& subject, + const Node& predicate, + const Node& object); + + inline Node get(const Node& subject, + const Node& predicate, + const Node& object); + + inline World& world() const { return _world; } private: - World& _world; - Node _base; + World& _world; + Node _base; }; /** Create an empty in-memory RDF model. */ -inline -Model::Model(World& world, - const std::string& base_uri, - unsigned indices, - bool graphs) - : _world(world) - , _base(world, Node::URI, base_uri) -{ - _c_obj = sord_new(_world.world(), indices, graphs); +inline Model::Model(World& world, + const std::string& base_uri, + unsigned indices, + bool graphs) + : _world(world) + , _base(world, Node::URI, base_uri) +{ + _c_obj = sord_new(_world.world(), indices, graphs); } inline void -Model::load_string(SerdEnv* env, - SerdSyntax syntax, - const char* str, - size_t /*len*/, +Model::load_string(SerdEnv* env, + SerdSyntax syntax, + const char* str, + size_t /*len*/, const std::string& /*base_uri*/) { - SerdReader* reader = sord_new_reader(_c_obj, env, syntax, nullptr); - serd_reader_read_string(reader, reinterpret_cast<const uint8_t*>(str)); - serd_reader_free(reader); + SerdReader* reader = sord_new_reader(_c_obj, env, syntax, nullptr); + serd_reader_read_string(reader, reinterpret_cast<const uint8_t*>(str)); + serd_reader_free(reader); } inline Model::~Model() { - sord_free(_c_obj); + sord_free(_c_obj); } inline void @@ -562,64 +589,58 @@ Model::load_file(SerdEnv* env, const std::string& data_uri, const std::string& /*base_uri*/) { - uint8_t* path = - serd_file_uri_parse(reinterpret_cast<const uint8_t*>(data_uri.c_str()), - nullptr); - if (!path) { - fprintf(stderr, "Failed to parse file URI <%s>\n", data_uri.c_str()); - return; - } - - // FIXME: blank prefix parameter? - SerdReader* reader = sord_new_reader(_c_obj, env, syntax, nullptr); - serd_reader_read_file(reader, path); - serd_reader_free(reader); - serd_free(path); + uint8_t* path = serd_file_uri_parse( + reinterpret_cast<const uint8_t*>(data_uri.c_str()), nullptr); + if (!path) { + fprintf(stderr, "Failed to parse file URI <%s>\n", data_uri.c_str()); + return; + } + + // FIXME: blank prefix parameter? + SerdReader* reader = sord_new_reader(_c_obj, env, syntax, nullptr); + serd_reader_read_file(reader, path); + serd_reader_free(reader); + serd_free(path); } inline SerdStatus Model::write_to_file(const std::string& uri, SerdSyntax syntax, SerdStyle style) { - uint8_t* path = - serd_file_uri_parse(reinterpret_cast<const uint8_t*>(uri.c_str()), - nullptr); - if (!path) { - fprintf(stderr, "Failed to parse file URI <%s>\n", uri.c_str()); - return SERD_ERR_BAD_ARG; - } - - FILE* const fd = fopen(reinterpret_cast<const char*>(path), "w"); - if (!fd) { - fprintf(stderr, "Failed to open file %s\n", path); - serd_free(path); - return SERD_ERR_UNKNOWN; - } - serd_free(path); - - SerdURI base_uri = SERD_URI_NULL; - if (serd_uri_parse(reinterpret_cast<const uint8_t*>(uri.c_str()), - &base_uri)) { - fprintf(stderr, "Invalid base URI <%s>\n", uri.c_str()); - fclose(fd); - return SERD_ERR_BAD_ARG; - } - - SerdWriter* writer = serd_writer_new(syntax, - style, - _world.prefixes().c_obj(), - &base_uri, - serd_file_sink, - fd); - - serd_env_foreach(_world.prefixes().c_obj(), - reinterpret_cast<SerdPrefixSink>(serd_writer_set_prefix), - writer); - - sord_write(_c_obj, writer, nullptr); - serd_writer_free(writer); - fclose(fd); - - return SERD_SUCCESS; + uint8_t* path = + serd_file_uri_parse(reinterpret_cast<const uint8_t*>(uri.c_str()), nullptr); + if (!path) { + fprintf(stderr, "Failed to parse file URI <%s>\n", uri.c_str()); + return SERD_ERR_BAD_ARG; + } + + FILE* const fd = fopen(reinterpret_cast<const char*>(path), "w"); + if (!fd) { + fprintf(stderr, "Failed to open file %s\n", path); + serd_free(path); + return SERD_ERR_UNKNOWN; + } + serd_free(path); + + SerdURI base_uri = SERD_URI_NULL; + if (serd_uri_parse(reinterpret_cast<const uint8_t*>(uri.c_str()), + &base_uri)) { + fprintf(stderr, "Invalid base URI <%s>\n", uri.c_str()); + fclose(fd); + return SERD_ERR_BAD_ARG; + } + + SerdWriter* writer = serd_writer_new( + syntax, style, _world.prefixes().c_obj(), &base_uri, serd_file_sink, fd); + + serd_env_foreach(_world.prefixes().c_obj(), + reinterpret_cast<SerdPrefixSink>(serd_writer_set_prefix), + writer); + + sord_write(_c_obj, writer, nullptr); + serd_writer_free(writer); + fclose(fd); + + return SERD_SUCCESS; } extern "C" { @@ -627,15 +648,14 @@ extern "C" { static size_t string_sink(const void* buf, size_t len, void* stream) { - try { - auto* str = static_cast<std::string*>(stream); - str->append(static_cast<const char*>(buf), len); - return len; - } catch (...) { - return 0; - } + try { + auto* str = static_cast<std::string*>(stream); + str->append(static_cast<const char*>(buf), len); + return len; + } catch (...) { + return 0; + } } - } inline std::string @@ -643,34 +663,30 @@ Model::write_to_string(const std::string& base_uri_str, SerdSyntax syntax, SerdStyle style) { - SerdURI base_uri = SERD_URI_NULL; - if (serd_uri_parse(reinterpret_cast<const uint8_t*>(base_uri_str.c_str()), - &base_uri)) { - fprintf(stderr, "Invalid base URI <%s>\n", base_uri_str.c_str()); - return ""; - } + SerdURI base_uri = SERD_URI_NULL; + if (serd_uri_parse(reinterpret_cast<const uint8_t*>(base_uri_str.c_str()), + &base_uri)) { + fprintf(stderr, "Invalid base URI <%s>\n", base_uri_str.c_str()); + return ""; + } - std::string ret; + std::string ret; - SerdWriter* writer = serd_writer_new(syntax, - style, - _world.prefixes().c_obj(), - &base_uri, - string_sink, - &ret); + SerdWriter* writer = serd_writer_new( + syntax, style, _world.prefixes().c_obj(), &base_uri, string_sink, &ret); - const SerdNode base_uri_node = serd_node_from_string( - SERD_URI, reinterpret_cast<const uint8_t*>(base_uri_str.c_str())); - serd_writer_set_base_uri(writer, &base_uri_node); + const SerdNode base_uri_node = serd_node_from_string( + SERD_URI, reinterpret_cast<const uint8_t*>(base_uri_str.c_str())); + serd_writer_set_base_uri(writer, &base_uri_node); - serd_env_foreach(_world.prefixes().c_obj(), - reinterpret_cast<SerdPrefixSink>(serd_writer_set_prefix), - writer); + serd_env_foreach(_world.prefixes().c_obj(), + reinterpret_cast<SerdPrefixSink>(serd_writer_set_prefix), + writer); - sord_write(_c_obj, writer, nullptr); + sord_write(_c_obj, writer, nullptr); - serd_writer_free(writer); - return ret; + serd_writer_free(writer); + return ret; } inline void @@ -678,37 +694,27 @@ Model::add_statement(const Node& subject, const Node& predicate, const Node& object) { - SordQuad quad = { subject.c_obj(), - predicate.c_obj(), - object.c_obj(), - nullptr }; + SordQuad quad = {subject.c_obj(), predicate.c_obj(), object.c_obj(), nullptr}; - sord_add(_c_obj, quad); + sord_add(_c_obj, quad); } inline Iter -Model::find(const Node& subject, - const Node& predicate, - const Node& object) +Model::find(const Node& subject, const Node& predicate, const Node& object) { - SordQuad quad = { subject.c_obj(), - predicate.c_obj(), - object.c_obj(), - nullptr }; + SordQuad quad = {subject.c_obj(), predicate.c_obj(), object.c_obj(), nullptr}; - return Iter(_world, sord_find(_c_obj, quad)); + return Iter(_world, sord_find(_c_obj, quad)); } inline Node -Model::get(const Node& subject, - const Node& predicate, - const Node& object) +Model::get(const Node& subject, const Node& predicate, const Node& object) { - SordNode* c_node = sord_get( - _c_obj, subject.c_obj(), predicate.c_obj(), object.c_obj(), nullptr); - return Node(_world, c_node, false); + SordNode* c_node = sord_get( + _c_obj, subject.c_obj(), predicate.c_obj(), object.c_obj(), nullptr); + return Node(_world, c_node, false); } -} // namespace Sord +} // namespace Sord -#endif // SORD_SORDMM_HPP +#endif // SORD_SORDMM_HPP |