MongoDB对图片进行CRUD操作——与JAVA结合

        上几篇博客简单对MongoDB进行了简单介绍和如何安装，以及在dos下是如何操作MongoDB和在安装MongoDB中，出现了什么错误，是如何解决的。当然这些都还不够，我们还要用到实际当中去。我用MyEclipse+JDK1.7做了一个简单的demo，来展示下MongoDB怎么运用到实际中去。

       MongoDB作为一个NoSql数据库的代表，存取多媒体数据，应该是强项吧？那么，在MongoDB中是如何对图片进行CRUD操作的。

       上几篇博客中已经提到，MongoDB的文档结构是BSON格式，BSON格式本身支持保存二进制格式的数据，所以可以把文件的二进制格式的数据直接保存到MongoDB的文档结构中。但是一个BSON的最大长度不能超过4M，所以限制了单个文档中能存入的最大文件不能超过4M。为了解决这个问题，MongoDB提供了“GridFS”方式，“GridFS”方式对文件操作需要引入相关jar包——mongo-java-driver-2.9.3.jar。

      不多说，看实例：

package com.zd.mongodb.common;

import java.io.File;
import java.io.IOException;
import java.net.UnknownHostException;

import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSDBFile;
import com.mongodb.gridfs.GridFSInputFile;

public class MongoDBCommon {

	// 连接mongodb
	public DB MongoDbConnection() {
		Mongo m = null;
		try {
			m = new Mongo("localhost", 27017);
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
		DB db = m.getDB("test");
		return db;
	}

	// 保存图片信息
	public void saveFile(String connection, String id, String file) {
		DB db = MongoDbConnection();  //获取MongoDB的数据库
		File imageFile = new File(file);
		GridFS gfsPhoto = new GridFS(db, connection); //connection为集合名词
		GridFSInputFile gfsFile = null;
		try {
			gfsFile = gfsPhoto.createFile(imageFile);
		} catch (IOException e) {
			e.printStackTrace();
		}
		gfsFile.setId(id);
		gfsFile.setContentType("image/jpeg");
		gfsFile.save();

	}

	// 读取文件
	public void readFile(String connection, String fileName) {
		DB db = MongoDbConnection();  //获取连接
		DBCollection collection = db.getCollection(connection);  //connection为集合名称
		String newFileName = fileName;
		GridFS gfsPhoto = new GridFS(db, connection);
		GridFSDBFile imageForOutput = gfsPhoto.findOne(newFileName);
		System.out.println(imageForOutput);   <span style="font-family: Arial, Helvetica, sans-serif;">//返回数据以BSON格式体现</span>
	}

	//根据id查询相应文件
	public void findByObjectId(String connection, String id) {
		DB db = MongoDbConnection();
		DBCollection collection = db.getCollection(connection);
		DBObject dbObj = collection.findOne(id);
		System.out.println(dbObj);  //返回数据以BSON格式体现

	}

	// 删除文件
	public void deleteFile(String connection,String id) {
		DB db = MongoDbConnection();
		DBCollection collection = db.getCollection(connection);
		DBObject o=collection.findOne(id);
		collection.remove(o);
	}

}

package com.zd.mongodb.common;


public class ZhudanTest {
<span style="white-space:pre">	</span>
<span style="white-space:pre">	</span> public static void main(String[] args) throws Exception {
<span style="white-space:pre">		</span> MongoDBCommon dbCommon=new MongoDBCommon();
<span style="white-space:pre">		</span> String newFileName="zhudan.jpg";
<span style="white-space:pre">	</span>     String imageFile="D:/生活/照片/me/zhudan.jpg";
//<span style="white-space:pre">	</span>     String connection="photo.files";
<span style="white-space:pre">	</span>     String connection="photo";
<span style="white-space:pre">	</span>     
<span style="white-space:pre">	</span>     //根据id保存数据
<span style="white-space:pre">	</span>     String id="1111";
<span style="white-space:pre">	</span>     dbCommon.saveFile( connection, id, imageFile);
<span style="white-space:pre">	</span>     
<span style="white-space:pre">	</span>     //根据名称获取数据
//<span style="white-space:pre">		</span> dbCommon.readFile(connection, newFileName);
<span style="white-space:pre">	</span>     
<span style="white-space:pre">	</span>     //根据id删除数据
//<span style="white-space:pre">	</span>     String id="1111";
//<span style="white-space:pre">	</span>     dbCommon.deleteFile(connection,id);
<span style="white-space:pre">		</span> 
<span style="white-space:pre">	</span>     //根据id查询数据
//<span style="white-space:pre">		</span> String id="1111";
//<span style="white-space:pre">		</span> dbCommon.findByObjectId(connection, id);
<span style="white-space:pre">		</span> 
<span style="white-space:pre">	</span> }
}

以图为证：

再分析下原理：

       创建photo时，驱动首先会在当前数据库创建两个集合：一个是"photo.files"集合，另一个是"photo.chunks"集合，前者记录了文件名，文件创建时间，文件类型等基本信息；后者分块存储了文件的二进制数据（并支持加密这些二进制数据）。

       一个trunk有一个默认的大小，当文件超过这个默认大小后，会把文件分割成多个chunk，再把这些chunk保存到photo.chunks中，最后再把文件信息存入到photo.files中。

        在读取文件的时候，先根据查询条件，在photo.files中找到一个合适的记录，得到“_id”的值，再据这个值到photo.chunks中查找所有“files_id”为“_id”的chunk，并按“n”排序，最后依次读取chunk中“data”对象的内容，还原成原来的文件。

总结：

       MongoDB作为一个NoSql数据库的代表，其实它里面包含的东西还有很多，我所接触到的也只是冰山一角，为以后的MongoDB的学习做一个小小的准备。