0

sparkを使用してmongodbの既存の文書に埋め込みフィールドに新しいエントリを挿入します。私はspark-mongodbライブラリのupdate + pushサポート?

db.blogs.update({id:"001"}, {$push:{comments:{title:"commentX",content:".."}}}); 

をやりたい

Blog { 
    id:"001" 
    title:"This is a test blog", 
    content:"...." 
    comments:[{title:"comment1",content:".."},{title:"comment2",content:"..."}]  
} 

は、それがこのライブラリでは、現在は可能ですか?もしそうでなければ、正しい方向に向けることができますか?

私は火花MongoDBのためカスバライブラリを使用して望んだの操作を行うことができたアドバンス

答えて

0

に感謝します。

import java.sql.Timestamp 
import java.util.Date 

import com.mongodb.casbah.MongoClient 
import com.mongodb.casbah.commons.MongoDBObject 
import com.mongodb.casbah.query.Imports._ 

object TestCasbah { 

    def main(args: Array[String]) { 
    val mongoClient = MongoClient("172.18.96.45", 27017) 
    val db = mongoClient("agentCallRecord") 
    val coll = db("CallDetails") 
    val query = MongoDBObject("agentId" -> "agent_1") 
    val callRatingMongoObject = MongoDBObject("audioId" -> 12351,"startTime" -> new Timestamp(new Date().getTime).toString, "endTime" -> new Timestamp(new Date().getTime).toString, "totalScore" -> 1, "sentiment" -> "NEGATIVE") 
    val update = $push("callRating" -> callRatingMongoObject) 
    coll.update(query, update) 
    } 
} 
関連する問題