mongodb Gridfs操作


GridFS 介紹

GridFS是MongoDB規范用於存儲和檢索大文件,如圖片,音頻文件,視頻文件等。這是一種文件系統用來存儲文件,但數據存儲於MongoDB集合中。GridFS存儲文件比其文檔大小16MB限制的更大能力。

GridFS的划分一個文件分成塊存儲數據每個塊在一個單獨的文件,每個最大尺寸255K。

GridFS默認使用兩個集合 fs.files 和 fs.chunks 存儲該文件的元數據和塊。每組塊標識其唯一的_id ObjectID字段。fs.files切斷作為父文件。 fs.chunks 文檔 files_id 字段鏈接塊到其父文件。

以下是fs.files集合的樣本文件:

{ "filename": "test.txt", "chunkSize": NumberInt(261120), "uploadDate": ISODate("2014-04-13T11:32:33.557Z"), "md5": "7b762939321e146569b07f72c62cca4f", "length": NumberInt(646) }

文件指定的文件名,塊大小,上傳日期,和長度。

以下是 fs.chunks 文件的樣本文件:

{ "files_id": ObjectId("534a75d19f54bfec8a2fe44b"), "n": NumberInt(0), "data": "Mongo Binary Data" }

將文件添加到GridFS:

現在,我們將使用GridFS的put命令存儲MP3文件。 為此,我們將使用存在於MongoDB的安裝文件夾下的bin文件夾的mongofiles.exe工具。

打開命令提示符,導航到MongoDB的安裝文件夾下的bin文件夾中的mongofiles.exe,並鍵入下面的代碼:

>mongofiles.exe -d gridfs put song.mp3

這里,gridfs上在文件存儲在數據庫的數據庫名稱。 如果數據庫不存在,MongoDB會自動動態創建一個新文檔。 Song.mp3的是上載的文件的名稱。要查看數據庫文件的文件,你可以使用查詢找到:

>db.fs.files.find()

上面的命令返回以下文檔:

{ _id: ObjectId('534a811bf8b4aa4d33fdf94d'), filename: "song.mp3", chunkSize: 261120, uploadDate: new Date(1397391643474), md5: "e4f53379c909f7bed2e9d631e15c1c41", length: 10401959 }

我們也可以看到在fs.chunks集合涉及使用下面的代碼保存的文件都存在於塊中,使用以前的查詢返回文檔ID:

>db.fs.chunks.find({files_id:ObjectId('534a811bf8b4aa4d33fdf94d')})

在我的示例中,該查詢返回40個文檔,是整個MP3文件划分成的40塊數據。

 

 

前言

GridFS是一種將大型文件存儲在MongoDB的文件規范:

 

數據庫支持以BSON格式保存二進制對象。 但是MongoDB中BSON對象最大不能超過4MB。

GridFS 規范提供了一種透明的機制,可以將一個大文件分割成為多個較小的文檔。

為實現這點,該規范指定了一個將文件分塊的標准。每個文件都將在文件集合對象中保存一個元數據對象,一個或多個塊對象可被組合保存在一個塊集合中。

 

上傳文件

  • Shell

        mongofiles put xxx.txt

        常用參數如下:

 

        -d 指定數據庫 

        -u –p 指定用戶名,密碼

        -h 指定主機

        -port 指定主機端口

        -r 如果存在同名文件則在put成功后刪除其他同名文件

 

        通過這樣的命令就可以把文件上傳到fs集合中。

  • Java

        //獲取db

        MongoClient mClient = new MongoClient("10.211.55.8");

        db = mClient.getDB("test");

        //得到Gridfs對象

        GridFS fs = new GridFS(db);

        //訪問要上傳的文件

        File file = new File("/Users/luoaz/05testDir/files/test1.txt");

        //執行保持

        GridFSInputFile gfFile = fs.createFile(file);

        gfFile.save();

下載文件

  • Shell

        mongofiles get xxx.txt

        常用參數如下:

 

        -d 指定數據庫 

        -u –p 指定用戶名,密碼

        -h 指定主機

        -port 指定主機端口

        -l 下載到本地的文件名,默認和數據庫中的名字一致

 

        通過這樣的命令就可以把文件從fs集合中下載到本地。

  • Java

        Java 下載的重點是怎么獲取到文件流,獲取到文件流后就跟普通的保持文件到本地一樣了。

          //獲取db

        MongoClient mClient = new MongoClient("10.211.55.8");

        db = mClient.getDB("test");

        //得到Gridfs對象

        GridFS fs = new GridFS(db);

        

        //要下載到的文件路徑

        File file = new File("/Users/files/down_test1.txt");

        FileOutputStream os = new FileOutputStream(file);

                        

        //獲得文件流

        InputStream is = fs.findOne(new BasicDBObject("filename","test1.txt")).getInputStream();

                        

        //下載

        byte[] bytes = new byte[1024];

        while(is.read(bytes)>0){

                os.write(bytes);

        }

        os.flush();

        os.close();

 

刪除文件

  • Shell

        mongofiles delete xxx.txt

        刪除指定名稱的文件,如果存在同名文件則都刪除

        常用參數如下:

 

        -d 指定數據庫 

        -u –p 指定用戶名,密碼

        -h 指定主機

        -port 指定主機端口

  • Java

        //獲取db

        MongoClient mClient = new MongoClient("10.211.55.8");

        db = mClient.getDB("test");

        //得到Gridfs對象

        GridFS fs = new GridFS(db);

                        

        //刪除指定文件名稱的文件

        fs.remove("test1.txt");

查看文件

  • Shell

        1、list 

                顯示所有文件

                mongofiles list xx.txt

                顯示所有的指定文件名的文件

        2、search

                搜索指定名稱的文件,可以模糊搜索

                mongofiles list xx.txt

                mongofiles list .txt

  • Java

        這個就跟MongoDB的find用法一樣了

 

 

 

/*//保存文件
GridFSFile file = myFS.createFile(new File("D:/aa.png"));
file.save(); */

//輸出文件
GridFSDBFile file1 =myFS.findOne("aa.png");
file1.writeTo(new File("D:/image1.png"));

//刪除文件
/*GridFSDBFile file =myFS.findOne("image1.jpg");
myFS.remove((ObjectId) file2.getId());*/


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM