`
stationxp
  • 浏览: 17386 次
社区版块
存档分类
最新评论

【MongoDB】1、MongoDB for Java

 
阅读更多

入门

安装

http://www.cnblogs.com/lipan/archive/2011/03/08/1966463.html

http://docs.mongodb.org/manual/tutorial/install-mongodb-on-windows/

开发

下载驱动:

http://central.maven.org/maven2/org/mongodb/mongo-java-driver/

GetStart

http://docs.mongodb.org/ecosystem/tutorial/getting-started-with-java-driver/

http://api.mongodb.org/java/current/

http://blog.163.com/wm_at163/blog/static/132173490201110254257510/

http://www.cnblogs.com/hoojo/archive/2011/06/02/2068665.html

http://hi.baidu.com/cesul/item/99be4f31dc75a9f7a9842872

入门已经完成。

代码:

package cn.liuhailong.mongostudy;
import com.mongodb.MongoClient;
import com.mongodb.MongoClient;
import com.mongodb.MongoException;
import com.mongodb.WriteConcern;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
import com.mongodb.DBCursor;
import com.mongodb.ServerAddress;
import java.util.Set;
import java.util.List;

class ConnectionAndSayHi {
	public static void main(String[] args){
		try{
			MongoClient mongoClient = new MongoClient( "localhost" , 27017 );
			for (String s : mongoClient.getDatabaseNames()) {
			   System.out.println(s);
			}
			System.out.println();
			
			
			DB db = mongoClient.getDB("test");
			
			
			DBCollection coll = db.getCollection("testCollection");
			//coll.createIndex(new BasicDBObject("name",1));
			
			/*
			BasicDBObject doc = new BasicDBObject("name", "MongoDB").
                              append("type", "database").
                              append("count", 1).
                              append("info", new BasicDBObject("x", 203).append("y", 102));

			coll.insert(doc);
			*/
			
			Set<String> collectionNames = db.getCollectionNames();

			for (String collectionName : collectionNames) {
				DBCollection collection = db.getCollectionFromString(collectionName);
			    System.out.println(collection.getDB() + "  "
			    	+ collection.getFullName() + "  "+ collection.getCount());
			    	
			   /* 	
			    DBObject myDoc = collection.findOne();
				System.out.println(myDoc);				
				*/
				DBCursor cursor = collection.find();
				try {
				   while(cursor.hasNext()) {
				       System.out.println(cursor.next());
				   }
				} finally {
				   cursor.close();
				}
				
				System.out.println();
				
				/*
				BasicDBObject query = new BasicDBObject("name", "Mongodb");

				cursor = collection.find(query);
				
				try {
				   while(cursor.hasNext()) {
				       System.out.println(cursor.next());
				   }
				} finally {
				   cursor.close();
				}
				
				
				System.out.println();
				*/
				List<DBObject> list = collection.getIndexInfo();

				for (DBObject o : list) {
				   System.out.println(o);
				}
				
				System.out.println();
			}
			
		}catch(Exception e){
			
		}
	}	
}


运行效果:




下一步:

积累

把官网配置相关文档看一遍。

把官网Java API通读一遍。
做一个简单的微博程序试试。

进阶

搭一个大集群,做压测。

找找成功案例。

分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics