兰cf| 北干初中| 厂商周| 中速骑| 达成集团| lol打野英雄排名| agogoktv| 蒙多视频| 肉用僵尸| 电影分镜头脚本范例| 什么游戏玩的人最多| 暗黑破坏神3黑蘑菇| lol鳄鱼视频| 北京自驾租车| 骨头镇操作| 100以内加减法口算| 石破天惊墨菲特| 报喜网| 残疾人无障碍设施| 午夜影院播放版| 火焰之地攻略| 6月5日是世界环境日| 勋章下载| 白宫记者协会晚宴| 澳门二手房| 比格团购| 怪物猎人开拓记| 昌吉电大| 大智慧官网下载| 铂雅苑| 陈海萱| 动燃火焰| 征途游戏下载| 超声波塑料熔接机| 多愁善感怎么办| 红草滩| dgame| 美女聊天视频| 沧州教育网| 风马音乐节| 奇缘网| 冰雪风暴| 宝鸡人才网最新招聘信息| 别墅效果图大全| 创意马克杯| 骑马与砍杀剑风传奇| 爱情公寓5全集| 宝宝生日策划| 网络游戏排行榜2015| 好玩的单击游戏| 保健食品批文转让| 万博娱乐正网| 365bet赌场| 必博| 捷报网足球分析| 大盛娱乐登录网站| 365bet在线官网| 万博体育下载| 金莎澳门官网手机版| hg0088如何开户| 365bet在线官网| 澳门365bet下载| 博牛注册| 新万博体育| 娱乐新天地| 优博平台| 365体育官网| 利来娱乐官网登录| 真人真钱网址赌博| 澳门新巴黎人娱乐网址| hg0088
基于mongodb的java之增删改查(CRUD)
flypeng 发布时间:03-12 来源:鹏鹏编程网 浏览:16次

1,下载驱动https://github.com/mongodb/mongo-java-driver/downloads,导入工程java中

2,建立测试代码

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;


public class TestMain {


 public static void main(String[] args) throws UnknownHostException, MongoException {
 // Mongo m = new Mongo();//默认本地
 // Mongo m = new Mongo("192.168.0.101");//默认端口 
  Mongo m = new Mongo("192.168.0.101",27017);
  //获取名为 alan 的数据库,不存在的情况下创建
  DB db = m.getDB("alan");
  
  //获取所有数据库,不显示无collection的db
  System.out.println("所有数据库名:"+m.getDatabaseNames());
  
  //获取名为 testCollection 的collection(相当于表),不存在的情况下创建
  DBCollection coll = db.getCollection("testCollection");
  
 
  //向collection中插入值 (可以插条 )
  BasicDBObject obj = new BasicDBObject();
  obj.put("name","jone");
  obj.put("sex", "male");
  BasicDBObject info = new BasicDBObject();
  info.put("height", 172);
  info.put("weight", 65);
  obj.put("other",info);
  coll.insert(obj);
  
  //获取数据库下所有的collection,不显示无数据的collection
  Set<String> colls = db.getCollectionNames();
  for(String s : colls){
   System.out.println(s);
  }
       //查询coll中全部记录 
   DBCursor ite = coll.find();  
   while(ite.hasNext()){
    System.out.println(ite.next());
   }
  //获取第一条记录
   DBObject o = coll.findOne();
         System.out.println(o);

        //统计colletion的数据条数
  System.out.println(coll.getCount());
  
        // 查询 name位 mark的对象 
         BasicDBObject query = new BasicDBObject();
         query.put("name", "mark");
         DBCursor it = coll.find(query);  
   while(it.hasNext()){
    System.out.println(it.next());
   }
         
  //查询height小于175,weight不等于65的对象 
   BasicDBObject query2 = new BasicDBObject();
      query2.put("other.height", new BasicDBObject("$lt", 175));
      query2.put("other.weight", new BasicDBObject("$ne",65));
      DBCursor it2 = coll.find(query2);  
      while(it2.hasNext()){
   System.out.println(it2.next());
  }


  //更新操作
      showData(coll);
      BasicDBObject old_obj = new BasicDBObject();
      old_obj.put("name", "mark");
      //这里的new_val对象一定要是find出的而不是new的,否则多字段的情况下就会丢失其它字段信息
      DBObject new_val = coll.findOne(old_obj);
      new_val.put("name", "zhoulong");
     /**这里只能修改一条满足条件的记录,而且根据API用updateMulti方法或者设置update第四个参数也无效,
      * 如果要批量跟新就要查询后,循环遍历更新了
      */
      coll.update(old_obj, new_val);
      showData(coll);
      
  
  //删除操作 
      showData(coll);
      BasicDBObject rmove = new BasicDBObject();
         rmove.put("name", "jone");  
         coll.remove(rmove);
      //coll.findAndRemove(rmove);//可以用findAndRemove删除 ,不过这个方法之能删除一条符合条件的记录 
      showData(coll);
      
     
      
      
 }

 //遍历数据
  static void showData(DBCollection col)  
   {  
      DBCursor ite = col.find();  
      while(ite.hasNext())  
      {  
             System.out.println(ite.next());  
        }  
    }  
}
3,参考api,http://api.mongodb.org.kthd9.com/java/2.5-pre-/index.html

 

4,用图形化的界面直观看看新建的库表和插入的数据

如果你有好的win10资讯或者win10教程,以及win10相关的问题想要获得win10系统下载的关注与报道。
欢迎加入发送邮件到657025171#qq.com(#替换为@)。期待你的好消息!
狗万官网 365体育电游 hg9393 365体育安卓 体育365下载
股票专家 北巴传媒股票 飞触 港币与人民币汇率 传奇汽车
海龙国际 海虹控股股票 光弘科技 赣能股份股票 滚塑
伟彦 海马汽车报价大全 壁合科技 八一钢铁 易方达增强回报b
余额宝收益时间 每股 澳洋顺昌 孚日股份股票 弹股
海南碧桂园 东南网架股票 大智慧股票软件官网 超频三股票 椰岛
水泥价格行情 赞球 宝宝树 股市博客 哈投股份股票
月月薪 招行主页 百大集团股票 农业金融 福日电子