Salinan kode adalah sebagai berikut:
paket mymaven;
impor java.net.unknownhostException;
impor java.util.set;
impor com.mongodb.basicdbObject;
impor com.mongodb.db;
impor com.mongodb.dbcollection;
impor com.mongodb.dbcursor;
impor com.mongodb.dbObject;
impor com.mongodb.mongo;
impor com.mongodb.mongoException;
tes kelas publik {
public static void main (string [] args) melempar UnknownHostException, MongoException {
Mongo mongo = mongo baru ("172.27.9.104", 27017);
Db db = mongo.getdb ("mytestdb");
Set <string> cols = db.getCollectionNames ();
// Cetak koleksi dalam database, di sini harus nol
untuk (string s: cols) {
System.out.println (s);
}
Dbcollection collection = db.getCollection ("mytestcoll");
collection.drop ();
BASICDBObject Obj = BASICDBObject () baru;
obj.put ("from", "blog.ihomer.net");
obj.put ("to", "forum.ithomer.net");
obj.put ("subjek", "ithomer.net");
collection.insert (OBJ); // Masukkan objek
Dbobject dbobj = collection.findone ();
System.out.println (DBOBJ); // Cetak data yang baru saja Anda masukkan
// masukkan 10 {peringkat: i} data
untuk (int i = 0; i <10; i ++) {
collection.insert (new BasicDbObject (). append ("Ranking", i));
}
System.out.println ("Count:" + Collection.getCount ());
Dbcursor kursor = collection.find (); // Lalu kami menggunakan kursor ini untuk mengulangi koleksi
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// kueri bersyarat sederhana, catatan kueri dengan peringkat 1
Query basicdbObject = basicdbobject () baru;
query.put ("peringkat", 1);
kursor = collection.find (kueri);
System.out.println ("Collection Find ({/" Ranking/": 1}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// kueri bersyarat yang kompleks, catatan kueri dengan peringkat lebih besar dari atau sama dengan 5 dan kurang dari 9
query = new BasicDbObject ();
query.put ("peringkat", new BasicDbObject ("$ gte", 5) .Perampingkan ("$ lt", 9));
kursor = collection.find (kueri);
System.out.println ("Collection Find ({/" Ranking/": [5-9)}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// mongo.dropdatabase ("mytestdb");
}
}
Hasil Menjalankan:
Salinan kode adalah sebagai berikut:
mytestcoll
System.indexes
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10107"}, "dari": "blog.ihomer.net", "to": "forum.ihomer.net", "subjek": "ihomer.net"}
Hitungan: 11
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10107"}, "dari": "blog.ihomer.net", "to": "forum.ihomer.net", "subjek": "ihomer.net"}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10108"}, "peringkat": 0}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10109"}, "peringkat": 1}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010a"}, "peringkat": 2}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010b"}, "peringkat": 3}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010c"}, "peringkat": 4}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010d"}, "peringkat": 5}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010e"}, "peringkat": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "peringkat": 7}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10110"}, "peringkat": 8}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10111"}, "peringkat": 9}
Collection Find ({"Peringkat": 1}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10109"}, "peringkat": 1}
Collection Find ({"Peringkat": [5-9)}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010d"}, "peringkat": 5}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010e"}, "peringkat": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "peringkat": 7}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10110"}, "peringkat": 8}
Contoh array MongoDB:
Salinan kode adalah sebagai berikut:
@SuppressWarnings ("Uncecked")
public static void loadmediatags (daftar <mediaEntity> MediaEntityList) {
mediaEntityList.clear ();
mencoba {
Mongo mongo = mongo baru (cosineCluster.gmongo_host, cosineCluster.gmongo_port);
Db db = mongo.getdb (cosineCluster.gmongo_db);
Dbcollection collection = db.getCollection (cosineCluster.gmongo_coll_media);
Dbcursor kursor = collection.find ();
INT INDEX = 0;
Long StartTime = System.CurrentTimeMillis ();
while (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 ("Kata kunci"); // kata kunci
ArrayList <Integer> CopyrightList = (ArrayList <Integer>) obj.get ("Hak Cipta"); // Hak Cipta
MediaEntity mediaEntity = new MediaEntity ();
mediaEntity.setid (id);
// Tag
untuk (int j = 0; j <taglist.size (); j ++) {
mediaEntity.addtag (taglist.get (j));
int tagId = gettagint (taglist.get (j));
mediaEntity.Addtag (TAGID);
}
// aktor
ArrayList <DBObject> ActorsObjList = (ArrayList <DBObject>) obj.get ("Actors"); // Aktor
untuk (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);
}
// Direktur
ArrayList <DBObject> DirectorObjList = (ArrayList <DBObject>) obj.get ("Director"); // Direktur
untuk (int j = 0; j <directorobjlist.size (); j ++) {
mediaEntity.adddirector ((string) directorobjlist.get (j) .get ("name"));
int directorId = getDirectorInt ((string) directorobjlist.get (j) .get ("name"));
mediaEntity.adddirector (DirectorID);
}
// kata kunci
untuk (int j = 0; j <kunciwordlist.size (); j ++) {
mediaEntity.AddKeyWord (KeyWordList.get (j));
Int KeyWordId = GetKeyWordInt (KeyWordList.get (j));
mediaEntity.AddKeyWord (KeyWordID);
}
// hak cipta
untuk (int j = 0; j <copyrightlist.size (); j ++) {
mediaEntity.AddCopyright (CopyrightList.get (j));
}
mediaEntityList.Add (mediaEntity);
indeks ++;
if (index> 100) {
merusak;
}
System.out.println (index + "--- mediaEntity:" + MediaStity.ToString ());
}
Long Costtime = System.CurrentTimeMillis () - StartTime;
System.out.println ("Muat Data Costtime =" + Index + "; Costtime =" + Costtime/1000F);
} catch (Exception e) {
e.printstacktrace ();
}
}
public static int getTagint (tag string) {
int tagIntid = -1;
mencoba {
Mongoclient mongo = mongoclient baru (cosineCluster.gmongo_host, cosineCluster.gmongo_port);
Db db = mongo.getdb (cosineCluster.gmongo_db);
Dbcollection tagMapCollection = db.getCollection ("REKOMENTAS_TAG_MAP");
Kursor dbcursor = tagmapcollection.find (new BasicDbObject ("name", tag));
if (kursor == null || kursor.toArray (). size () <= 0) {// Proses Mapping Keywords Kurang dari 2 atau N, sama di bawah ini
mengembalikan tagintid;
}
Dbobject obj = kursor.toArray (). Get (0);
Name string = tag;
tagIntid = (integer) obj.get ("id");
int num = (integer) obj.get ("num");
mongo.close ();
} catch (unknownHostException e) {
e.printstacktrace ();
}
mengembalikan tagintid;
}
public static int getActorint (string aktor) {
int actorIntid = -1;
mencoba {
Mongoclient mongo = mongoclient baru (cosineCluster.gmongo_host, cosineCluster.gmongo_port);
Db db = mongo.getdb (cosineCluster.gmongo_db);
Dbcollection tagMapCollection = db.getCollection ("REKOMENTAS_ACTOR_MAP");
Kursor dbcursor = tagmapcollection.find (new BasicDbObject ("name", aktor));
if (kursor == null || kursor.toArray (). size () <= 0) {
mengembalikan aktorintid;
}
Dbobject obj = kursor.toArray (). Get (0);
Name string = aktor;
ActorIntid = (integer) obj.get ("id");
int num = (integer) obj.get ("num");
mongo.close ();
} catch (unknownHostException e) {
e.printstacktrace ();
}
mengembalikan aktorintid;
}