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存取文件的过程。