MongoDB存放文件 MongoDB存放文件

package test;

import java.io.File;
import java.io.IOException;
import java.util.List;

import com.mongodb.DB;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSDBFile;
import com.mongodb.gridfs.GridFSInputFile;
/**
* 将一系列图片文件存储到MongoDB中
* @author Kaka
*
*/
public class MongFileTest {
String path="D:\\img\\original";
File[]listFile(){
File directory=new File(path);
return directory.listFiles();
}
public static void main(String[] args) throws MongoException, IOException {
//
MongFileTest mft=new MongFileTest();
//连接服务器
Mongo mongo=new Mongo("127.0.0.1", 27017);
//数据库
DB db=mongo.getDB("files");
//存储fs的根节点
GridFS gridFS=new GridFS(db,"pictures");
//列出文件下目录
File []files=mft.listFile();
//遍历存储近MongoDB
for (File file : files) {
System.out.println("save "+file.getAbsoluteFile());
GridFSInputFile gfs=gridFS.createFile(file);
gfs.put("filename", file.getName());
gfs.put("path", file.getAbsoluteFile());
gfs.put("contentType", file.getName().substring(file.getName().lastIndexOf(".")));
gfs.save();
}
//检索
List list =gridFS.find("201008171282033626670.jpg");
for (GridFSDBFile dbFile : list) {
String name="t.jpg";
dbFile.writeTo(name);
System.out.println("out put to "+name);
name="t"+name;
}
}

} +++++++++++++++++++++++++++++++++++++++++++++++++++ import java.io.File;
import java.net.UnknownHostException;
import java.util.Date;
import java.util.List;
import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.DBObject;
import com.mongodb.Mongo;
import com.mongodb.MongoException;
import com.mongodb.gridfs.GridFS;
import com.mongodb.gridfs.GridFSInputFile;

public class MongoDBClientTest {

public static void main(String[] args) {
//initData();
//query();
initData4GridFS();
}

private static void initData4GridFS(){
long start = new Date().getTime();
try {
Mongo db = new Mongo("127.0.0.1", 50000);
DB mydb = db.getDB("wlb");
File f = new File("D://study//document//MySQL5.1参考手册.chm");
GridFS myFS = new GridFS(mydb);
GridFSInputFile inputFile = myFS.createFile(f);
inputFile.save();

DBCursor cursor = myFS.getFileList();
while(cursor.hasNext()){
System.out.println(cursor.next());
}
db.close();
long endTime = new Date().getTime();
System.out.println(endTime - start);
System.out.println((endTime - start) / 10000000);
}catch (Exception e) {
e.printStackTrace();
}
}
}

MongoDB存放文件

推荐阅读

redis秒杀实现思路java redis秒杀场景实现

s plot分析,the dead的plot分析

长沙市第四医院|“冻手冻脚”的朋友注意，冬季取暖，谨防一氧化碳中毒！

mysql脚本文件在哪里 mysql引入脚本报错

一公里等于多少英里一公里等于多少里

西梅不熟可以吃吗

喝了酒之后洗澡会有什么不良反应喝完酒洗澡会怎么样

最近经常头晕，一出门走动

我的ID是江南美人男主小时候是谁演的

oppo发布6nm芯片马里亚纳X的 ai算法超越a15

二手房交易要交税吗

做梦哭醒做梦哭醒的含义

laravel|laravel 的用户认证

钓鱼两根线怎样接

新冠疫苗第二针打完可以洗澡吗

广西浦北县圆通快递在哪里

如何测定乙醇的含量

网银链接服务器失败网银服务器错误怎么办

一斤杨梅泡几斤白酒

纪录片《大国崛起》为什么没有讲奥斯曼帝国?奥斯曼帝国不算世界性大国吗？