【MongoDB】6.關於MongoDB存儲文件的 命令執行+代碼執行

參考：http://www.runoob.com/mongodb/mongodb-gridfs.html　

　1.命令執行

MongoDB GridFS

GridFS 用於存儲和恢復那些超過16M（BSON文件限制）的文件(如：圖片、音頻、視頻等)。

GridFS 也是文件存儲的一種方式，但是它是存儲在MonoDB的集合中。

GridFS 可以更好的存儲大於16M的文件。

GridFS 會將大文件對象分割成多個小的chunk(文件片段),一般為256k/個,每個chunk將作為MongoDB的一個文檔(document)被存儲在chunks集合中。

 

GridFS 用兩個集合來存儲一個文件：fs.files與fs.chunks。

每個文件的實際內容被存在chunks(二進制數據)中,和文件有關的meta數據(filename,content_type,還有用戶自定義的屬性)將會被存在files集合中。

 

GridFS 添加文件

現在我們使用 GridFS 的 put 命令來存儲 mp3 文件。 調用 MongoDB 安裝目錄下bin的 mongofiles.exe工具。

打開命令提示符，進入到MongoDB的安裝目錄的bin目錄中，找到mongofiles.exe，並輸入下面的代碼：

>mongofiles.exe -d gridfs put song.mp3

gridfs是存儲文件的數據名稱。如果不存在該數據庫，MongoDB會自動創建。Song.mp3 是音頻文件名。

例如：【將a.mp3文件放在MongoDB目錄下】

執行如下命令：

mongofiles.exe -d filesDB put ..\a.mp3

filesDB是數據庫名字  ..\去上一層找   a.mp3是文件名字

 

然后我們在數據庫中查詢：

-->db.fs.chunks.find()

 

-->db.fs.files.find()

 

-->db.fs.chunks.find().count()

這個a.mp3文件工存儲了9個集合

 

僅查詢某個字段的 值

-->db.fs.chunks.find({"_id" : ObjectId("584f6a44150a0d241401b933")},{"data":1})

 

 

2.代碼執行

上傳文件到MongoDB

首先 獲取連接

package com.mongo.util;

import java.util.ArrayList;
import java.util.List;

import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;

public class MongoConnection {
     
    /**
     * 需要驗證用戶名  密碼的 MongoDB的連接方式   com.mongodb.MongoClient.getDatabase("數據庫名")
     * @return
     */
    public MongoDatabase getConnection() {
         try {  
                //連接到MongoDB服務 如果是遠程連接可以替換“localhost”為服務器所在IP地址  
                //ServerAddress()兩個參數分別為 服務器地址 和 端口  
                ServerAddress serverAddress = new ServerAddress("localhost",27017);  
                List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
                addrs.add(serverAddress);  
                  
                //MongoCredential.createScramSha1Credential()三個參數分別為 用戶名 數據庫名稱 密碼  
                MongoCredential credential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());  
                List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
                credentials.add(credential);  
                  
                //通過連接認證獲取MongoDB連接  
                MongoClient mongoClient = new MongoClient(addrs,credentials);  
                  
                //連接到數據庫  
                MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");  
                System.out.println("連接成功");  
                return mongoDatabase;
            } catch (Exception e) {  
                System.err.println( e.getClass().getName() + ": " + e.getMessage() );  
            }  
         return null;
    }
    
    /**
     * 不需要驗證  用戶名+密碼  的獲取連接的方式 com.mongodb.MongoClient.getDatabase("數據庫名")
     * @return
     */
    public MongoDatabase getConnectionBasis(){
        try {
            //連接到mongodb服務
            MongoClient mongoClient = new MongoClient("localhost",27017);
            MongoDatabase mongoDatabase = mongoClient.getDatabase("databaseName");
            System.out.println("連接成功");
            return mongoDatabase;
        } catch (Exception e) {
            System.out.println(e.getClass().getName()+":"+e.getMessage());
        }
        return null;
    }
    
}

接着 就可以創建 傳輸文件所用的通道了

注意 我將操作的文件放在這個位置

讀取項目中某個文件夾下的文件要注意了

package com.mongo.test;


import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

import org.bson.types.ObjectId;
import org.junit.Test;

import com.mongo.util.MongoConnection;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;

/**
 * MongoDB操作文件
 * @author Administrator
 *
 */
public class MongoGridfs {
    MongoConnection mongoConnection = new MongoConnection();
    MongoDatabase database = mongoConnection.getConnectionBasis();
    
