java 什么使用mongodb

先下载好驱动

import javanetUnknownHostException;

import commongodbBasicDBObject;

import commongodbDB;

import commongodbDBCollection;

import commongodbDBCursor;

import commongodbMongo;

import commongodbMongoException;

/

 Java + MongoDB Hello world Example

/

public class MongoDBFirstApp {

    public static void main(String[] args)throws UnknownHostException, MongoException{

        //实例化Mongo对象，连接27017端口

        Mongo mongo = new Mongo("localhost", 27017);

                           //连接名为yourdb的数据库，假如数据库不存在的话，mongodb会自动建立

        DB db = mongogetDB("yourdb");// Get collection from MongoDB, database named "yourDB"

        

        //从Mongodb中获得名为yourColleection的数据集合，如果该数据集合不存在，Mongodb会为其新建立

        DBCollection collection = dbgetCollection("yourCollection");

        

        // 使用BasicDBObject对象创建一个mongodb的document,并给予赋值。

        BasicDBObject document = new BasicDBObject();

        documentput("id", 1001);

        documentput("msg", "hello world mongoDB in Java");

        //将新建立的document保存到collection中去

        collectioninsert(document);

        // 创建要查询的document

        BasicDBObject searchQuery = new BasicDBObject();

        searchQueryput("id", 1001);

        // 使用collection的find方法查找document

        DBCursor cursor = collectionfind(searchQuery);

        //循环输出结果

        while (cursorhasNext()) {

            Systemoutprintln(cursornext());

        }

        Systemoutprintln("Done");

    }

}

package mavendemotest;

import javautilArrayList;

import javautilList;

import commongodbBasicDBObject;

import commongodbDB;

import commongodbDBCollection;

import commongodbDBObject;

import commongodbMongo;

import commongodbQueryOperators;

