การคัดลอกรหัสมีดังนี้:
แพ็คเกจ 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;
การทดสอบระดับสาธารณะ {
โมฆะคงที่สาธารณะหลัก (String [] args) พ่นไม่รู้จัก Hostexception, 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 = db.getCollection ("MyTestColl");
collection.drop ();
BasicDbObject OBJ = ใหม่ BASICDBOBJECT ();
obj.put ("จาก", "blog.ihomer.net");
obj.put ("ถึง", "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 (ใหม่ BASICDBOBJECT (). ผนวก ("การจัดอันดับ", i));
-
System.out.println ("Count:" + Collection.getCount ());
DBCursor Cursor = Collection.Find ();
ในขณะที่ (cursor.hasnext ()) {
System.out.println (cursor.next ());
-
// แบบสอบถามแบบมีเงื่อนไขแบบง่ายบันทึกการสืบค้นด้วยการจัดอันดับ 1
basicDbObject query = new BasicDbObject ();
query.put ("การจัดอันดับ", 1);
Cursor = Collection.Find (Query);
System.out.println ("ค้นหาคอลเลกชัน ({/" การจัดอันดับ/": 1}):");
ในขณะที่ (cursor.hasnext ()) {
System.out.println (cursor.next ());
-
// แบบสอบถามแบบมีเงื่อนไขที่ซับซ้อนบันทึกการสืบค้นที่มีการจัดอันดับมากกว่าหรือเท่ากับ 5 และน้อยกว่า 9
แบบสอบถาม = ใหม่ basicDbObject ();
query.put ("การจัดอันดับ", ใหม่ BASICDBOBJECT ("$ GTE", 5) .Append ("$ lt", 9));
Cursor = Collection.Find (Query);
System.out.println ("ค้นหาคอลเลกชัน ({/" การจัดอันดับ/": [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": "52c62ed8e4b0f4de3dd10110"}, "การจัดอันดับ": 8}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10111"}, "การจัดอันดับ": 9}
ค้นหาคอลเลกชัน ({"การจัดอันดับ": 1}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10109"}, "การจัดอันดับ": 1}
ค้นหาคอลเลกชัน ({"การจัดอันดับ": [5-9)}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010d"}, "การจัดอันดับ": 5}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010e"}, "การจัดอันดับ": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "การจัดอันดับ": 7}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10110"}, "การจัดอันดับ": 8}
ตัวอย่างของ MongoDB Array:
การคัดลอกรหัสมีดังนี้:
@suppresswarnings ("ไม่ได้ตรวจสอบ")
Public Static Void LoadMedMediatags (รายการ <SedicoEntity> 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 = 0;
Long StartTime = System.currentTimeMillis ();
ในขณะที่ (cursor.hasnext ()) {
BasicDbObject OBJ = (BasicDbObject) Cursor.next ();
Long id = obj.getLong ("_ id");
arrayList <String> tagList = (arrayList <String>) obj.get ("tag"); // tag
arrayList <String> keywordList = (arrayList <String>) obj.get ("คำหลัก"); // คีย์เวิร์ด
ArrayList <Integer> CopyrightList = (ArrayList <Integer>) obj.get ("ลิขสิทธิ์"); // ลิขสิทธิ์
MediaTe MediaTity = 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 ("ชื่อ"));
int actorid = getActorInt ((String) ActorSobjlist.get (j) .get ("ชื่อ"));
MediaEntity.Addactor (Actorid);
-
// ผู้อำนวยการ
ArrayList <DbObject> DirectorObJlist = (ArrayList <DbObject>) obj.get ("ผู้อำนวยการ"); // ผู้อำนวยการ
สำหรับ (int j = 0; j <directorobjlist.size (); j ++) {
MediaEntity.adddidirector ((String) DirectorObjlist.get (j) .get ("ชื่อ"));
int directorid = getDirectorInt ((String) DirectorObjlist.get (j) .get ("ชื่อ"));
MEDIANTITY.ADDDIRECTOR (DirectorID);
-
// คำหลัก
สำหรับ (int j = 0; j <keywordList.size (); j ++) {
MediaEntity.addkeyword (keywordList.get (j));
int keywordid = getKeywordInt (keywordList.get (j));
MediaEntity.addkeyword (KeywordId);
-
// ลิขสิทธิ์
สำหรับ (int j = 0; j <copyrightlist.size (); j ++) {
MediaEntity.addcopyright (CopyrightList.get (J));
-
MediaEntityList.add (MEDIEENTITY);
ดัชนี ++;
ถ้า (ดัชนี> 100) {
หยุดพัก;
-
System.out.println (INDEX + "--- MEDIEENTITY:" + MEDIANTITY.TOSTRING ());
-
Long Costtime = System.currentTimeMillis () - starttime;
System.out.println ("โหลดข้อมูลค่าใช้จ่าย =" + ดัชนี + "; costtime =" + ค่าใช้จ่าย/1000f);
} catch (Exception e) {
E.PrintStackTrace ();
-
-
public 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 (ใหม่ BASICDBOBJECT ("ชื่อ", แท็ก));
if (cursor == null || cursor.toarray (). size () <= 0) {// กระบวนการแมปการแมปคำหลักน้อยกว่า 2 หรือ n
คืนแท็ก
-
dbobject obj = cursor.toarray (). รับ (0);
ชื่อสตริง = แท็ก;
tagintid = (จำนวนเต็ม) obj.get ("id");
int num = (จำนวนเต็ม) obj.get ("num");
Mongo.close ();
} catch (unknownhostexception e) {
E.PrintStackTrace ();
-
คืนแท็ก
-
public Static int getActorint (นักแสดงสตริง) {
int actorintid = -1;
พยายาม {
Mongoclient Mongo = ใหม่ mongoclient (cosinecluster.gmongo_host, cosinecluster.gmongo_port);
db db = mongo.getdb (cosinecluster.gmongo_db);
dbcollection tagmapcollection = db.getCollection ("แนะนำ _actor_map");
DBCursor Cursor = TagMapCollection.Find (ใหม่ BASICDBOBJECT ("ชื่อ", นักแสดง));
if (cursor == null || cursor.toarray (). size () <= 0) {
return Actorintid;
-
dbobject obj = cursor.toarray (). รับ (0);
ชื่อสตริง = นักแสดง;
Actorintid = (จำนวนเต็ม) obj.get ("id");
int num = (จำนวนเต็ม) obj.get ("num");
Mongo.close ();
} catch (unknownhostexception e) {
E.PrintStackTrace ();
-
return Actorintid;
-