جافا عملية مونغودب مشاركة

نسخة الكود كما يلي:

حزمة mymaven.

استيراد java.net.unknownhostexception ؛

استيراد java.util.set ؛

استيراد com.mongodb.basicdbobject ؛

استيراد com.mongodb.db ؛

استيراد com.mongodb.dbcollection ؛

استيراد com.mongodb.dbcursor ؛

استيراد com.mongodb.dboBject ؛

استيراد com.mongodb.mongo ؛

استيراد com.mongodb.mongoException ؛

اختبار الفئة العامة {

الفراغ الثابت العام (سلسلة [] args) يلقي unknownhostexception ، mongoException {

Mongo Mongo = New Mongo ("172.27.9.104" ، 27017) ؛

db db = mongo.getdb ("mytestdb") ؛

تعيين <string> cols = db.getCollectionNames () ؛

// اطبع المجموعة في قاعدة البيانات ، هنا يجب أن تكون فارغة

لـ (String S: Cols) {

system.out.println (s) ؛

}

DBCollection Collection = db.getCollection ("MyTestColl") ؛

collection.drop () ؛

BasicDboBject OBJ = New BasicDbobject ()

obj.put ("من" ، "blog.ihomer.net") ؛

obj.put ("to" ، "forum.ithomer.net") ؛

obj.put ("الموضوع" ، "ithomer.net") ؛

Collection.insert (OBJ) ؛

DbObject DbObj = collection.findone () ؛

System.out.println (DBOBJ)

// إدراج 10 {الترتيب: I} البيانات

لـ (int i = 0 ؛ i <10 ؛ i ++) {

collection.insert (new BasicDbobject (). append ("الترتيب" ، i)) ؛

}

System.out.println ("العد:" + collection.getCount ()) ؛

DBCursor Cursor = collection.find () ؛

بينما (cursor.hasnext ()) {

system.out.println (cursor.next ()) ؛

}

// استعلام مشروط بسيط ، سجلات الاستعلام مع ترتيب 1

BasicDbObject Query = New BasicDbobject () ؛

Query.put ("الترتيب" ، 1) ؛

المؤشر = collection.find (query) ؛

System.out.println ("Collection Find ({/" retking/": 1}):") ؛

بينما (cursor.hasnext ()) {

system.out.println (cursor.next ()) ؛

}

// استعلام مشروط معقد ، سجلات الاستعلام مع ترتيب أكبر من أو يساوي 5 وأقل من 9

الاستعلام = جديد basicdbobject () ؛

Query.put ("الترتيب" ، New BasicDbobject ("$ gte" ، 5) .Append ("$ lt" ، 9)) ؛

المؤشر = collection.find (query) ؛

System.out.println ("Collection Find ({/" retking/": [5-9)}):") ؛

بينما (cursor.hasnext ()) {

system.out.println (cursor.next ()) ؛

}

// mongo.dropdatabase ("mytestdb") ؛

}

}

نتائج التشغيل:

نسخة الكود كما يلي:

mytestcoll

System.Indexes

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10107"} ، "من": "blog.ihomer.net" ، "إلى": "forum.ihomer.net" ، "الموضوع:" ihomer.net "}

العد: 11

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10107"} ، "من": "blog.ihomer.net" ، "إلى": "forum.ihomer.net" ، "الموضوع:" ihomer.net "}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10108"} ، "الترتيب": 0}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10109"} ، "الترتيب": 1}

{"_id": {"$ OID": "52C62ED8E4B0F4DE3DD1010A"} ، "الترتيب": 2}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010B"} ، "الترتيب": 3}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010C"} ، "الترتيب": 4}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010D"} ، "الترتيب": 5}

{"_id": {"$ OID": "52C62ED8E4B0F4DE3DD1010E"} ، "الترتيب": 6}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010F"} ، "الترتيب": 7}

{"_id": {"$ OID": "52C62ED8E4B0F4DE3DD110"} ، "الترتيب": 8}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1111"} ، "الترتيب": 9}

العثور على ({"الترتيب": 1}):

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10109"} ، "الترتيب": 1}

Collection Find ({"الترتيب": [5-9)}):

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010D"} ، "الترتيب": 5}

{"_id": {"$ OID": "52C62ED8E4B0F4DE3DD1010E"} ، "الترتيب": 6}

