La copie de code est la suivante:
package mymaven;
import java.net.unknownhostException;
import java.util.set;
import com.mongodb.basicdbObject;
import com.mongodb.db;
import com.mongodb.dbcollection;
import com.mongodb.dbcursor;
import com.mongodb.dbObject;
import com.mongodb.mongo;
import com.mongodb.mongoexception;
Test de classe publique {
public static void Main (String [] args) lève unehostexception inconnue, MongoException {
Mongo Mongo = New Mongo ("172.27.9.104", 27017);
DB DB = Mongo.getDB ("MyTestDB");
Set <string> cols = db.getCollectionNames ();
// imprime la collection dans la base de données, ici elle devrait être nul
pour (String S: Cols) {
System.out.println (s);
}
Collection dbCollection = db.getCollection ("myTestColl");
collection.drop ();
BasicDbObject obj = new BasicDbObject ();
obj.put ("From", "blog.ihomer.net");
obj.put ("to", "forum.ithomer.net");
obj.put ("sujet", "ithomer.net");
Collection.insert (OBJ);
DbObject dbObj = collection.FindOne ();
System.out.println (DBOBJ);
// insérer 10 {classement: i} données
pour (int i = 0; i <10; i ++) {
collection.insert (new BasicDbObject (). APPEND ("Ranking", i));
}
System.out.println ("Count:" + Collection.getCount ());
Dbcursor Cursor = Collection.Find ();
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// Requête conditionnelle simple, enregistrements de requête avec classement de 1
BasicDBObject Query = new BasicDBObject ();
Query.put ("Ranking", 1);
Cursor = Collection.Find (Query);
System.out.println ("Collection Find ({/" Ranking / ": 1}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// Requête conditionnelle complexe, enregistrements de requête avec un classement supérieur ou égal à 5 et inférieur à 9
query = new BasicDbObject ();
query.put ("classement", new BasicDbObject ("$ gte", 5) .Apnd ("$ lt", 9));
Cursor = Collection.Find (Query);
System.out.println ("Collection Find ({/" Ranking / ": [5-9)}):");
while (cursor.hasnext ()) {
System.out.println (cursor.next ());
}
// Mongo.DropDatabase ("MyTestDB");
}
}
Résultats en cours:
La copie de code est la suivante:
mytestcoll
System.indexes
?
Compte: 11
?
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10108"}, "classement": 0}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10109"}, "classement": 1}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010a"}, "classement": 2}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010b"}, "classement": 3}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010c"}, "classement": 4}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010d"}, "classement": 5}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010e"}, "classement": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "classement": 7}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10110"}, "classement": 8}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10111"}, "classement": 9}
Collection Find ({"Ranking": 1}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10109"}, "classement": 1}
Collection Find ({"Ranking": [5-9)}):
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010d"}, "classement": 5}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010e"}, "classement": 6}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd1010f"}, "classement": 7}
{"_id": {"$ oid": "52c62ed8e4b0f4de3dd10110"}, "classement": 8}
Exemple de tableau MongoDB:
La copie de code est la suivante:
@SuppressWarnings ("non contrôlé")
public static void loadMediatags (list <Adiaentity> mediaentityList) {
MediaentityList.Clear ();
essayer {
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 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 ("mot-clé"); // mot-clé
ArrayList <Integer> CopyrightList = (ArrayList <Integer>) obj.get ("Copyright"); // Copyright
Mediaentity Mediaentity = New Mediaentity ();
mediaentity.setid (id);
// étiqueter
pour (int j = 0; j <taglist.size (); j ++) {
mediaentity.addtag (taglist.get (j));
int tagid = getTagint (taglist.get (j));
mediaentity.addtag (tagid);
}
// acteurs
ArrayList <DBObject> ActorSobjList = (ArrayList <DBObject>) Obj.get ("Actors"); // Actors
pour (int j = 0; j <acteursObjList.size (); j ++) {
Mediaentity.AddActor ((String) ActorSobjList.get (j) .get ("name"));
int actorid = getActorint ((string) acteursObjList.get (j) .get ("name"));
Mediaentity.adddactor (Actorid);
}
// directeur
ArrayList <DBObject> DirectorObjList = (ArrayList <DBObject>) Obj.get ("Director"); // Directeur
pour (int j = 0; j <meneureobjlist.size (); j ++) {
mediaentity.adddirector ((string) mene,AnterObjList.get (j) .get ("name"));
Int DirectorId = GetDirectorInt ((String) menetrageObjList.get (j) .get ("name"));
Mediaentity.Adddirector (DirectorId);
}
// mot-clé
pour (int j = 0; j <keywordList.size (); j ++) {
mediaentity.addkeyword (keywordlist.get (j));
int keywordId = getKeyWordInt (keywordList.get (j));
Mediaentity.AddKeyword (KeywordId);
}
// Copyright
pour (int j = 0; j <copyrightList.size (); j ++) {
Mediaentity.AddCopyRight (CopyrightList.get (J));
}
MediaentityList.add (Mediaentity);
index ++;
if (index> 100) {
casser;
}
System.out.println (index + "--- Mediaentity:" + mediaentity.toString ());
}
Long Costtime = System.CurrentTimemillis () - Starmtime;
System.out.println ("Charge Data CostTime =" + Index + "; CostTime =" + CostTime / 1000F);
} catch (exception e) {
e.printStackTrace ();
}
}
public static int getTagint (string tag) {
int tagintid = -1;
essayer {
Mongoclient Mongo = New Mongoclient (cosineCluster.gmongo_host, cosineCluster.gmongo_port);
Db db = Mongo.getdb (cosineCluster.gmongo_db);
DbCollection tagmapCollection = db.getCollection ("recommander_tag_map");
Dbcursor cursor = tagmapCollection.Find (new BasicDBObject ("name", tag));
if (cursor == null || cursor.toArray (). size () <= 0) {// mappage de processus de mappage de processus inférieurs à 2 ou n, le même ci-dessous
retour tagintid;
}
DbObject obj = cursor.toArray (). Get (0);
String name = tag;
tagintid = (entier) obj.get ("id");
int num = (entier) obj.get ("num");
Mongo.Close ();
} catch (inconnuhostException e) {
e.printStackTrace ();
}
retour tagintid;
}
public static int getActorint (acteur de chaîne) {
int acorintid = -1;
essayer {
Mongoclient Mongo = New Mongoclient (cosineCluster.gmongo_host, cosineCluster.gmongo_port);
Db db = Mongo.getdb (cosineCluster.gmongo_db);
DbCollection tagmapCollection = db.getCollection ("recommander_actor_map");
Dbcursor cursor = tagmapCollection.Find (new BasicDBObject ("name", acteur));
if (cursor == null || cursor.toArray (). size () <= 0) {
retour actorintid;
}
DbObject obj = cursor.toArray (). Get (0);
String name = acteur;
actoriNtid = (Integer) obj.get ("id");
int num = (entier) obj.get ("num");
Mongo.Close ();
} catch (inconnuhostException e) {
e.printStackTrace ();
}
retour actorintid;
}