From dac57dee5998fdc4777f6996e7cf6c4f286fffc7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=AA=E5=B1=B1=E9=A3=9E=E9=B9=84?= Date: Thu, 11 Sep 2014 01:40:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=86=92=E6=B3=A1=E6=8E=92=E5=BA=8F=E5=8F=8AMo?= =?UTF-8?q?ngodb=E7=A4=BA=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/net/aimeizi/tutorials/MaoPao.java | 22 +++++ .../java/net/aimeizi/tutorials/Mongodb.java | 98 +++++++++++++++++++ 2 files changed, 120 insertions(+) create mode 100644 aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/MaoPao.java create mode 100644 aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/Mongodb.java diff --git a/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/MaoPao.java b/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/MaoPao.java new file mode 100644 index 0000000..d1c4b48 --- /dev/null +++ b/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/MaoPao.java @@ -0,0 +1,22 @@ +package net.aimeizi.tutorials; + +import java.util.Arrays; + +public class MaoPao { + + public static void main(String args[]) { + int temp; + int[] s = { 23, 5, 12, 59, 78, 21, 100, 79, 66 ,200,365,420,862}; + for(int j=1;j<=s.length;j++){ + for(int i=0;is[i+1]){ + temp=s[i]; + s[i]=s[i+1]; + s[i+1]=temp; + } + } + } + System.out.println("最终顺序:-------------------"); + System.out.println(Arrays.toString(s)); + } +} \ No newline at end of file diff --git a/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/Mongodb.java b/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/Mongodb.java new file mode 100644 index 0000000..4a5b810 --- /dev/null +++ b/aimeizi-tutorials/src/main/java/net/aimeizi/tutorials/Mongodb.java @@ -0,0 +1,98 @@ +package net.aimeizi.tutorials; + + +public class Mongodb { + + private Mongo mongo; + private DBCollection dbCollection; + private DB db; + + public Mongodb() throws Exception{ + //使用ip地址创建Mongo对象 + mongo=new Mongo("127.0.0.1"); + //获取orcl数据库 + db=mongo.getDB("orcl"); + //判断是否存在集合person + boolean b=db.collectionExists("person"); + System.out.println("是否存在集合[person]:"+b); + dbCollection = db.getCollection("person"); + long count=dbCollection.count(); + System.out.println("总记录数是:"+count); + DBCursor cursor =dbCollection.find().skip(20).limit(20); + while(cursor.hasNext()){ + System.out.println(cursor.next()); + } + + + } + + + + public void list(){ + dbCollection=db.getCollection("person"); + BasicDBObject dbObject=new BasicDBObject(); + dbObject.put("age", new BasicDBObject("$gt",20).append("$lt", 60)); + DBCursor cursor = dbCollection.find(dbObject); + System.out.println(cursor.count()); + while(cursor.hasNext()){ + System.out.println(cursor.next()); + } + + } + + + + private boolean insert(){ + + dbCollection=db.getCollection("person"); + BasicDBObject dbObject=new BasicDBObject(); + dbObject.put("name", "zhangsan"); + dbObject.put("age", 20); + WriteResult writeResult = dbCollection.save(dbObject); + System.out.println(writeResult.getN()); + return false; + } + + private boolean delete(){ + dbCollection=db.getCollection("person"); + BasicDBObject dbObject=new BasicDBObject(); + dbObject.put("name", "zhangsan"); + WriteResult writeResult = dbCollection.remove(dbObject); + System.out.println(writeResult.getN()); + return false; + } + + + private boolean update(){ + dbCollection=db.getCollection("person"); + BasicDBObject dbObject=new BasicDBObject(); + dbObject.put("name", "s0020"); + BasicDBObject dbObject2=new BasicDBObject(); + dbObject2.put("name", "s0020"); + dbObject2.put("age", 65); + WriteResult writeResult = dbCollection.update(dbCollection.findOne(dbObject), dbObject2); + System.out.println(writeResult.getN()); + return false; + } + + + private Object getOne(){ + dbCollection=db.getCollection("person"); + BasicDBObject dbObject=new BasicDBObject(); + dbObject.put("name", "s0020"); + //dbObject.put("age", 65); + DBObject object=dbCollection.findOne(dbObject); + System.out.println(object.toMap().get("name")+"\t"+object.toMap().get("age")); + return object; + } + + + public static void main(String[] args) throws Exception{ + Mongodb mongodb=new Mongodb(); + //mongodb.insert(); + //mongodb.getOne(); + //mongodb.update(); + //mongodb.delete(); + //mongodb.list(); + } +}