{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010F"} ، "الترتيب": 7}

{"_id": {"$ OID": "52C62ED8E4B0F4DE3DD110"} ، "الترتيب": 8}

مثال على صفيف mongodb:

نسخة الكود كما يلي:

suppressWarnings ("غير محدد")

ploodediatags الثابتة العامة (قائمة <MederAntity> MediaEntityList) {

MediaEntityList.clear () ؛

يحاول {

Mongo Mongo = new mongo (cosinecluster.gmongo_host ، cosinecluster.gmongo_port) ؛

db db = mongo.getdb (cosinecluster.gmongo_db) ؛

مجموعة dbCollection = db.getCollection (cosinecluster.gmongo_coll_media) ؛

dbCursor Cursor = collection.find () ؛

int index = 0 ؛

وقت بدء طويل = system.currentTimeMillis () ؛

بينما (cursor.hasnext ()) {

BasicDbObject obj = (basicdBobject) cursor.next () ؛

معرف طويل = obj.getlong ("_ id") ؛

ArrayList <string> tagList = (ArrayList <String>) obj.get ("TAG") ؛ // TAG

ArrayList <Tring> keywordlist = (ArrayList <String>) obj.get ("الكلمة الرئيسية") ؛ // الكلمة الرئيسية

ArrayList <integer> copyrightlist = (ArrayList <integer>) obj.get ("حقوق الطبع والنشر") ؛ // حقوق الطبع والنشر

Mediaentity Mediaentity = new MediaEntity () ؛

Mediaentity.setId (id) ؛

// العلامة

لـ (int j = 0 ؛ j <taglist.size () ؛ j ++) {

Mediaentity.Addtag ​​(tagList.get (j)) ؛

int tagid = getTagint (tagList.get (j)) ؛

Mediaentity.Addtag ​​(tagid) ؛

}

// الممثلين

ArrayList <DbObject> ActorsObjList = (ArrayList <DbObject>) obj.get ("الممثلون") ؛ // الممثلون

لـ (int j = 0 ؛ j <ActorsObjList.size () ؛ j ++) {

MediaEntity.AdDactor ((String) ActorsObjList.get (j) .get ("name")) ؛

int actorId = getActorInt ((string) ActorsObjList.get (j) .get ("name")) ؛

Mediaentity.Addactor (ActorId) ؛

}

// مخرج

ArrayList <DbObject> DirectionObjList = (ArrayList <DbObject>) obj.get ("Director") ؛ // Director

لـ (int j = 0 ؛ j <directionObjList.size () ؛ j ++) {

MediaEntity.AddIrector ((String) DirectionObjList.get (j) .get ("name")) ؛

int directionId = getDireCtorint ((String) DistractObjList.get (j) .get ("name")) ؛

Mediaentity.Addirector (DirectionId) ؛

}

// الكلمة الرئيسية

لـ (int j = 0 ؛ j <keywordlist.size () ؛ j ++) {

MediaEntity.AdDkeyword (Keywordlist.get (j)) ؛

int keywordid = getKeywordint (keywordlist.get (j)) ؛

MediaEntity.AdDkeyword (الكلمة الرئيسية) ؛

}

// حقوق الطبع والنشر

لـ (int j = 0 ؛ j <copyrightlist.size () ؛ j ++) {

Mediaentity.AddCopyRight (CopyrightList.get (j)) ؛

}

MediaEntityList.add (Mediaentity) ؛

فهرس ++ ؛

if (index> 100) {

استراحة؛

}

System.out.println (index + "--- MediaEntity:" + mediaentity.toString ()) ؛

}

طويل التكلفة = system.currentTimeMillis () - وقت البدء ؛

system.out.println ("تحميل بيانات البيانات =" + index + "؛ costtime =" + costtime/1000f) ؛

} catch (استثناء e) {

E.PrintStackTrace () ؛

}

}

static int getTagint (علامة السلسلة) {

int tagintid = -1 ؛

يحاول {

mongoclient mongo = جديد mongoclient (cosinecluster.gmongo_host ، cosinecluster.gmongo_port) ؛

db db = mongo.getdb (cosinecluster.gmongo_db) ؛

dbCollection tagMapCollection = db.getCollection ("التوصية_tag_map") ؛

dbCursor Cursor = tagMapCollection.find (New BasicDbobject ("name" ، tag)) ؛

if (cursor == null || cursor.toarray (). size () <= 0) {// قم بتخطيط الكلمات الرئيسية أقل من 2 أو n ، نفس الشيء أدناه

إرجاع tagintid.

}

dbObject obj = cursor.toarray (). get (0) ؛

اسم السلسلة = علامة ؛

tagintid = (integer) obj.get ("id") ؛

int num = (integer) obj.get ("num") ؛

mongo.close () ؛

} catch (unknownhostexception e) {

E.PrintStackTrace () ؛

}

إرجاع tagintid.

}

int static int getActorInt (string actor) {

int ActorIntId = -1 ؛

يحاول {

mongoclient mongo = جديد mongoclient (cosinecluster.gmongo_host ، cosinecluster.gmongo_port) ؛

db db = mongo.getdb (cosinecluster.gmongo_db) ؛

dbCollection tagMapCollection = db.getCollection ("التوصية_ agaCt_MAP") ؛

dbCursor Cursor = tagMapCollection.find (New BasicDbobject ("name" ، Actor)) ؛

if (cursor == null || cursor.toarray (). size () <= 0) {

إرجاع الممثل ؛

}

dbObject obj = cursor.toarray (). get (0) ؛

اسم السلسلة = ممثل ؛

ActorIntId = (integer) obj.get ("id") ؛

int num = (integer) obj.get ("num") ؛

mongo.close () ؛

} catch (unknownhostexception e) {

E.PrintStackTrace () ؛

}

إرجاع الممثل ؛

}