MongoDB.NET 2.2.4驅動版本對Mongodb3.3數據庫中GridFS增刪改查
更新時間：2020年04月10日 11:31:01 作者：天風隼
這篇文章主要為大家詳細介紹了使用MongoDB.NET 2.2.4驅動版本對Mongodb3.3數據庫中GridFS增刪改查,具有一定的參考價值，感興趣的小伙伴們可以參考一下
本文實例為大家分享了針對Mongodb3.3數據庫中GridFS增刪改查，供大家參考，具體內容如下
Program.cs代碼如下:
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獲取當前應用程序集的執(zhí)行目錄的上級的上級目錄
//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的代碼如下:
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的代碼如下:
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代碼如下:
/// <summary>
/// 手動記錄錯誤日志，不用Log4Net組件
/// </summary>
public class LogHelper
{
/// <summary>
/// 將日志寫入指定的文件
/// </summary>
/// <param name="Path">文件路徑，如果沒有該文件，剛創(chuàng)建</param>
/// <param name="content">日志內容</param>
public static void WriteFile(string content)
{
string Path = AppDomain.CurrentDomain.BaseDirectory + "Log";
if (!Directory.Exists(Path))
{
//若文件目錄不存在 則創(chuàng)建
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">文件路徑，如果沒有該文件，剛創(chuàng)建</param>
/// <param name="content">日志內容</param>
public static void WriteFile(int content)
{
string Path = AppDomain.CurrentDomain.BaseDirectory + "Log";
if (!Directory.Exists(Path))
{
//若文件目錄不存在 則創(chuàng)建
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))
{
//若文件目錄不存在 則創(chuàng)建
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數據：
查找圖片：
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關文章
成功啟動MongoDB后，再打開一個命令行窗口輸入mongo，就可以進行數據庫的一些操作。輸入help可以看到基本操作命令，只是MongoDB沒有創(chuàng)建數據庫的命令，但有類似的命令2014-03-03
這篇文章主要介紹了為什么?PostgreSQL?能代替?MongoDB？,需要的朋友可以參考下2023-12-12
這篇文章主要給大家介紹了在mongodb 3.4下遠程連接認證失敗的解決方法，文中通過示例代碼介紹的非常詳細，對大家具有一定的參考學習價值，需要的朋友們下面跟著小編一起來學習學習吧。2017-06-06
MongoDB快速入門筆記(六)之MongoDB的文檔修改操作
這篇文章主要介紹了MongoDB快速入門筆記(六)之MongoDB的文檔修改操作的相關資料,需要的朋友可以參考下2016-06-06
這篇文章主要介紹了mongodb數據庫實驗之增刪查改的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-11-11
在 MongoDB 數據庫中,我們經常需要進行數據去重并保留最新的數據,本文將介紹如何使用 MongoDB 聚合操作完成這一任務,并將結果保存到新的集合或者覆蓋原有的集合,感興趣的小伙伴跟著小編一起來看看吧2024-01-01
這篇文章主要介紹了MongoDB下根據數組大小進行查詢的方法,分別實現了指定大小的數組和某個范圍的數組,需要的朋友可以參考下2014-04-04
$toBool聚合運算符將指定的值轉換為布爾類型boolean,這篇文章主要介紹了MongoDB聚合運算符：$toBool的相關知識,需要的朋友可以參考下2024-05-05
這篇文章主要介紹了MongoDB數據庫基礎操作,結合實例形式總結分析了MongoDB數據庫創(chuàng)建、刪除、集合、文檔等基本操作技巧,需要的朋友可以參考下2020-06-06
MongoDB添加secondary節(jié)點的2種方法詳解
這篇文章主要給大家總結介紹了關于MongoDB添加secondary節(jié)點的2種方法，以及MongoDB secondary節(jié)點出現recovering狀態(tài)的解決方法，文中介紹的非常詳細，需要的朋友可以參考下2018-10-10