05 使用java訪問mongodb存取文件

上一節我們介紹了java訪問mongodb存取基本數據，這一節我們將使用java訪問mongodb存儲文件。
在啟動mongodb服務成功之后，這一節我們將使用命令行操作mongodb。

1、前提約束

• 已經啟動mongodb服務，假設端口是27017
  https://www.jianshu.com/p/529f66ea5f67

2、操作步驟

2.1通過命令行上傳文件

• 以管理員命令行方式進入mongodb安裝文件夾的bin目錄，執行以下命令：

# 上傳文件
mongofiles.exe -d tf put ..\mongo.conf
# 進入mongodb命令行
mongo.exe   
# 顯示database
show dbs
# 進入tf實例
use tf
# 顯示tf中的collections,我們會看到fs.chunks，fs.files兩個文件，
# 前者存儲文件真正內容，后者存儲文件邏輯信息
show collections

fs.chunks與fs.files的聯系和區別如下圖所示：

2.2 通過java代碼上傳文件

• 創建一個maven項目，加入以下依賴

        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>3.6.3</version>
        </dependency>

• 創建一個TestMongo.java，內容如下：

import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSDBFile;
import com.mongodb.gridfs.GridFSInputFile;
import org.bson.types.ObjectId;

import java.io.File;


public class MongoTest {

    public static void main(String[] args) {
//        upload("C:/Users/zhangli/Desktop/1.png");
        download("5e4be8c63930f446e42b8c65","C:/Users/zhangli/Desktop/1.png");
    }


    public static void download(String id,String filepath) {
        try {
            Mongo db = new Mongo("127.0.0.1", 27017);
            DB mydb = db.getDB("tf");
            GridFS myFS = new GridFS(mydb);
            GridFSDBFile gridFSDBFile = myFS.findOne(new ObjectId(id));
            gridFSDBFile.writeTo(filepath);
            db.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static void upload(String filepath) {
        try {
            Mongo db = new Mongo("127.0.0.1", 27017);
            DB mydb = db.getDB("tf");
            File f = new File(filepath);
            GridFS myFS = new GridFS(mydb);
            GridFSInputFile inputFile = myFS.createFile(f);
            inputFile.save();
            System.out.println(inputFile.getId());
            db.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

• 測試
  先執行upload方法，確保本地文件路徑正確，上傳完畢，記錄打印的文件id，在通過該id，執行download方法。
  以上就是java訪問mongodb存取文件的過程。