1

以下の構造のmongodbドキュメントがあります。

{

    "key4" : 

         [
           {"k1":"v1", "k2":"va1", "k3":"value1"},         
           {"k1":"v2", "k2":"va2", "k4":"name"},
           {"k1":"v3", "k2":"va3"}
         ]
}

このドキュメントを特定の構造で更新していたとき。

{

    "key4" : 

         [
           {"k1":"v1", "k3":"val1"},         
           {"k1":"v2", "k3":"val2"},
           {"k1":"v3", "k3":"val3"},
           {"k1":"v4", "k3":"val4"}
         ]
}

として出力する必要があります。

{

"key4" : 

         [
           {"k1":"v1", "k2":"va1", "k3":"val1"},         
           {"k1":"v2", "k2":"va2", "k3":"val2", "k4":"name"},
           {"k1":"v3", "k2":"va3", "k3":"val3"},
           {"k1":"v4", "k3":"val4"}
         ]
}

つまり、「k1」の値が新しい配列に存在する場合、配列の唯一のオブジェクトをnewにマージする必要があります。私はこの構造をclojureマップに実装しています。

4

2 に答える 2

1

merge-with、、、の組み合わせで非常mapに近づくことができますmerge

user> a
{"key4" [{"k1" "v1", "k2" "va1", "k3" "value1"} 
         {"k1" "v2", "k2" "va2", "k4" "name"} 
         {"k1" "v3", "k2" "va3"}]}
user> b
{"key4" [{"k1" "v1", "k3" "val1"} 
         {"k1" "v2", "k3" "val2"} 
         {"k1" "v3", "k3" "val3"} 
         {"k1" "v4", "k3" "val4"}]}
user> (merge-with #(map merge %1 %2) a b)
{"key4" 
    ({"k1" "v1", "k2" "va1", "k3" "val1"} 
     {"k1" "v2", "k2" "va2", "k3" "val2", "k4" "name"} 
     {"k1" "v3", "k2" "va3", "k3" "val3"})}
user>

次に、長いセットのアイテムをマージする必要があります。

于 2012-04-18T22:15:26.250 に答える
0

元の質問では、主にClojureを対象とした回答を探しているのか、MongoDBの回答を対象とした回答を探しているのかが明確ではありません。MongoDBを対象とした答えに挑戦します。

読み取りまたは更新のパフォーマンスに関心があるかどうかに応じて、いくつかのトレードオフがあります

提供されたスキーマには、読み取りは高速ですが更新が複雑な配列が埋め込まれているため、結果を確認し、プッシュ/追加するために2回目の更新が必要です。

単一の更新/挿入要求に対してMongoDBアップサートを利用する場合は、スキーマの埋め込みを解除/フラット化できますが、その後、複数のドキュメントを読み取る必要があります。

以下に、Leiningenでmonger [com.novemberain / monger "1.0.0-beta4"]を使用して、両方のアプローチのClojure/mongerコードを見つけてください。

(ns FREE-10649-clojure.test.core
  (:use [FREE-10649-clojure.core])
  (:use [clojure.test])
  (:require [monger.core] [monger.collection] [monger.query])
  (:use [monger.operators])
  (:import [org.bson.types ObjectId] [com.mongodb DB WriteConcern]))

;; some operators are missing from monger
(defmacro ^{:private true} defoperator
  [operator]
    (let [op# (str operator)
       op-sym# (symbol op#)]
      `(def ~op-sym# ~op#)))

(defoperator $exists)
(defoperator $mod)
(defoperator $size)
(defoperator $type)
(defoperator $not)

(deftest mytest

    (def initial_doc {
        "key4" [
                { "k1" "v1", "k2" "va1", "k3" "value1" }
                { "k1" "v2", "k2" "va2", "k4" "name" }
                { "k1" "v3", "k2" "va3" }
            ]
        }
    )
    (def data_to_update {
        "key4" [
                { "k1" "v1", "k3" "val1" }
                { "k1" "v2", "k3" "val2" }
                { "k1" "v3", "k3" "val3" }
                { "k1" "v4", "k3" "val4" }
            ]
        }
    )
    (def expected_doc {
        "key4" [
                { "k1" "v1", "k2" "va1", "k3" "val1" }
                { "k1" "v2", "k2" "va2", "k3" "val2", "k4" "name" }
                { "k1" "v3", "k2" "va3", "k3" "val3" }
                { "k1" "v4", "k3" "val4" }
            ]
        }
    )

    (monger.core/connect!)
    (monger.core/set-db! (monger.core/get-db "test"))
    (def coll-name "free10649")

    ;; user-supplied schema
    (monger.collection/remove coll-name)
    (is (= 0 (monger.collection/count coll-name)))

    (monger.collection/insert coll-name initial_doc)
    (is (= 1 (monger.collection/count coll-name)))

    (doseq [outer_key (keys data_to_update)]
      (def array_of_updates (data_to_update outer_key))
      (doseq [object_of_updates array_of_updates]
        (def k1 "k1")
        (def k3 "k3")
        (def v1 (object_of_updates k1))
        (def v3 (object_of_updates k3))
        (def query { outer_key { $elemMatch { k1 v1 } } })
        (def update { $set { (str outer_key ".$." k3) v3 } })
        (monger.collection/update coll-name query update)
        (if (false? (monger.result/updated-existing? (monger.core/get-last-error)))
          (monger.collection/update coll-name { outer_key { $exists true } } { $push { outer_key object_of_updates } })
        )
      )
    )
    (prn "user-supplied-schema updated document")
    (prn (monger.collection/find-maps coll-name))

    ;; flattened schema
    (monger.collection/remove coll-name)
    (is (= 0 (monger.collection/count coll-name)))

    (doseq [outer_key (keys initial_doc)]
      (def array_of_docs (initial_doc outer_key))
      (doseq [doc array_of_docs]
        (monger.collection/insert coll-name (merge { outer_key true } doc))
      )
    )
    (prn "flattened-schema initial documents")
    (prn (monger.collection/find-maps coll-name))

    (monger.collection/ensure-index coll-name { "key4" 1 "k1" 1 })
    ;;(monger.collection/explain (monger.collection/find coll-name { "key4" { $exists true } })) ;; missing explain in monger(?)

    (doseq [outer_key (keys data_to_update)]
      (def array_of_updates (data_to_update outer_key))
      (doseq [object_of_updates array_of_updates]
        (def k1 "k1")
        (def v1 (object_of_updates k1))
        (def query { outer_key { $exists true } k1 v1 })
        (def update { $set (merge { outer_key true } object_of_updates) })
        (monger.collection/update coll-name query update :upsert true)
      )
    )

    (prn "flattened-schema updated documents")
    (prn (monger.collection/find-maps coll-name))
)
于 2012-04-20T19:01:43.533 に答える