mongodb初体验
package com.yt;import java.net.UnknownHostException;import java.util.ArrayList;import java.util.Iterator;import java.util.List;import javax.annotation.Resource;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.RequestMapping;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;import com.yt.man.Man;import com.yt.man.ManRepository;@Controller@RequestMapping("/test")public class TestController {@Resource(name = "manRepo")private ManRepository manRepo;/** * 删除 * @return * @throws UnknownHostException * @throws MongoException */@RequestMapping(value = "/delete")public String index() throws UnknownHostException, MongoException {DBCollection coll = setConnect("stdent");coll.drop();return "";}/** * 添加 * @return * @throws UnknownHostException * @throws MongoException */@RequestMapping(value = "/insert")public String insert() throws UnknownHostException, MongoException {DBCollection coll = setConnect("stdent");//List<Man> manlist = manRepo.getManlistBysql(500, 1);List<Man> manlist = manRepo.getGqById();List<DBObject> datas = new ArrayList<DBObject>();for (int i = 0; i < manlist.size(); i++) {Man man = manlist.get(i);BasicDBObject doc = new BasicDBObject();doc.put("id", man.getId());doc.put("name", man.getName());doc.put("addr", man.getAddr());datas.add(doc);}coll.insert(datas);return "";}/** * 查询 * @return * @throws UnknownHostException * @throws MongoException */@RequestMapping(value = "/select")public String select() throws UnknownHostException, MongoException {DBCollection coll = setConnect("stdent");//DBCursor cursor = coll.find().limit(10).skip(10); 分页查询DBCursor cursor = coll.find();System.out.println("数量： "+cursor.count());for(Iterator<DBObject> it = cursor.iterator();it.hasNext();){DBObject o = (DBObject) it.next();System.out.println(o.get("id")+""+o.get("name")+""+ o.get("addr"));}return "";}public DBCollection setConnect(String tableName) throws UnknownHostException, MongoException{Mongo m = new Mongo("192.168.8.65", 27017);DB db = m.getDB("memo");DBCollection coll = db.getCollection(tableName);return coll;}}
页:
[1]