    @Test
    public void gridf4File() throws IOException{
        //創建 傳輸文件的通道
        GridFSBucket buckets = GridFSBuckets.create(database);
        //調用uploadFromStream上傳
        ObjectId objectId = buckets.uploadFromStream("test.mp3",new FileInputStream(new File(System.getProperty("user.dir")+"/file/test.mp3")));

        
        FileOutputStream out = new FileOutputStream(new File("d:/aa.mp3"));
        //調用downloadToStream下載
        buckets.downloadToStream(objectId, out);
        out.close();
        
    }
    
    

}

這樣就可以完成對MongoDB的文件傳輸了

 

還有一點補充的代碼 是基友的代碼作為參考  【很詳細】：

package com.mongo.util;

 
import java.io.File;
import java.io.FileOutputStream;
import java.util.ArrayList;
import java.util.List;
import org.bson.conversions.Bson;
import com.mongodb.BasicDBObject;
import com.mongodb.MongoClient;
import com.mongodb.MongoCredential;
import com.mongodb.ServerAddress;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
import com.mongodb.client.gridfs.GridFSFindIterable;
import com.mongodb.client.gridfs.model.GridFSDownloadByNameOptions;
import com.mongodb.client.gridfs.model.GridFSFile;
 
/**
 * 
 * @author AGEN
 *
 */
public class TestMondodb {
     public static void main(String[] args) {
         try { 
             //localhost:mongodb服務器的地址， 27017：mongodb服務器的端口
             ServerAddress serverAddress = new ServerAddress("localhost", 27017);  
             List<ServerAddress> addrs = new ArrayList<ServerAddress>();  
             addrs.add(serverAddress);  
             //第一個參數report:用戶名，第二個參數report:數據庫名，第三個參數"sa".toCharArray():密碼
             MongoCredential credential = MongoCredential.createScramSha1Credential("report", "report", "sa".toCharArray());  
             List<MongoCredential> credentials = new ArrayList<MongoCredential>();  
             credentials.add(credential);  
               
             //通過連接認證獲取MongoDB連接  
             MongoClient mongoClient = new MongoClient(addrs, credentials);  
               
             //連接到數據庫  
             MongoDatabase mongoDatabase = mongoClient.getDatabase("report");  
             
             //創建文件存取通道
             GridFSBucket gsb = GridFSBuckets.create(mongoDatabase);
             
             //向mongodb里面寫入文件
//             File file = new File("F:\\500226199001096256.jpg");
//             FileInputStream fis = new FileInputStream(file);
//             ObjectId id = gsb.uploadFromStream("字根.jpg", fis);
             
             //按Id查找文件，並保存到指定地方
             //注意，下面ID為fs.files的id, 非fs.chunks的id
             //如果不行，我就不知道了，你解決后跟我說一下，讓我長長見識！thank you
             FileOutputStream fos = new FileOutputStream(new File("D:\\aaaa.jpg"));
//             gsb.downloadToStream(new ObjectId("57178cd65eeb4f1f5c2cbaf1"), fos);
             
             //對於你那個uuid是36位的，可以這樣構建條件來查詢將下列md5換成你的_id，對應的值換成像的36位uuid即可
             Bson bson = new BasicDBObject("md5", "4d08209a90345ec9ebb0baf99dd218a1");
             GridFSFindIterable gsfi = gsb.find(bson);
             //因為你的_id是用uuid來表示的，是唯一的，所以應該可以也只能查出一條記錄，在此就直接取第一條，否則應該再篩選
             GridFSFile gfsf = gsfi.first();  
             //按文件名來取得此文件，第三個參數直接創建，表示取此文件的最新版本，如果需要取較舊的版本，則new GridFSDownloadByNameOptions().revision(0)
             //其中0為版本號，表示如下
//            0 = the original stored file
//            1 = the first revision
//            2 = the second revision
//            etc..
//            -2 = the second most recent revision
//            -1 = the most recent revision
             gsb.downloadToStreamByName(gfsf.getFilename(), fos, new GridFSDownloadByNameOptions());
             System.out.println(gfsf.getFilename() + "---" + gfsf.getObjectId() + "---" + gfsf.getId());
         } catch (Exception e) {  //57178cd65eeb4f1f5c2cbaf2
             System.err.println(e.getClass().getName() + ":" + e.getMessage());  
         }  
    }
}