reduce ditto

Author: guojidan

src/types/redis_json.cc

@@ -205,22 +205,11 @@ rocksdb::Status Json::ArrLen(const std::string &user_key, const std::string &pat
 rocksdb::Status Json::StrAppend(const std::string &user_key, const std::string &path, const std::string &value,
                                 std::vector<uint64_t> &append_cnt) {
   auto ns_key = AppendNamespacePrefix(user_key);
-
-  LockGuard guard(storage_->GetLockManager(), ns_key);
-
-  std::string bytes;
   JsonMetadata metadata;
-  Slice rest;
-  auto s = GetMetadata(kRedisJson, ns_key, &bytes, &metadata, &rest);
+  JsonValue json_val;
+  auto s = read(ns_key, &metadata, &json_val);
   if (!s.ok()) return s;
 
-  if (metadata.format != JsonStorageFormat::JSON)
-    return rocksdb::Status::NotSupported("JSON storage format not supported");
-
-  auto json_res = JsonValue::FromString(rest.ToStringView());
-  if (!json_res) return rocksdb::Status::Corruption(json_res.Msg());
-  auto json_val = *std::move(json_res);
-
   auto append_res = json_val.StrAppend(path, value, append_cnt);
   if (!append_res) return rocksdb::Status::InvalidArgument(append_res.Msg());
   // need Reverse order

tests/cppunit/types/json_test.cc

@@ -276,13 +276,13 @@ TEST_F(RedisJsonTest, ArrLen) {
 
 TEST_F(RedisJsonTest, StrAppend) {
   ASSERT_TRUE(json_->Set(key_, "$", R"({"a":"foo", "nested": {"a": "hello"}, "nested2": {"a": 31}})").ok());
-  ASSERT_TRUE(json_->StrAppend(key_, "$.a", "be", append_cnt_).ok());
+  ASSERT_TRUE(json_->StrAppend(key_, "$.a", "\"be\"", append_cnt_).ok());
   ASSERT_EQ(append_cnt_.size(), 1);
   ASSERT_EQ(append_cnt_[0], 5);
 
   append_cnt_.clear();
   ASSERT_TRUE(json_->Set(key_, "$", R"({"a":"foo", "nested": {"a": "hello"}, "nested2": {"a": 31}})").ok());
-  ASSERT_TRUE(json_->StrAppend(key_, "$..a", "be", append_cnt_).ok());
+  ASSERT_TRUE(json_->StrAppend(key_, "$..a", "\"be\"", append_cnt_).ok());
   ASSERT_EQ(append_cnt_.size(), 3);
   int64_t result1[] = {5, 7, -1};
   for (int i = 0; i < 3; ++i) {

tests/gocase/unit/type/json/json_test.go

@@ -135,12 +135,12 @@ func TestJson(t *testing.T) {
 		var result1 = make([]interface{}, 0)
 		result1 = append(result1, int64(5))
 		require.NoError(t, rdb.Do(ctx, "JSON.SET", "a", "$", `{"a":"foo", "nested": {"a": "hello"}, "nested2": {"a": 31}}`).Err())
-		require.Equal(t, rdb.Do(ctx, "JSON.STRAPPEND", "a", "$.a", "be").Val(), result1)
+		require.Equal(t, rdb.Do(ctx, "JSON.STRAPPEND", "a", "$.a", "\"be\"").Val(), result1)
 
 		var result2 = make([]interface{}, 0)
 		result2 = append(result2, int64(5), int64(7), interface{}(nil))
 		require.NoError(t, rdb.Do(ctx, "JSON.SET", "a", "$", `{"a":"foo", "nested": {"a": "hello"}, "nested2": {"a": 31}}`).Err())
-		require.Equal(t, rdb.Do(ctx, "JSON.STRAPPEND", "a", "$..a", "be").Val(), result2)
+		require.Equal(t, rdb.Do(ctx, "JSON.STRAPPEND", "a", "$..a", "\"be\"").Val(), result2)
 	})
 
 	t.Run("JSON.STRLEN basics", func(t *testing.T) {