服务器之家：专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

香港云服务器
服务器之家 - 数据库 - MongoDB - MongoDB.NET 2.2.4驱动版本对Mongodb3.3数据库中GridFS增删改查

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

2020-05-09 16:05天风隼 MongoDB

这篇文章主要为大家详细介绍了使用MongoDB.NET 2.2.4驱动版本对Mongodb3.3数据库中GridFS增删改查,具有一定的参考价值，感兴趣的小伙伴们可以参考一下

本文实例为大家分享了针对Mongodb3.3数据库中GridFS增删改查，供大家参考，具体内容如下

Program.cs代码如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
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();
 }
 }

GridFSHelper.cs的代码如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
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);
  }
 }
 
 }
}

ImageHelper.cs的代码如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
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;
 }
 }
}

LogHelper.cs代码如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
/// <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();
 }
 }

结果如下:

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

Mongodb数据：

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

查找图片：

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

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持服务器之家。

  • mongodb
  • 增删改查
  • GridFS
  • MongoDB.NET

    • 延伸 · 阅读

    精彩推荐
    • MongoDB迁移sqlserver数据到MongoDb的方法

      迁移sqlserver数据到MongoDb的方法

      这篇文章主要介绍了迁移sqlserver数据到MongoDb的方法,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下...

      听枫xl9682021-01-03
    • MongoDBmongodb基本命令实例小结

      mongodb基本命令实例小结

      这篇文章主要介绍了mongodb基本命令,结合实例形式总结分析了MongoDB数据库切换、查看、删除、查询等基本命令用法与操作注意事项,需要的朋友可以参考下...

      dawn-liu3652020-05-26
    • MongoDBMongodb实现定时备份与恢复的方法教程

      Mongodb实现定时备份与恢复的方法教程

      这篇文章主要给大家介绍了Mongodb实现定时备份与恢复的方法教程，文中通过示例代码介绍的非常详细，对大家具有一定的参考学习价值，需要的朋友们下面...

      chenjsh364522020-05-13
    • MongoDBMongoDB凭什么跻身数据库排行前五

      MongoDB凭什么跻身数据库排行前五

      MongoDB以比去年同期超出65.96分的成绩继续雄踞榜单前五，这个增幅在全榜仅次于PostgreSQL的77.99，而其相对于4月份的6.10分的增长也是仅次于微软SQL Server排名...

      孙浩峰3892020-05-22
    • MongoDB分布式文档存储数据库之MongoDB分片集群的问题

      分布式文档存储数据库之MongoDB分片集群的问题

      这篇文章主要介绍了分布式文档存储数据库之MongoDB分片集群的问题，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋...

      Linux-18743072020-12-20
    • MongoDBMongoDB安装图文教程

      MongoDB安装图文教程

      这篇文章主要为大家详细介绍了MongoDB安装图文教程，分为两大部分为大家介绍下载MongoDB和安装MongoDB的方法，感兴趣的小伙伴们可以参考一下 ...

      Yangyi.He6132020-05-07
    • MongoDBMongoDB 内存使用情况分析

      MongoDB 内存使用情况分析

      都说 MongoDB 是个内存大户，但是怎么知道它到底用了多少内存呢...

      MongoDB教程网10002020-09-29
    • MongoDBMongoDB中javascript脚本编程简介和入门实例

      MongoDB中javascript脚本编程简介和入门实例

      作为一个数据库，MongoDB有一个很大的优势——它使用js管理数据库，所以也能够使用js脚本进行复杂的管理——这种方法非常灵活 ...

      MongoDB教程网6982020-04-24
    最近更新
    编辑推荐
    阅读排行
    热门标签
    28663 　 数据库删除 　 db.serverStatus 　 分片技术 　 MongoDB教程 　 MongoDB安装图解 　 MongoDB安装教程 　 MongoDB入门教程 　 PHP驱动 　 修改用户密码 　 自定义连接池 　 replica 　 mongodb导入 　 mongodb导出 　 mongodb还原 　 mongodb备份 　 整库备份 　 数据库切换 　 数据库创建 　 cgroup 　 循环遍历 　 数据库游标 　 NumberInt32 　 添加管理员 　 安全设置命令 　 php分页类 　 编程模型 　 脚本编程 　 mongodb条件查询 　 mongodb数组查询 　
    © 2019-2025 服务器之家(www.zzvips.com) 版权所有关于我们联系我们版权申明网站地图
    379