public class MongoDB {

private static void print(String str){

Systemoutprintln(str);

}

public static void main(String[] args) {

try {

//创建连接

Mongo m=new Mongo("127001", 27017);

//得到数据库

DB db=mgetDB("test");

//得到所有数据库

// List<String> colls=mgetDatabaseNames();

// for(String str:colls){

// Systemoutprintln(str);

// }

// //得到所有的集合（表）

// for(String collection:dbgetCollectionNames()){

// Systemoutprintln(collection);

// }

//删除一个数据库

//mdropDatabase("sun");

//得到sun表

DBCollection coll=dbgetCollection("things");

//查看一个表的索引

// for(DBObject index:collgetIndexInfo()){

// Systemoutprintln(index);

// }

// DBObject myDoc=collfindOne();

// Systemoutprintln(myDoc);

//添加

// BasicDBObject doc=new BasicDBObject();

// docput("name", "sunshan");

// docput("sex", "男");

// docput("age", 22);

//collinsert(doc);

//删除

//collremove(doc);

// BasicDBObject doc1=new BasicDBObject();

// doc1put("i", 0);

// doc1put("j", "foo");

// BasicDBObject doc2=new BasicDBObject();

// doc2put("hello", "world");

// doc1put("doc2", doc2);

// collinsert(doc1);

//修改

// BasicDBObject doc3=new BasicDBObject();

// doc3put("x", 6);

// BasicDBObject doc4=new BasicDBObject();

// doc4put("x", 1);

// collupdate(doc3, doc4,true,false);

//如果数据库不存在就添加 |多条修改 false只修改第一天，true如果有多条就不修改

//条件查询

//Systemoutprintln(collfind(doc4));

//collfindAndRemove(doc4);

// //批量插入

// List<DBObject> datas=new ArrayList<DBObject>();

// for(int i=0;i<10;i++){

// BasicDBObject bd=new BasicDBObject();

// bdput("name", "data");

// bdappend("age", i);

// datasadd(bd);

// }

// collinsert(datas);

//添加

// BasicDBObjectBuilder documentBuilder = BasicDBObjectBuilderstart();

// documentBuilderadd("database", "mkyongDB");

// documentBuilderadd("table", "hosting");

// BasicDBObjectBuilder documentBuilderDetail = BasicDBObjectBuilderstart();

// documentBuilderDetailadd("records", "99");

// documentBuilderDetailadd("index", "vps_index1");

// documentBuilderDetailadd("active", "true");

// documentBuilderadd("detail", documentBuilderDetailget());

// collinsert(documentBuilderget());

//添加

// Map<Object,Object> map=new HashMap<Object,Object>();

// mapput("a", 1);

// mapput("b", "b");

// collinsert(new BasicDBObject(map));

//添加

// String json ="{'1' : '1','2' : '2',"+"'11' : {'1' : 1, '2' : '2', '3' : '3'}}";

// DBObject dbobject=(DBObject)JSONparse(json);

// collinsert(dbobject);

//更新

// BasicDBObject bdo=new BasicDBObject();

// bdoput("x", 11);

// collupdate(new BasicDBObject()append("x", 0), bdo);

//更新

// BasicDBObject bdo=new BasicDBObject()append("$inc", new BasicDBObject()append("x", 12));

// collupdate(new BasicDBObject()append("x", 11), bdo);

//更新

//如果不使用$set 直接是 age则所有的都会更新

//根据age为9条件把name：data修改为 name：sun

// BasicDBObject bdo=new BasicDBObject()append("$set", new BasicDBObject()append("name", "sunshan"));

// collupdate(new BasicDBObject()append("age", 9), bdo);

//更新

//根据name为data条件把age：批量修改为 age:age

// BasicDBObject bdo=new BasicDBObject()append("$set", new BasicDBObject()append("age", "age"));

// collupdate(new BasicDBObject()append("name", "data"), bdo,false, true);

//查询age=1

// print("find："+collfind(new BasicDBObject("age", 1))toArray());

//查询age<=1

// print("find: "+collfind(new BasicDBObject("age", new BasicDBObject("$lte", 1)))toArray());

//查询age>=1

// print("fint: "+collfind(new BasicDBObject("age", new BasicDBObject("$gte", 1)))toArray());

//查询age！=1

// print("fint: "+collfind(new BasicDBObject("age", new BasicDBObject("$ne", 1)))toArray());

//查询age=1,2,3

// print("fint: "+collfind(new BasicDBObject("age", new BasicDBObject(QueryOperatorsIN ,new int[]{1,2,3})))toArray());

//查询age！=1,2,3

// print("find: "+collfind(new BasicDBObject("age" ,new BasicDBObject(QueryOperatorsNIN ,new int[]{1,2,3})))toArray());

// print("find: "+collfind(new BasicDBObject("age" ,new BasicDBObject(QueryOperatorsEXISTS ,true)))toArray());

//查询age属性

// print("find: "+collfind(null ,new BasicDBObject("age" ,true))toArray());

// List<DBObject> list=collfind()toArray();

// for(Object obj:list){

// Systemoutprintln(obj);

// }

//true查询出来存在的 /false 查询出来不存在的

//print(""+collfind(new BasicDBObject("y",new BasicDBObject(QueryOperatorsEXISTS,false)))toArray());

// DBObject dbc=new BasicDBObject();

// dbcput("name", 1111);

// List<DBObject> list=new ArrayList<DBObject>();

// listadd(dbc);

// Systemoutprintln(collinsert(list)getN());

// //查询部分数据块

// DBCursor cursor=collfind()skip(1);

// while(cursorhasNext()){

// Systemoutprintln(cursornext());

// }

// DBCursor cur=collfind(); //DBCursor cur=collfind()limit(2);

// while(curhasNext()){

// Systemoutprintln(curnext());

// }

//Systemoutprintln(curgetCursorId()+" "+curcount()+" "+JSONserialize(cur));

//条件查询

BasicDBObject doc5=new BasicDBObject();

doc5put("$gt", 1);

doc5put("$lt", 3);

print("find 21<y<23："+collfind(new BasicDBObject("y", doc5))toArray());

// BasicDBObject doc5=new BasicDBObject();

// doc5put("$gt", 1);

// doc5put("$lt", 3);

// BasicDBObject doc6=new BasicDBObject();

// doc6put("x", doc5);

// Systemoutprintln(collfind(doc6));

} catch (Exception e) {

eprintStackTrace();

}

}

}

很多人都在知道，计算机行业的发展是非常迅速的，软件开发人员想要跟上时代的发展，最重要的就是不断挑战自己。在学习软件开发的过程，前期学习的知识是远远不够的，需要了解更多的知识，并且挑战更多的复杂性。

现在学习Java语言不能忽略工具和框架的使用，工具和框架的构建越来越复杂。很多人不知道学习工具和框架有什么用？下面昌平电脑培训为大家具体了解Java开发应该了解的大数据工具和框架。

一、MongoDB

这是一种最受欢迎的，跨平台的，面向文档的数据库。

