redis_result.hpp

浏览该文件的文档.

#ifndef NEFORCE_DATABASE_REDIS_RESULT_HPP__
#define NEFORCE_DATABASE_REDIS_RESULT_HPP__

 
#ifdef NEFORCE_SUPPORT_HIREDIS
#    include <hiredis/hiredis.h>
#    include "NeForce/db/db_interface.hpp"
NEFORCE_BEGIN_NAMESPACE__



struct NEFORCE_API redis_result final : idb_kv_result {
private:
    ::redisReply* result_ = nullptr; 
    size_type cursor_ = 0;           
    size_type rows_ = 0;             
 
    unique_ptr<vector<string>> column_names_;           
    unique_ptr<vector<pair<string, string>>> kv_pairs_; 
 
    size_type kv_cursor_ = 0; 
    bool is_array_ = false;   
 
    NEFORCE_NODISCARD string get_string() const;
 
public:
    redis_result();

    explicit redis_result(::redisReply* reply);

    ~redis_result() override;

    NEFORCE_NODISCARD bool empty() const noexcept override {
        return result_ == nullptr || (rows_ == 0 && kv_pairs_->empty());
    }

    NEFORCE_NODISCARD bool next() noexcept override;

    NEFORCE_NODISCARD string_view key() const noexcept override;

    NEFORCE_NODISCARD string_view value() const noexcept override;

    NEFORCE_NODISCARD bool value_bool() const override;

    NEFORCE_NODISCARD int64_t value_int64() const override;

    NEFORCE_NODISCARD double value_double() const override;

    NEFORCE_NODISCARD vector<string> value_array() const override;

    NEFORCE_NODISCARD const vector<pair<string, string>>& value_hash() const override { return *kv_pairs_; }

    NEFORCE_NODISCARD int type() const noexcept { return result_ != nullptr ? result_->type : -1; }

    NEFORCE_NODISCARD bool is_nil() const noexcept { return result_ != nullptr && result_->type == REDIS_REPLY_NIL; }
};
 // Redis
 // Database
 
NEFORCE_END_NAMESPACE__
#endif
#endif // NEFORCE_DATABASE_REDIS_RESULT_HPP__