C#如何向MongoDB GridFs中存储文件

如下示例代码,使用的是MongoDB官方的csharp 驱动程序：

[csharp] view plaincopyprint?

1. var server = MongoServer.Create("mongodb://localhost:27020");  
2. var database = server.GetDatabase("tesdb");  
3.   
4. var fileName = "D:\\Untitled.png";  
5. var newFileName = "D:\\new_Untitled.png";  
6. using (var fs = new FileStream(fileName, FileMode.Open))  
7. {  
8.    var gridFsInfo = database.GridFS.Upload(fs, fileName);  
9.    var fileId = gridFsInfo.Id;  
10.   
11.    ObjectId oid= new ObjectId(fileId);  
12.    var file = database.GridFS.FindOne(Query.EQ("_id", oid));  
13.   
14.    using (var stream = file.OpenRead())  
15.    {  
16.       var bytes = new byte[stream.Length];  
17.       stream.Read(bytes, 0, (int)stream.Length);  
18.       using(var newFs = new FileStream(newFileName, FileMode.Create))  
19.       {  
20.         newFs.Write(bytes, 0, bytes.Length);  
21.       }   
22.    }  
23. }  

 var server = MongoServer.Create("mongodb://localhost:27020"); var database = server.GetDatabase("tesdb"); var fileName = "D:\\Untitled.png"; var newFileName = "D:\\new_Untitled.png"; using (var fs = new FileStream(fileName, FileMode.Open)) {    var gridFsInfo = database.GridFS.Upload(fs, fileName);    var fileId = gridFsInfo.Id;    ObjectId oid= new ObjectId(fileId);    var file = database.GridFS.FindOne(Query.EQ("_id", oid));    using (var stream = file.OpenRead())    {       var bytes = new byte[stream.Length];       stream.Read(bytes, 0, (int)stream.Length);       using(var newFs = new FileStream(newFileName, FileMode.Create))       {         newFs.Write(bytes, 0, bytes.Length);       }     } }

执行结果如下：

File：

Chunks collection: