zoukankan      html  css  js  c++  java
  • c#通过操作mongodb gridfs实现文件的数据库存储

    @(编程)

    源码

    using MongoDB.Driver;
    using MongoDB.Driver.GridFS;
    using System.IO;
    
    namespace Wisdombud.Mongo
    {
        /// <summary>
        /// 
        /// </summary>
        public class MongoFileBll
        {
            private MongoDatabase repository;
            /// <summary>
            /// 
            /// </summary>
            /// <returns></returns>
            public MongoCursor<MongoGridFSFileInfo> FindAll()
            {
                return this.repository.GetGridFS(MongoGridFSSettings.Defaults).FindAll();
            }
            /// <summary>
            /// 
            /// </summary>
            /// <param name="pConnectionstring"></param>
            public MongoFileBll(string pConnectionstring)
            {
                MongoUrl mongourl = MongoUrl.Create(pConnectionstring);
                var client = new MongoClient(mongourl);
                MongoServer server = client.GetServer();
                this.repository = server.GetDatabase(mongourl.DatabaseName);
            }
            /// <summary>
            /// 
            /// </summary>
            /// <param name="filePath"></param>
            public void UploadFile(string filePath)
            {
                FileInfo fi = new FileInfo(filePath);
                this.repository.GetGridFS(MongoGridFSSettings.Defaults).Upload(filePath, fi.Name);
            }
            /// <summary>
            /// 
            /// </summary>
            /// <param name="filePath"></param>
            /// <param name="fileName"></param>
    
            public void UploadFile(string filePath, string fileName)
            {
                this.repository.GetGridFS(MongoGridFSSettings.Defaults).Upload(filePath, fileName);
            }
    
            /// <summary>
            /// 
            /// </summary>
            /// <param name="fileName"></param>
            /// <param name="filePath"></param>
            public void DownloadFile(string fileName)
            {
                this.repository.GetGridFS(MongoGridFSSettings.Defaults).Download(fileName);
            }
            /// <summary>
            /// 
            /// </summary>
            /// <param name="fileName"></param>
            public void DeleteFile(string fileName)
            {
                this.repository.GetGridFS(MongoGridFSSettings.Defaults).Delete(fileName);
            }
            /// <summary>
            /// 
            /// </summary>
            public void DeleteAll()
            {
                foreach (var inst in this.repository.GetGridFS(MongoGridFSSettings.Defaults).FindAll())
                {
                    inst.Delete();
                }
            }
        }
    }
    
    

    这个源码持续更新中

    用法

    MongoFileBll tl = new MongoFileBll("mongodb://127.0.0.1:27017/chzhaotest");
    string folder = @"D:Wisdombud201620160324_Wisdombud.MongoSourceCodeWisdombud.Mongo.SampleinDebug";
    DirectoryInfo di = new DirectoryInfo(folder);
    foreach (var file in di.GetFiles())
    {
        tl.UploadFile(file.FullName, Guid.NewGuid().ToString());
    }
    var aaa = tl.FindAll();
    foreach (var inst in aaa)
    {
        Console.WriteLine(inst.Name);
    }
    
  • 相关阅读:
    在线客服系统前端多国语言实现方案和代码
    索引下推,这个点你肯定不知道!
    拿捏!隔离级别、幻读、Gap Lock、Next-Key Lock
    现在已经卷到需要问三色标记了吗?
    听说你对explain 很懂?
    面试官:你说说一条更新SQL的执行过程?
    面试官:你说说一条查询SQL的执行过程
    别再纠结线程池大小线程数量了,没有固定公式的
    记一次慢SQL优化
    缓存热点,缓存穿透,终极解决方案看过来
  • 原文地址:https://www.cnblogs.com/wardensky/p/5331969.html
Copyright © 2011-2022 走看看