Scala代码将JSON字符串插入mongo DB

本文介绍了Scala代码将JSON字符串插入mongo DB的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

我有下面的JSON字符串，

{"card_id" : 75893645814809,"cust_id": 1008,"card_info": {"card_type" : "Travel Card","credit_limit": 126839},"card_dates" : [{"date":"1997-09-09" },{"date":"2007-09-07" }]}

，我想将此插入到MongoDB中.谁能帮我这个忙.

and I want to insert this to MongoDB. Can anyone help me on this.

预先感谢

推荐答案

例如:

val mongo_url = MongoClientURI("mongo://...") val mongoClient: MongoClient = MongoClient(mongo_url) val db = mongoClient("radar") val coll = db("job_history") val job = MongoDBObject("name"-> spark, "status"-> "success") coll.insert(job) coll.find().foreach(println)

输出将如下所示:

{"_id":{"$ oid":"5984b745a63eeeacbcbd301d"}，"id":22，"name":"shenrf22"}

{ "_id" : { "$oid" : "5984b745a63eeeacbcbd301d"} , "id" : 22 , "name" : "shenrf22"}