mongoDB大文件的存取操作

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了mongoDB大文件的存取操作，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2957字，纯文字阅读大概需要5分钟。

内容图文

此处所用mongoDB包是3.4.2版。
大家复制的时候最好将引包部分复制。

直接上demo.

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.file.Files;
import java.util.ArrayList;
import java.util.List;

import org.bson.Document;
import org.bson.types.ObjectId;

import com.mongodb.Block;
import com.mongodb.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.gridfs.GridFSBucket;
import com.mongodb.client.gridfs.GridFSBuckets;
import com.mongodb.client.gridfs.GridFSUploadStream;
import com.mongodb.client.gridfs.model.GridFSFile;
import com.mongodb.client.gridfs.model.GridFSUploadOptions;
import com.nari.Dao.DatabaseInfor;

public class Mytest {

private MongoClient mongoClient;
private MongoDatabase mongoDatabase;
private GridFSBucket gridFSBucket;
// private MongoTemplate mongoTemplate;
{
mongoClient =new MongoClient(“localhost”,27017);
mongoDatabase =mongoClient.getDatabase(“test”);
gridFSBucket =GridFSBuckets.create(mongoDatabase,“files”);

}

public ObjectId saveFile(String url) {
ObjectId fileid = null;
GridFSUploadStream gfsupload = null;
// 配置一些参数
GridFSUploadOptions options = null;
// 截取文件名
String filename = url.substring((url.lastIndexOf("/") + 1), url.length());
try {
options = new GridFSUploadOptions().chunkSizeBytes(358400).metadata(new Document(“type”, “presentation”));

// 存储文件，第一个参数是文件名称，第二个是输入流,第三个是参数设置
gfsupload = gridFSBucket.openUploadStream(filename, options);

byte[] data = Files.readAllBytes(new File(url).toPath());

gfsupload.write(data);

} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {

gfsupload.close();
fileid = gfsupload.getObjectId();
}
return fileid;
}
// 查询所有储存的文件
public List findAllFile() {
List filenames = new ArrayList<>();

gridFSBucket.find().forEach(new Block() {

@Override
public void apply(GridFSFile t) {
filenames.add(t.getFilename());
}
});

return filenames;
}
public String downFile(String url, ObjectId id) {
FileOutputStream out = null;
String result=null;
try {
out = new FileOutputStream(new File(url));
gridFSBucket.downloadToStream(id, out);

} catch (FileNotFoundException e) {
e.printStackTrace();
}finally {
try {
out.close();
result=out.toString();
} catch (IOException e) {
e.printStackTrace();
}
}
return result;
}
public static void main(String[] args) {
Mytest mytest = new Mytest();
//要保存在mongoDB中的大文件。
// ObjectId _id=mytest.saveFile(“D:\NR.CalcConfig.war”);
//downFile(“下载路径（包含文件名）”,)
// String str=mytest.downFile(“D:\Data\NR.CalcConfig.war”,_id);
List fileNames =mytest.findAllFile();
for(String str:fileNames) {
System.out.println(str);
}
}

}

已测试完成

文件参考：https://blog.csdn.net/cher1sh_zhaotong/article/details/79192876

如何用侵权请即时联系我：QQ:1836302994

内容总结

以上是互联网集市为您收集整理的mongoDB大文件的存取操作全部内容，希望文章能够帮你解决mongoDB大文件的存取操作所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端