首页 / 数据库 / MySQL / 用MongoDB基于GridFS存储文件

在Mongodb中以GridFSB方式存放文件有两种方式：1、命令行方式mongofiles 2、客户端驱动编程（以Java为例）相关阅读：MongoDB集群配置（sharding with replica set） http://www.linuxidc.com/Linux/2012-01/50773.htmMongoDB运行时添加分片复制集 http://www.linuxidc.com/Linux/2012-01/50775.htm1、命令行方式mongofiles在bin目录下有一个命令mongofiles.exe，即可完成命令行下向Mongodb数据库中插入文件数据。这里以前述所搭的4个分片，每分片3个复制集，3个ConfigSever ，1个路由节点的Windows的模拟集群为例。D:/mongodb-win32-i386-1.8.0/bin>mongofiles.exe -host 127.0.0.1:50000 -d wlb put mongodump.exe
connected to: 127.0.0.1:50000
added file: { _id: ObjectId（"4d91dbc1fb02c495a0a479d7"）, filename: "mongodump.exe", chunkSize: 262144, uploadDate: new Date（1301404609850）, md5: "647dcae88077e6
fa2bb3be6b0cdebb07", length: 3271680 }
done！向数据库wlb中插入一个文件，即Mongodb/bin/mongodump.exe,所使用的Mongodb集群的路由节点为127.0.0.1，端口为50000，其中put为命令，表示向Mongodb中上传文件，也存在get、delete两个其它命令，分别表示取得文件和删除文件。以如下命令启动mongo，进入wlb数据库，执行 db.fs.files.find（）即可看到GridFS中的文件列表.D:/mongodb-win32-i386-1.8.0/cmd>cd d:/mongodb-win32-i386-1.8.0/bin
D:/mongodb-win32-i386-1.8.0/bin>call mongo.exe 127.0.0.1:50000/admin
MongoDB shell version: 1.8.0
connecting to: 127.0.0.1:50000/admin
> use wlb
switched to db wlb
> db.fs.files.find（）
{ "_id" : ObjectId（"4d91dbc1fb02c495a0a479d7"）, "filename" : "mongodump.exe", "chunkSize" : 262144, "uploadDate" : ISODate（"2011-03-29T13:16:49.850Z"）, "md5" :
"647dcae88077e6fa2bb3be6b0cdebb07", "length" : 3271680 }2、以Java API来存取文件这里以mongo-2.5.jar为例，代码如下：

1. package com.zhangzk.mongodb;  
2. import java.io.File;  
3. import java.net.UnknownHostException;  
4. import java.util.Date;  
5. import java.util.List;  
6. import com.mongodb.BasicDBObject;  
7. import com.mongodb.DB;  
8. import com.mongodb.DBCollection;  
9. import com.mongodb.DBCursor;  
10. import com.mongodb.DBObject;  
11. import com.mongodb.Mongo;  
12. import com.mongodb.MongoException;  
13. import com.mongodb.gridfs.GridFS;  
14. import com.mongodb.gridfs.GridFSInputFile;  
15.   
16. public class MongoDBClientTest {  
17.   
18.     public static void main（String[] args） {  
19. //      initData（）;   
20. //      query（）;   
21.         initData4GridFS（）;  
22.     }  
23.       
24.       
25.     private static void initData4GridFS（）   {  
26.         long start = new Date（）.getTime（）;  
27.         try {  
28.             Mongo db = new Mongo（"127.0.0.1", 50000）;  
29.             DB mydb = db.getDB（"wlb"）;  
30.             File f = new File（"D://study//document//MySQL5.1参考手册.chm"）;  
31.             GridFS myFS = new GridFS（mydb）;               
32.             GridFSInputFile inputFile = myFS.createFile（f）;  
33.             inputFile.save（）;  
34.   
35.             DBCursor cursor = myFS.getFileList（）;  
36.             while（cursor.hasNext（））{  
37.                 System.out.println（cursor.next（））;  
38.             }     
39.             db.close（）;  
40.             long endTime = new Date（）.getTime（）;  
41.             System.out.println（endTime - start）;  
42.             System.out.println（（endTime - start） / 10000000）;  
43.         }catch （Exception e） {  
44.             e.printStackTrace（）;  
45.         }  
46.     }  
47. }  

MongoDB运行时添加分片复制集MongoDB的优点与不足相关资讯      MongoDB 

MongoDB 3.3.0 发布下载  （01月14日） 使用MongoDB C#官方驱动操作  （12/31/2015 16:27:56） CentOS 6.6下安装MongoDB 3.0.1  （12/21/2015 19:29:02）

MongoDB 3.2版WiredTiger存储引擎  （01月02日） 进程监控工具Supervisor 启动  （12/26/2015 10:49:57） MongoDB 3.2.1 RC0 发布下载  （12/18/2015 11:32:29）

本文评论 查看全部评论 （0）

表情： 姓名： 匿名字数 版权所有©石家庄振强科技有限公司2024 冀ICP备08103738号-5 网站地图