简要介绍一下Java是怎样操作Mongodb进行数据的增删改查的:
什么是MongoDB ?
MongoDB 是由C++语言编写的,是一个基于分布式文件存储的开源数据库系统。
在高负载的情况下,添加更多的节点,可以保证服务器性能。
MongoDB 旨在为WEB应用提供可扩展的高性能数据存储解决方案。
MongoDB 将数据存储为一个文档,数据结构由键值(key=>value)对组成。MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档,数组及文档数组。
主要特点
- MongoDB的提供了一个面向文档存储,操作起来比较简单和容易。
- 你可以在MongoDB记录中设置任何属性的索引 (如:FirstName="Sameer",Address="8 Gandhi Road")来实现更快的排序。
- 你可以通过本地或者网络创建数据镜像,这使得MongoDB有更强的扩展性。
- 如果负载的增加(需要更多的存储空间和更强的处理能力) ,它可以分布在计算机网络中的其他节点上这就是所谓的分片。
- Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记,可轻易查询文档中内嵌的对象及数组。
- MongoDb 使用update()命令可以实现替换完成的文档(数据)或者一些指定的数据字段 。
- Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。
- Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录,将key与value传给Reduce函数进行处理。
- Map函数和Reduce函数是使用Javascript编写的,并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。
- GridFS是MongoDB中的一个内置功能,可以用于存放大量小文件。
- MongoDB允许在服务端执行脚本,可以用Javascript编写某个函数,直接在服务端执行,也可以把函数的定义存储在服务端,下次直接调用即可。
- MongoDB支持各种编程语言:RUBY,PYTHON,JAVA,C++,PHP,C#等多种语言。
- MongoDB安装简单。
你可以在mongodb官网下载该安装包,地址为: http://www.mongodb.org/downloads。
个人用的MongoDB桌面管理工具是:robomongo 网上搜搜随处可下
Java操作MongoDB需要MongoDB的驱动jar包:
首先你必须下载mongo jar包,下载地址:http://mongodb.github.io/mongo-java-driver/, 请确保下载最新版本。
你需要将 mongo-java-driver-3.X.X.jar (找到合适的版本)包含在你的 classpath 中。。
国内 mongodb-driver jar 下载地址:http://central.maven.org/maven2/org/mongodb/mongo-java-driver/
接下来所说都是废话,直接上代码:
此代码可以直接运行:
package com.taotao.mongdb;
import com.mongodb.*;
/**
* Created by tao on 2017/2/16.
*/
public class MongdbDemo {
private static Mongo mongo = null;
private static DBCollection dbCollection = null;
/**
* 初始化连接Mongdb,此处使用默认连接(本地地址,默认端口)
*
* @return mongo
*/
private static Mongo initMongo() {
System.out.println("连接Mongo");
mongo = new Mongo();
// mongo = new MongoClient( "localhost" , 27017 );
//查询所有的Database
for (String name : mongo.getDatabaseNames()) {
System.out.println("dbName: " + name);
}
return mongo;
}
/**
* 根据集合名名称获取集合对象
*
* @param name
* @return dbCollection
*/
private static DBCollection getDBCollection(String name) {
System.out.println("根据集合名名称获取集合对象");
DB db = mongo.getDB("FirstDB");//有此数据库就返回,没有就创建一个新的数据库
System.out.println(db.getStats());
//查询所有的聚集集合
for (String n : db.getCollectionNames()) {
System.out.println("collectionName: " + n);
}
dbCollection = db.getCollection(name);//有集合就返回,无就根据名字创建一个新的集合
return dbCollection;
}
/**
* 插入
*/
private static void insert() {
System.out.println("插入数据:");
for (int i = 0; i < 2; i++) {
BasicDBObject basicDBObject = new BasicDBObject();
basicDBObject.put("xingming", "雷涛"+i);
basicDBObject.put("age", 22);
basicDBObject.put("sex", "man");
dbCollection.save(basicDBObject);//存入值
BasicDBObject basicDBObject_2 = new BasicDBObject();
basicDBObject_2.put("xingming", "苍狼"+i);
basicDBObject_2.put("age", 22);
basicDBObject_2.append("friend_1", basicDBObject);
dbCollection.save(basicDBObject_2);//存入值
}
System.out.println("插入数据成功");
}
/**
* 更新指定文档指定字段的值
*/
private static void update() {
System.out.println("更新数据:");
//构建更新文档的条件
DBObject query = new BasicDBObject();
query.put("xingming", "苍狼0");
//构建需要更新的字段的值
DBObject updateValue = new BasicDBObject();
updateValue.put("age", 100);
DBObject updateSetValue = new BasicDBObject("$set",updateValue);
dbCollection.update(query, updateSetValue);
System.out.println("更新数据成功");
}
/**
* 删除
*/
private static void delete() {
System.out.println("删除数据:");
DBObject query = new BasicDBObject();
query.put("xingming", "涛濤");
dbCollection.remove(query);
System.out.println("删除数据成功");
}
/**
* 条件查询()
*/
private static void select() {
System.out.println("条件查询:");
BasicDBObject basicDBObject = new BasicDBObject();
basicDBObject.put("age", 22);
DBCursor cur1 = dbCollection.find(basicDBObject);
System.out.println(cur1.next());
DBObject dbObject = cur1.next();
System.out.println(dbObject.get("xingming"));
//条件查询一个,不输入条件之间findOne()将返回集合中第一个文档
DBObject query_2 = new BasicDBObject();
query_2.put("age", 22);
DBObject dbObject_2 = dbCollection.findOne(query_2);
if (null!=dbObject_2) {
System.out.println("只查询一个:" + dbObject_2.get("xingming") + ";" + dbObject_2.get("sex"));
}
}
/**
* 查询当前集合下所有数据
*/
private static void selectAll() {
System.out.println("查询所有数据:");
DBCursor cur = dbCollection.find();
while (cur.hasNext()) {
System.out.println("while=" + cur.next());
}
}
public static void main(String[] args) {
initMongo();
getDBCollection("canglang");
insert();
update();
select();
selectAll();
delete();
}
}
运行结果:
数据库里面的结果:
希望此文对初学者有所帮助!!!
入门学习地址:http://www.runoob.com/mongodb/mongodb-java.html