diff --git a/storage/tianmu/handler/tianmu_handler.cpp b/storage/tianmu/handler/tianmu_handler.cpp index fe069fe87..a6b55d212 100644 --- a/storage/tianmu/handler/tianmu_handler.cpp +++ b/storage/tianmu/handler/tianmu_handler.cpp @@ -154,7 +154,8 @@ static core::Value GetValueFromField(Field *f) { return v; } -TianmuHandler::TianmuHandler(handlerton *hton, TABLE_SHARE *table_arg) : handler(hton, table_arg) { +TianmuHandler::TianmuHandler(handlerton *hton, TABLE_SHARE *table_arg, bool partitioned) + : handler(hton, table_arg), m_partitioned(partitioned) { ref_length = sizeof(uint64_t); } diff --git a/storage/tianmu/handler/tianmu_handler.h b/storage/tianmu/handler/tianmu_handler.h index 058465dda..02a3938f7 100644 --- a/storage/tianmu/handler/tianmu_handler.h +++ b/storage/tianmu/handler/tianmu_handler.h @@ -27,7 +27,7 @@ namespace dbhandler { // Class definition for the storage engine class TianmuHandler final : public handler { public: - TianmuHandler(handlerton *hton, TABLE_SHARE *table_arg); + TianmuHandler(handlerton *hton, TABLE_SHARE *table_arg, bool partitioned); virtual ~TianmuHandler() = default; /* The name that will be used for display purposes */ const char *table_type() const override { return "TIANMU"; } @@ -188,6 +188,7 @@ class TianmuHandler final : public handler { std::unique_ptr m_cq; bool m_result = false; std::vector> blob_buffers; + bool m_partitioned = false; }; } // namespace dbhandler diff --git a/storage/tianmu/handler/tianmu_handler_com.cpp b/storage/tianmu/handler/tianmu_handler_com.cpp index 14f9a35b0..39636b919 100644 --- a/storage/tianmu/handler/tianmu_handler_com.cpp +++ b/storage/tianmu/handler/tianmu_handler_com.cpp @@ -63,9 +63,8 @@ static int rcbase_done_func([[maybe_unused]] void *p) { DBUG_RETURN(0); } -handler *rcbase_create_handler(handlerton *hton, TABLE_SHARE *table, bool partitioned, - MEM_ROOT *mem_root) { // stonedb8 TODO - return new (mem_root) TianmuHandler(hton, table); +handler *rcbase_create_handler(handlerton *hton, TABLE_SHARE *table, bool partitioned, MEM_ROOT *mem_root) { + return new (mem_root) TianmuHandler(hton, table, partitioned); } int rcbase_panic_func([[maybe_unused]] handlerton *hton, enum ha_panic_function flag) {