MongoDB 将Json数据直接写入MongoDB的方法

java版本

<span style="color: #000000;">import com.mongodb.MongoClient;
import com.mongodb.DBObject;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.util.JSON;
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 构造一个Json字符串</span>
String json = <span style="color: #800000;">"</span><span style="color: #800000;"> {</span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘school_code‘ : ‘111111‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘school_name‘ : ‘汉东政法大学‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘teacher_idcard‘ : ‘0000001‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘teacher_name‘ : ‘高育良‘ </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> } </span><span style="color: #800000;">"</span><span style="color: #000000;">;
MongoClient mongoClient </span>= <span style="color: #0000ff;">new</span> MongoClient(<span style="color: #800000;">"</span><span style="color: #800000;">10.4.120.83</span><span style="color: #800000;">"</span>, <span style="color: #800080;">27017</span><span style="color: #000000;">);
MongoDatabase database </span>= mongoClient.getDatabase(<span style="color: #800000;">"</span><span style="color: #800000;">dbName</span><span style="color: #800000;">"</span><span style="color: #000000;">);
MongoCollection</span><DBObject> collection = database.getCollection(<span style="color: #800000;">"</span><span style="color: #800000;">collectionName</span><span style="color: #800000;">"</span>, DBObject.<span style="color: #0000ff;">class</span><span style="color: #000000;">);    
DBObject bson </span>=<span style="color: #000000;"> (DBObject)JSON.parse(json);
collection.insertOne(bson);</span>

2、将字符串转换成org.bson.Document

scala版本

<span style="color: #000000;">import org.bson.Document
import com.mongodb.casbah.{MongoClient, MongoCollection}
import com.mongodb.util.JSON;
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 构造一个Json字符串</span>
val json = s<span style="color: #800000;">"""</span><span style="color: #800000;">{</span>
           |  <span style="color: #800000;">"</span><span style="color: #800000;">school_code</span><span style="color: #800000;">"</span> : <span style="color: #800000;">"</span><span style="color: #800000;">${school_code}</span><span style="color: #800000;">"</span><span style="color: #000000;">,
           </span>|  <span style="color: #800000;">"</span><span style="color: #800000;">school_name</span><span style="color: #800000;">"</span> : <span style="color: #800000;">"</span><span style="color: #800000;">${school_name}</span><span style="color: #800000;">"</span><span style="color: #000000;">,
           </span>|  <span style="color: #800000;">"</span><span style="color: #800000;">teacher_idcard</span><span style="color: #800000;">"</span> : <span style="color: #800000;">"</span><span style="color: #800000;">${teacher_idcard}</span><span style="color: #800000;">"</span><span style="color: #000000;">,
           </span>|  <span style="color: #800000;">"</span><span style="color: #800000;">teacher_name</span><span style="color: #800000;">"</span> : <span style="color: #800000;">"</span><span style="color: #800000;">${teacher_name}</span><span style="color: #800000;">"</span>
           |<span style="color: #000000;">}
           </span>|<span style="color: #800000;">"""</span><span style="color: #800000;">.stripMargin</span>
<span style="color: #000000;">
val document:Document </span>=<span style="color: #000000;"> Document.parse(json)
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 注意！com.mongodb.casbah.MongoCollection只支持写DBObject的子类，
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 不支持写入Document类的对象，可以使用com.mongodb.client.MongoCollection
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 写入Document类的对象，这里能写入是因为用了自定义的隐式转换函数，将
</span><span style="color: #008000;">//</span><span style="color: #008000;"> Document转换成了DBObject
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 自定义的隐式转换函数</span>
<span style="color: #0000ff;">implicit</span> def document2DBObject(doc: Document): DBObject =<span style="color: #000000;"> JSON.parse(doc.toJson).asInstanceOf[DBObject]
val collection: MongoCollection </span>= MongoClient(<span style="color: #800000;">"</span><span style="color: #800000;">10.4.120.83</span><span style="color: #800000;">"</span>)(<span style="color: #800000;">"</span><span style="color: #800000;">dbName</span><span style="color: #800000;">"</span>)(<span style="color: #800000;">"</span><span style="color: #800000;">collectionName</span><span style="color: #800000;">"</span><span style="color: #000000;">)
collection.insert(document)</span>

Java版本

<span style="color: #000000;">import org.bson.Document;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
</span><span style="color: #008000;">//</span><span style="color: #008000;"> 构造一个Json字符串</span>
String json = <span style="color: #800000;">"</span><span style="color: #800000;"> {</span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘school_code‘ : ‘111111‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘school_name‘ : ‘汉东政法大学‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘teacher_idcard‘ : ‘0000001‘, </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> ‘teacher_name‘ : ‘高育良‘ </span><span style="color: #800000;">"</span> +
                <span style="color: #800000;">"</span><span style="color: #800000;"> } </span><span style="color: #800000;">"</span><span style="color: #000000;">;
MongoClient mongoClient </span>= <span style="color: #0000ff;">new</span> MongoClient(<span style="color: #800000;">"</span><span style="color: #800000;">10.4.120.83</span><span style="color: #800000;">"</span>, <span style="color: #800080;">27017</span><span style="color: #000000;">);
MongoDatabase database </span>= mongoClient.getDatabase(<span style="color: #800000;">"</span><span style="color: #800000;">dbName</span><span style="color: #800000;">"</span><span style="color: #000000;">);
MongoCollection</span><Document> collection = database.getCollection(<span style="color: #800000;">"</span><span style="color: #800000;">collectionName</span><span style="color: #800000;">"</span><span style="color: #000000;">);  
Document document </span>=<span style="color: #000000;"> Document.parse(json);
collection.insertOne(document );</span>

MongoDB 将Json数据直接写入MongoDB的方法

标签：doc   teacher   行存储   com   cli   name   getc   隐式转换函数   client