MongoDB CRUD 增删改查
pom.xml依赖文件:
<dependency>
    <groupid>org.mongodb</groupid>
    <artifactid>mongo-java-driver</artifactid>
    <version>2.12.4</version>
</dependency>java源码:
package mongoDb;
import com.mongodb.MongoClient;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
/**
 * User: shellbye.com@gmail.com
 * Date: 2014/10/29
 */
public class MongoTest {
    public static void main(String[] args){
        // http://www.tutorialspoint.com/mongodb/mongodb_aggregation.htm
        // http://www.tutorialspoint.com/mongodb/mongodb_java.htm
        try{
            // To connect to mongodb server
            MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
            // Now connect to your databases
            DB db = mongoClient.getDB( "user" );
            DBCollection user = db.getCollection("user");
            // CRUD OF MONGO
//            create(user);
//            read(user);
//            update(user);
            delete(user);
        }catch(Exception e){
            System.err.println( e.getClass().getName() + ": " + e.getMessage() );
        }
    }
    public static void create(DBCollection collection){
        BasicDBObject doc = new BasicDBObject("name", "MongoDB").
                append("by", "shellbye");
        collection.insert(doc);
    }
    public static void delete(DBCollection collection){
        collection.remove(collection.findOne());
    }
    public static void update(DBCollection collection){
        BasicDBObject query = new BasicDBObject();
        query.put("name", "my_name");
        DBCursor cursor = collection.find(query);
        while(cursor.hasNext()){
            DBObject updateDocument = cursor.next();
            updateDocument.put("name","JACK");
            collection.save(updateDocument);
        }
    }
    public static void read(DBCollection collection){
        DBCursor cursor = collection.find();
        int i=1;
        while (cursor.hasNext()) {
            System.out.println("Inserted Document: "+i);
            System.out.println(cursor.next());
            i++;
        }
    }
}参考文档:
0.http://stackoverflow.com/questions/6840540/java-mongodb-query-by-date
1.http://www.tutorialspoint.com/mongodb/mongodb_java.htm
blog comments powered by Disqus