نسخة الكود كما يلي:
حزمة 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 () ؛
}
إرجاع الممثل ؛
}