Die Codekopie lautet wie folgt:
Paket mymaven;
Importieren Sie java.net.unnownhostException;
Java.util.set importieren;
import com.mongodb.basicdbObject;
import com.mongodb.db;
import com.mongodb.dbcollection;
import com.mongodb.dbcursor;
import com.mongodb.dbobject;
import com.mongodb.mongo;
com.mongoDB.MongoException;
öffentliche Klassen -Test {
public static void main (String [] args) löst UnbekannthostException, MongoException {
Mongo Mongo = New Mongo ("172.27.9.104", 27017);
Db db = mongo.getDB ("myTestDB");
Set <string> cols = db.getCollectionNames ();
// Drucken Sie die Sammlung in der Datenbank aus, hier sollte sie null sein
für (String S: cols) {
System.out.println (s);
}
Dbcollection collection = db.getCollection ("myTestColl");
Sammlung.Drop ();
BasicDBObject obj = new BasicDBObject ();
obj.put ("from", "blog.ihomer.net");
obj.put ("to", "Forum.ithomer.net");
obj.put ("Subjekt", "ithomer.net");
Sammlung.insert (OBJ);
DBObject DBOBJ = Collection.Findone ();
System.out.println (DBOBJ);
// 10 {Ranking: i} Daten einfügen
für (int i = 0; i <10; i ++) {
Collection.insert (New BasicDBObject (). Append ("Ranking", i));
}
System.out.println ("count:" + collection.getCount ());
DBCUror Cursor = Collection.find ();
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// Einfache bedingte Abfrage, Abfragen von Aufzeichnungen mit 1 Ranking von 1
BasicDBObject query = new BasicDBObject ();
query.put ("Ranking", 1);
cursor = collection.find (query);
System.out.println ("Sammlung find ({/" Ranking/": 1}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// Komplexe bedingte Abfrage, Abfragenaufzeichnungen mit Ranking größer oder gleich 5 und weniger als 9
query = new BasicDBObject ();
query.put ("ranking", new BasicDBObject ("$ gte", 5) .Append ("$ lt", 9));
cursor = collection.find (query);
System.out.println ("Sammlung find ({/" ranking/": [5-9)}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// mongo.dropdatabase ("myTestDB");
}
}
Auslaufergebnisse:
Die Codekopie lautet wie folgt:
MyTestColl
System.Indexes
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10107"}, "aus": "blog.ihomer.net", ":" Forum.ihomer.net "," Subjekt ":" Ihomer.net "}}
Graf: 11
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10107"}, "aus": "blog.ihomer.net", ":" Forum.ihomer.net "," Subjekt ":" Ihomer.net "}}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10108"}, "Ranking": 0}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10109"}, "Ranking": 1}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010A"}, "Ranking": 2}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010B"}, "Ranking": 3}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010c"}, "Ranking": 4}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010D"}, "Ranking": 5}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010E"}, "Ranking": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "Ranking": 7}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10110"}, "Ranking": 8}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10111"}, "Ranking": 9}
Sammlung Find ({"Ranking": 1}):
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10109"}, "Ranking": 1}
Sammlung Find ({"Ranking": [5-9)}):
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010D"}, "Ranking": 5}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD1010E"}, "Ranking": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "Ranking": 7}
{"_id": {"$ oid": "52C62ED8E4B0F4DE3DD10110"}, "Ranking": 8}
Beispiel eines MongoDB -Arrays:
Die Codekopie lautet wie folgt:
@Suppresswarnings ("Unbekämpft")
public static void loadmediatags (Liste <MedienEntity> MediaEntityList) {
MediaEntityList.Clear ();
versuchen {
Mongo mongo = new mongo (coSinecluster.gmongo_host, cosinecluster.gmongo_port);
Db db = mongo.getDB (coSineCluster.gmongo_db);
Dbcollection collection = db.getCollection (coSinecluster.gmongo_coll_media);
DbCursor cursor = collection.find ();
int index = 0;
Long start time = 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 ("keyword"); // Schlüsselwort
ArrayList <Neger> CopyrightList = (ArrayList <Gearner>) obj.get ("Copyright"); // Copyright
MediaEntity MediaEntity = new MediaEntity ();
MediaEntity.SetId (ID);
// Etikett
für (int j = 0; j <taglist.size (); j ++) {
MediaEntity.addtag (TagList.get (j));
int tagid = getagint (taglist.get (j));
MediaEntity.AddTag (Tagid);
}
// Schauspieler
ArrayList <DBObject> actorsObjList = (ArrayList <DBObject>) obj.get ("Schauspieler"); // Schauspieler
für (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);
}
// Direktor
ArrayList <DBObject> DirectorObjList = (ArrayList <DBObject>) obj.get ("Director"); // Director
für (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);
}
// Schlüsselwort
für (int j = 0; j <keywordlist.size (); j ++) {
MediaEntity.AddKeyword (keywordlist.get (j));
int keywordid = getKeywordint (keywordlist.get (j));
MediaEntity.AddKeyword (KeywordID);
}
// Copyright
für (int j = 0; j <Copyrightlist.size (); j ++) {
MediaEntity.Addcopyright (CopyrightList.get (j));
}
MediaEntityList.add (MediaEntity);
Index ++;
if (index> 100) {
brechen;
}
System.out.println (Index + "--- MediaEntity:" + MediaEntity.toString ());
}
Langkostenzeit = System.CurrentTimemillis () - Starttime;
System.out.println ("Datenlastdaten costTime =" + index + "; costTime =" + costime/1000f);
} catch (Ausnahme e) {
E. printstacktrace ();
}
}
public static int gettAgint (String -Tag) {
int tagintid = -1;
versuchen {
Mongoclient mongo = new mongoclient (cosinecluster.gmongo_host, cosinecluster.gmongo_port);
Db db = mongo.getDB (coSineCluster.gmongo_db);
Dbcollection tagmapcollection = db.getCollection ("empfehlen_tag_map");
DbCursor cursor = tagmapcollection.find (new BasicDBObject ("Name", Tag));
if (cursor == NULL ||
return tagintid;
}
DBObject obj = cursor.toArray (). Get (0);
String name = Tag;
TagIntid = (Integer) obj.get ("id");
int num = (Integer) obj.get ("num");
mongo.close ();
} catch (unbekannteHostException e) {
E. printstacktrace ();
}
return tagintid;
}
public static int getActorint (String -Schauspieler) {
int actorintid = -1;
versuchen {
Mongoclient mongo = new mongoclient (cosinecluster.gmongo_host, cosinecluster.gmongo_port);
Db db = mongo.getDB (coSineCluster.gmongo_db);
Dbcollection tagmapcollection = db.getCollection ("empfehlen_actor_map");
DbCursor cursor = tagmapcollection.find (new BasicDBObject ("Name", Schauspieler));
if (cursor == null || cursor.toArray (). size () <= 0) {
Rückkehr Schauspieler;
}
DBObject obj = cursor.toArray (). Get (0);
String name = Schauspieler;
Actorintid = (Integer) obj.get ("id");
int num = (Integer) obj.get ("num");
mongo.close ();
} catch (unbekannteHostException e) {
E. printstacktrace ();
}
Rückkehr Schauspieler;
}