MongoDB.NET 2.2.4驱动版本对Mongodb3.3数据库中GridFS增删改查

internal class Program  {  private static void Main(string[] args)  {   GridFSHelper helper = new GridFSHelper("mongodb://localhost", "GridFSDemo", "Pictures");    #region 上传图片    //第一种   //Image image = Image.FromFile("D://dog.jpg");   //byte[] imgdata = ImageHelper.ImageToBytes(image);   //ObjectId oid = helper.UploadGridFSFromBytes(imgdata);    //第二种   //Image image = Image.FromFile("D://man.jpg");   //Stream imgSteam = ImageHelper.ImageToStream(image);   //ObjectId oid = helper.UploadGridFSFromStream("man",imgSteam);   //LogHelper.WriteFile(oid.ToString());   // Console.Write(oid.ToString());    #endregion    #region 下载图片    //第一种   //ObjectId downId = new ObjectId("578e2d17d22aed1850c7855d");   //byte[] Downdata= helper.DownloadAsByteArray(downId);   //string name= ImageHelper.CreateImageFromBytes("coolcar",Downdata);    //第二种   // byte[] Downdata = helper.DownloadAsBytesByName("QQQ");   //string name = ImageHelper.CreateImageFromBytes("dog", Downdata);    //第三种   //byte[] Downdata = helper.DownloadAsBytesByName("QQQ");   //Image img = ImageHelper.BytesToImage(Downdata);   //string path = Path.GetFullPath(@"../../DownLoadImg/") + DateTime.Now.ToString("yyyyMMddHHmmssfff") + ".jpg";   ////使用path获取当前应用程序集的执行目录的上级的上级目录   //img.Save(path, System.Drawing.Imaging.ImageFormat.Jpeg);    #endregion    #region 查找图片   GridFSFileInfo gridFsFileInfo = helper.FindFiles("man");   Console.WriteLine(gridFsFileInfo.Id);   #endregion    #region 删除图片   //helper.DroppGridFSBucket();   #endregion    Console.ReadKey();  }  } 

using System; using System.Collections.Generic; using System.Configuration; using System.IO; using System.Linq; using System.Text; using System.Threading.Tasks; using MongoDB.Bson; using MongoDB.Driver; using MongoDB.Driver.GridFS;  namespace MongoDemo {  public class GridFSHelper  {  private readonly IMongoClient client;  private readonly IMongoDatabase database;  private readonly IMongoCollection<BsonDocument> collection;  private readonly GridFSBucket bucket;  private GridFSFileInfo fileInfo;  private ObjectId oid;   public GridFSHelper()   : this(   ConfigurationManager.AppSettings["mongoQueueUrl"], ConfigurationManager.AppSettings["mongoQueueDb"],   ConfigurationManager.AppSettings["mongoQueueCollection"])  {  }   public GridFSHelper(string url, string db, string collectionName)  {   if (url == null)   {   throw new ArgumentNullException("url");   }   else   {   client = new MongoClient(url);   }    if (db == null)   {   throw new ArgumentNullException("db");   }   else   {   database = client.GetDatabase(db);   }    if (collectionName == null)   {   throw new ArgumentNullException("collectionName");   }   else   {   collection = database.GetCollection<BsonDocument>(collectionName);   }    //this.collection = new MongoClient(url).GetDatabase(db).GetCollection<BsonDocument>(collectionName);    GridFSBucketOptions gfbOptions = new GridFSBucketOptions()   {   BucketName = "bird",   ChunkSizeBytes = 1*1024*1024,   ReadConcern = null,   ReadPreference = null,   WriteConcern = null   };   var bucket = new GridFSBucket(database, new GridFSBucketOptions   {   BucketName = "videos",   ChunkSizeBytes = 1048576, // 1MB   WriteConcern = WriteConcern.WMajority,   ReadPreference = ReadPreference.Secondary   });   this.bucket = new GridFSBucket(database, null);  }   public GridFSHelper(IMongoCollection<BsonDocument> collection)  {   if (collection == null)   {   throw new ArgumentNullException("collection");   }   this.collection = collection;   this.bucket = new GridFSBucket(collection.Database);  }    public ObjectId UploadGridFSFromBytes(string filename, Byte[] source)  {   oid = bucket.UploadFromBytes(filename, source);   return oid;  }   public ObjectId UploadGridFSFromStream(string filename,Stream source)  {   using (source)   {   oid = bucket.UploadFromStream(filename, source);   return oid;   }  }   public Byte[] DownloadAsByteArray(ObjectId id)  {   Byte[] bytes = bucket.DownloadAsBytes(id);   return bytes;  }   public Stream DownloadToStream(ObjectId id)  {   Stream destination = new MemoryStream();   bucket.DownloadToStream(id, destination);   return destination;  }   public Byte[] DownloadAsBytesByName(string filename)  {   Byte[] bytes = bucket.DownloadAsBytesByName(filename);   return bytes;  }   public Stream DownloadToStreamByName(string filename)  {   Stream destination = new MemoryStream();   bucket.DownloadToStreamByName(filename, destination);   return destination;  }   public GridFSFileInfo FindFiles(string filename)  {   var filter = Builders<GridFSFileInfo>.Filter.And(   Builders<GridFSFileInfo>.Filter.Eq(x => x.Filename, "man"),   Builders<GridFSFileInfo>.Filter.Gte(x => x.UploadDateTime, new DateTime(2015, 1, 1, 0, 0, 0, DateTimeKind.Utc)),   Builders<GridFSFileInfo>.Filter.Lt(x => x.UploadDateTime, new DateTime(2017, 2, 1, 0, 0, 0, DateTimeKind.Utc)));   var sort = Builders<GridFSFileInfo>.Sort.Descending(x => x.UploadDateTime);   var options = new GridFSFindOptions   {   Limit = 1,   Sort = sort   };   using (var cursor = bucket.Find(filter, options))   {    fileInfo = cursor.ToList().FirstOrDefault();   }   return fileInfo;  }    public void DeleteAndRename(ObjectId id)  {   bucket.Delete(id);  }   //The “fs.files” collection will be dropped first, followed by the “fs.chunks” collection. This is the fastest way to delete all files stored in a GridFS bucket at once.  public void DroppGridFSBucket()  {   bucket.Drop();  }   public void RenameAsingleFile(ObjectId id,string newFilename)  {   bucket.Rename(id, newFilename);  }   public void RenameAllRevisionsOfAfile(string oldFilename,string newFilename)  {   var filter = Builders<GridFSFileInfo>.Filter.Eq(x => x.Filename, oldFilename);   var filesCursor = bucket.Find(filter);   var files = filesCursor.ToList();   foreach (var file in files)   {   bucket.Rename(file.Id, newFilename);   }  }   } } 

using System; using System.Collections.Generic; using System.Drawing; using System.Drawing.Imaging; using System.IO; using System.Linq; using System.Text; using System.Threading.Tasks;  namespace MongoDemo {  public static class ImageHelper  {  /// <summary>  /// //将Image转换成流数据，并保存为byte[]  /// </summary>  /// <param name="image"></param>  /// <returns></returns>  public static byte[] ImageToBytes(Image image)  {   ImageFormat format = image.RawFormat;   using (MemoryStream ms = new MemoryStream())   {   if (format.Equals(ImageFormat.Jpeg))   {    image.Save(ms, ImageFormat.Jpeg);   }   else if (format.Equals(ImageFormat.Png))   {    image.Save(ms, ImageFormat.Png);   }   else if (format.Equals(ImageFormat.Bmp))   {    image.Save(ms, ImageFormat.Bmp);   }   else if (format.Equals(ImageFormat.Gif))   {    image.Save(ms, ImageFormat.Gif);   }   else if (format.Equals(ImageFormat.Icon))   {    image.Save(ms, ImageFormat.Icon);   }   byte[] buffer = new byte[ms.Length];   //Image.Save()会改变MemoryStream的Position，需要重新Seek到Begin   ms.Seek(0, SeekOrigin.Begin);   ms.Read(buffer, 0, buffer.Length);   return buffer;   }  }    public static Stream ImageToStream(Image image)  {   ImageFormat format = image.RawFormat;   MemoryStream ms = new MemoryStream();    if (format.Equals(ImageFormat.Jpeg))   {   image.Save(ms, ImageFormat.Jpeg);   }   else if (format.Equals(ImageFormat.Png))   {   image.Save(ms, ImageFormat.Png);   }   else if (format.Equals(ImageFormat.Bmp))   {   image.Save(ms, ImageFormat.Bmp);   }   else if (format.Equals(ImageFormat.Gif))   {   image.Save(ms, ImageFormat.Gif);   }   else if (format.Equals(ImageFormat.Icon))   {   image.Save(ms, ImageFormat.Icon);   }   return ms;  }   //参数是图片的路径  public static byte[] GetPictureData(string imagePath)  {   FileStream fs = new FileStream(imagePath, FileMode.Open);   byte[] byteData = new byte[fs.Length];   fs.Read(byteData, 0, byteData.Length);   fs.Close();   return byteData;  }     /// <summary>  /// Convert Byte[] to Image  /// </summary>  /// <param name="buffer"></param>  /// <returns></returns>  public static Image BytesToImage(byte[] buffer)  {   MemoryStream ms = new MemoryStream(buffer);   Image image = System.Drawing.Image.FromStream(ms);   return image;  }   /// <summary>  /// Convert Byte[] to a picture and Store it in file  /// </summary>  /// <param name="fileName"></param>  /// <param name="buffer"></param>  /// <returns></returns>  public static string CreateImageFromBytes(string fileName, byte[] buffer)  {   string file = fileName;   Image image = BytesToImage(buffer);   ImageFormat format = image.RawFormat;   if (format.Equals(ImageFormat.Jpeg))   {   file += ".jpg";   }   else if (format.Equals(ImageFormat.Png))   {   file += ".png";   }   else if (format.Equals(ImageFormat.Bmp))   {   file += ".bmp";   }   else if (format.Equals(ImageFormat.Gif))   {   file += ".gif";   }   else if (format.Equals(ImageFormat.Icon))   {   file += ".icon";   }   System.IO.FileInfo info = new System.IO.FileInfo(Path.GetFullPath(@"DownLoadImg/")); //在当前程序集目录中添加指定目录DownLoadImg   System.IO.Directory.CreateDirectory(info.FullName);   File.WriteAllBytes(info+file, buffer);   return file;  }  } } 

/// <summary>  /// 手动记录错误日志，不用Log4Net组件  /// </summary>  public class LogHelper  {  /// <summary>  /// 将日志写入指定的文件  /// </summary>  /// <param name="Path">文件路径，如果没有该文件，刚创建</param>  /// <param name="content">日志内容</param>  public static void WriteFile(string content)  {   string Path = AppDomain.CurrentDomain.BaseDirectory + "Log";   if (!Directory.Exists(Path))   {   //若文件目录不存在 则创建   Directory.CreateDirectory(Path);   }   Path += "//" + DateTime.Now.ToString("yyMMdd") + ".log";   if (!File.Exists(Path))   {   File.Create(Path).Close();   }   StreamWriter writer = new StreamWriter(Path, true, Encoding.GetEncoding("gb2312"));   writer.WriteLine("时间：" + DateTime.Now.ToString());   writer.WriteLine("日志信息：" + content);   writer.WriteLine("-----------------------------------------------------------");   writer.Close();   writer.Dispose();  }   /// <summary>  /// 将日志写入指定的文件  /// </summary>  /// <param name="Path">文件路径，如果没有该文件，刚创建</param>  /// <param name="content">日志内容</param>  public static void WriteFile(int content)  {   string Path = AppDomain.CurrentDomain.BaseDirectory + "Log";   if (!Directory.Exists(Path))   {   //若文件目录不存在 则创建   Directory.CreateDirectory(Path);   }   Path += "//" + DateTime.Now.ToString("yyMMdd") + ".log";   if (!File.Exists(Path))   {   File.Create(Path).Close();   }   StreamWriter writer = new StreamWriter(Path, true, Encoding.GetEncoding("gb2312"));   writer.WriteLine("时间：" + DateTime.Now.ToString());   writer.WriteLine("日志信息：" + content);   writer.WriteLine("-----------------------------------------------------------");   writer.Close();   writer.Dispose();  }    /// <summary>  /// 将日志写入指定的文件  /// </summary>  /// <param name="erroMsg">错误详细信息</param>  /// <param name="source">源位置</param>  /// <param name="fileName">文件名</param>  public static void WriteFile(string erroMsg, string source, string stackTrace, string fileName)  {   string Path = AppDomain.CurrentDomain.BaseDirectory + "Log";   if (!Directory.Exists(Path))   {   //若文件目录不存在 则创建   Directory.CreateDirectory(Path);   }   Path += "//" + DateTime.Now.ToString("yyMMdd") + ".log";   if (!File.Exists(Path))   {   File.Create(Path).Close();   }   StreamWriter writer = new StreamWriter(Path, true, Encoding.GetEncoding("gb2312"));   writer.WriteLine("时间：" + DateTime.Now.ToString());   writer.WriteLine("文件：" + fileName);   writer.WriteLine("源：" + source);   writer.WriteLine("错误信息：" + erroMsg);   writer.WriteLine("-----------------------------------------------------------");   writer.Close();   writer.Dispose();  }  }