MongoDB的核心优势是灵活的文档模型，高可用性复制集和可扩展的碎片集群。北京java培训建议可以尝试以多种方式了解MongoDB，例如MongoDB工具的实时监控，内存使用和页面错误，连接，数据库 *** 作，复制集等。

二、Elasticsearch

主要是能够为云构建的分布式RESTful搜索引擎。

Elasticsearch主要是使用在Lucene之中的服务器，能够进行分布式多用户能力的全文搜索引擎，并且还是使用在Java的开发中，这是现在很多企业中使用最流行的搜索引擎。ElasticSearch不仅是一个全文搜索引擎，而且是一个分布式实时文档存储，每个字段都能够被索引并且可以被搜索。它也是一个具有实时分析功能的分布式搜索引擎，java课程发现它还可以扩展到数百个服务器存储和处理数PB的数据。

三、Cassandra

这是一个开源的分布式数据库管理系统，最初由Facebook开发，用于处理许多商用服务器上的大量数据，提供高可用性而无单点故障。

ApacheCassandra是一套开源分布式NoSQL数据库系统。集GoogleBigTable的数据模型与AmazonDynamo的完全分布式架构于一身。于2008开源，此后，由于Cassandra良好的可扩展性，被Digg、Twitter等Web20网站所采纳，成为了一种流行的分布式结构化数据存储方案。

四、Redis

开源（BSD许可证）内存数据结构存储，用作数据库，缓存和消息代理。

Redis是一个开源的，基于日志的Key-Value数据库，用ANSIC编写，支持网络，可以基于内存持久化，并提供多种语言的API。Redis有三个主要功能，北京IT培训认为可以将它与许多其他竞争对手区分开来：Redis是一个将数据完全存储在内存中的数据库，仅使用磁盘用于持久性目的。

private Mongo mog = null;

02 private DB db = null;

03 private DBCollection dbc = null;

04

05 /

06 构造方法

07 /

08 public MongoTest(){

09 //实例化Mongo 会默认连接你的数据库

10 try {

11 mog = new Mongo();

12 } catch (UnknownHostException e) {

13 eprintStackTrace();

14 } catch (MongoException e) {

15 eprintStackTrace();

16 }

17

18 //得到MyTest数据库，如果不存在会自动创建

19 db = moggetDB("MyTest");

20

21 //得到集合，相当于其他数据库的表，如果没有也会自动创建

22 dbc = dbgetCollection("table1");

23 }

做梦也很累

2这个是我查询table1集合中所有的数据，如果table1不存在的话它会自动创建，

01 public void selectAll(){

02 Systemoutprintln("查询table1中的所有数据：");

03

04 //得到查询

05 DBCursor cur = dbcfind();

06

07 //遍历结果

08 while(curhasNext()){

09 Systemoutprintln(curnext());

10 }

11 }

做梦也很累

3这个是插入一条文档的方法，这些name/title/age/等等都是你随便添加的，哪怕你第一次添加三个、第二次添加一个、第三次添加10个都没有问题，

01 public void insert(){

02 DBObject msg = new BasicDBObject();

03

04 //赋值

05 msgput("name", "qlier");

06 msgput("age", "21");

07 msgput("sex", "男");

08 msgput("email", "xiuxu123@livecn");

09

10 //保存数据，获取影响行数

11 int result = dbcsave(msg)getN();

12

13 Systemoutprintln("插入结果：" + result);

14 }

做梦也很累

4这个是删除的方法，删除是要说的，它可以根据_id删除，这个_id是系统生成的，这个是很重要的一个标示，我们删除的时候可以根据它删除也可以根据其他的删除。

01 public void updateById(){

02 //要修改的_id

03 DBObject msg1 = new BasicDBObject("_id", new ObjectId("4f3b26b5f8293433e7043e4d"));

04

05 //要修改的值

06 DBObject msg2 = new BasicDBObject();

07 //如果这一个文档很多字段，你就修改一个字段，那么其他的字段会被删除

08 msg2put("name", "Qlier1");

09

10 //修改name，如果name值不存在会重新添加这天数据

11 int result = dbcupdate(msg1, msg2)getN();

12

13 Systemoutprintln("修改结果：" + result);

以上就是关于java 什么使用mongodb全部的内容，包括:java 什么使用mongodb、高手帮帮忙，我刚接触mongodb，怎么用java对mongodb数据库进行多条件查询，先谢谢了、学习Java应该了解的大数据和框架等相关内容解答，如果想了解更多相关内容，可以关注我们，你们的支持是我们更新的动力！