Improve code

Author: liuh-80

common/dbconnector.cpp

@@ -10,7 +10,7 @@
 
 #include "common/dbconnector.h"
 #include "common/redisreply.h"
-#include "common/redisapi.h"
+//#include "common/redisapi.h"
 #include "common/redispipeline.h"
 #include "common/pubsub.h"
 
@@ -884,9 +884,7 @@ void DBConnector::hmset(const std::unordered_map<std::string, std::vector<std::p
     RedisPipeline pipe(this);
     for (auto& hash : multiHash)
     {
-        RedisCommand hset;
-        hset.formatHSET(hash.first, hash.second.begin(), hash.second.end());
-        pipe.push(hset, REDIS_REPLY_INTEGER);
+        pipe.pushHset(hash.first, hash.second.begin(), hash.second.end());
     }
 
     pipe.flush();
@@ -899,9 +897,7 @@ void DBConnector::del(const std::vector<std::string>& keys)
     RedisPipeline pipe(this);
     for (auto& key : keys)
     {
-        RedisCommand del;
-        del.formatDEL(key);
-        pipe.push(del, REDIS_REPLY_INTEGER);
+        pipe.pushDel(key);
     }
 
     pipe.flush();

common/redispipeline.h

@@ -62,6 +62,26 @@ class RedisPipeline {
         return r.release();
     }
 
+    redisReply *pushHset(const std::string& key, const std::map<std::string, std::string> &values)
+    {
+        return pushHset(key, values.begin(), values.end());
+    }
+
+    template<typename InputIterator>
+    redisReply *pushHset(const std::string& key, const InputIterator& begin, const InputIterator& end)
+    {
+        RedisCommand hset;
+        hset.formatHSET(key, begin, end);
+        return push(hset, REDIS_REPLY_INTEGER);
+    }
+
+    redisReply *pushDel(const std::string& key)
+    {
+        RedisCommand del;
+        del.formatDEL(key);
+        return push(del, REDIS_REPLY_INTEGER);
+    }
+
     std::string loadRedisScript(const std::string& script)
     {
         RedisCommand loadcmd;