ASP.NET MongoDB数据库操作类

本文涉及的产品
云数据库 MongoDB,通用型 2核4GB
简介: 1、Web.config文件中配置数据库连接信息,如下代码: 2、MongoDBHelper操作类,如下代码:using System;using System.

1、Web.config文件中配置数据库连接信息,如下代码:

<appSettings>
    <!--连接MongoDB数据库连接字符串开始-->
    <add key="MongoIP" value="192.168.33.162" />
    <add key="MongoDatabase" value="ADS5_HNXY" />
    <!--MongoDB集群名称,单台MongoDB时请注释掉下面行的配置-->
    <!--<add key="ReplicaSetName" value="atrepl"/>-->
    <add key="MongoUser" value=""/>
    <add key="MongoPassword" value=""/>
    <!--连接MongoDB数据库连接字符串结束 -->
</appSettings>


2、MongoDBHelper操作类,如下代码:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using MongoDB.Bson;
using MongoDB.Driver;
using MongoDB.Driver.Builders;
using MongoDB.Driver.GridFS;
using MongoDB.Driver.Linq;
using AT.Business.IDAO;
using AT.Business.DAL;
using AT_DataShiftService;


namespace BAL.DBHelper
{
    /// <summary>
    /// MongoDB数据库操作类
    /// </summary>
    public class MongoData
    {


        #region 属性列表


        private static string ip = System.Configuration.ConfigurationManager.AppSettings["MongoIP"];
        private static string dbname = System.Configuration.ConfigurationManager.AppSettings["MongoDatabase"];
        private static string user = System.Configuration.ConfigurationManager.AppSettings["MongoUser"];
        private static string pwd = System.Configuration.ConfigurationManager.AppSettings["MongoPassword"];
        private static string myReplicaSetName = System.Configuration.ConfigurationManager.AppSettings["ReplicaSetName"];


        private static ReadPreference myReadPreference = ReadPreference.SecondaryPreferred;


        //两个不同的表名
        private const string _ADS5 = "ads5";
        private const string _POWERPARAMETERS = "PowerParameters";


        private static AT_System_IDAO systemidao = new AT_System_Dal();


        #endregion


        #region MongoDB权限认证


        /// <summary>
        ///  MongoDB权限认证
        /// </summary>
        /// <returns></returns>
        public static MongoDatabase getDatabase()
        {
            MongoClientSettings setting = new MongoClientSettings();
            if (!string.IsNullOrEmpty(user) && !string.IsNullOrEmpty(pwd))
            {
                //Logger.Log.Info("MongoDB开启权限访问 " + user + ":" + pwd);
                List<MongoCredential> lstCredential = new List<MongoCredential>();
                lstCredential.Add(MongoCredential.CreateCredential(dbname, user, pwd));
                setting.Credentials = lstCredential;
            }
            setting.Server = new MongoServerAddress(ip);
            if (!string.IsNullOrEmpty(myReplicaSetName))
            {
                //Logger.Log.Info("MongoDB开启集群模式 " + myReplicaSetName);
                setting.ConnectionMode = ConnectionMode.ReplicaSet;
                setting.ReplicaSetName = myReplicaSetName;
                setting.ReadPreference = myReadPreference;
            }
            //MongoClient client = new MongoClient(QJBL.MongoDBConn);
            var client = new MongoClient(setting);
            MongoServer server = client.GetServer();
            MongoDatabase database = server.GetDatabase(dbname);
            return database;
        }


        #endregion


        #region 获取MySQL中对应表具列表信息 2017-05-17


        /// <summary>
        ///  获取MySQL中对应表具列表信息
        /// </summary>
        /// <returns></returns>
        public static DataTable GetMeterList()
        {
            return systemidao.GetMeterList();
        }


        #endregion


        #region 获取每个整点需要上传的表具读数 2017-05-17


        /// <summary>
        /// 获取每个整点需要上传的表具读数
        /// </summary>
        /// <param name="datetime"></param>
        /// <returns></returns>
        public static DataTable AT_Up_EnergyValue4WJW(string datetime)
        {
            DataTable dt = GetMeterList();
            DataTable newDT = new DataTable();
            newDT.Columns.Add("BuildID", typeof(string));
            newDT.Columns.Add("CollectionID", typeof(string));
            newDT.Columns.Add("MeterID", typeof(string));
            newDT.Columns.Add("EnergyValue", typeof(double));
            foreach (DataRowView drv in dt.DefaultView)
            {
                DataRow row = newDT.NewRow();
                if (drv["F_MeasureClassify"].ToString() == "04" || drv["F_MeasureClassify"].ToString() == "14")
                {
                    //从MongoDB中的PowerParameters中取数
                    row["BuildID"] = drv["BuildID"].ToString();
                    row["CollectionID"] = drv["CollectionID"].ToString();
                    row["MeterID"] = drv["MeterID"].ToString();
                    double rawValue = GetDataFromPowerParameters(drv["F_MeterID"].ToString(), DateTime.Parse(datetime), drv["F_ValueType"].ToString());
                    //这里去除的可能是负数,要做绝对值转换
                    double absValue = Math.Abs(rawValue);
                    row["EnergyValue"] = double.Parse(drv["F_Ratio"].ToString()) * absValue * 0.0036;
                    WriteLog(drv["F_MeterID"].ToString() + "\t" + datetime + "\t" + (double.Parse(drv["F_Ratio"].ToString()) * absValue * 0.0036) + "\r");
                    newDT.Rows.Add(row);
                }
                else
                {
                    //从MongoDB中的ADS5中取数
                    row["BuildID"] = drv["BuildID"].ToString();
                    row["CollectionID"] = drv["CollectionID"].ToString();
                    row["MeterID"] = drv["MeterID"].ToString();
                    double rawValue = GetDataFromADS5(drv["F_TagName"].ToString(), DateTime.Parse(datetime));


                    double absValue = Math.Abs(rawValue);
                    row["EnergyValue"] = double.Parse(drv["F_Ratio"].ToString()) * absValue;
                    WriteLog(drv["F_TagName"].ToString() + "\t" + datetime + "\t" + double.Parse(drv["F_Ratio"].ToString()) * absValue + "\r");
                    newDT.Rows.Add(row);
                }
            }
            return newDT;
        }


        #endregion


        #region 当F_MeasureClassify不为‘04’和‘14’时,从ADS5表中获取表头示数 2017-08-03


        /// <summary>
        /// F_CaclType = 0 ,从ADS5表中获取数据
        /// </summary>
        /// <param name="TagName"></param>
        /// <param name="DateTime"></param>
        /// <returns></returns>
        public static double GetDataFromADS5(string TagName, DateTime DateTime)
        {
            MongoDatabase db = MongoData.getDatabase();
            //获得Users集合,如果数据库中没有,先新建一个
            MongoCollection col = db.GetCollection(_ADS5);


            var query = Query.And(
            Query.EQ("TagName", TagName),
            Query.EQ("DateTime", DateTime)
            );
            List<BsonDocument> documents = col.FindAs<BsonDocument>(query).ToList();
            //做异常处理
            if (documents.Count != 0)
            {
                BsonElement element = documents[0].GetElement("Value");
                return double.Parse(element.Value.ToString());
            }
            else
            {
                //直至可以获取到上一个有数据的时刻 2017-08-03
                int index = 0;
                do
                {
                    index++;
                    DateTime NewDateTime = DateTime.AddHours(-1 * index);
                    query = Query.And(
                        Query.EQ("TagName", TagName),
                        Query.EQ("DateTime", NewDateTime)
                     );
                    documents = col.FindAs<BsonDocument>(query).ToList();
                } while (documents.Count == 0);


                BsonElement element = documents[0].GetElement("Value");
                return double.Parse(element.Value.ToString());
            }
        }


        #endregion


        #region 当F_MeasureClassify为‘04’或‘14’时,从PowerParameters表中获取表头示数 2017-08-03


        /// <summary>
        /// 从PowerParameters表中获取数据
        /// </summary>
        /// <param name="TagName"></param>
        /// <param name="DateTime"></param>
        /// <returns></returns>
        public static double GetDataFromPowerParameters(string MeterID, DateTime DateTime, string ValueType)
        {
            MongoDatabase db = MongoData.getDatabase();
            //获得Users集合,如果数据库中没有,先新建一个
            MongoCollection col = db.GetCollection(_POWERPARAMETERS);
            var query = Query.And(
             Query.EQ("MeterID", MeterID),
             Query.EQ("DateTime", DateTime)
             );
            List<BsonDocument> documents = col.FindAs<BsonDocument>(query).ToList();
            //做异常处理
            if (documents.Count != 0)
            {
                BsonElement element = documents[0].GetElement(ValueType);
                return double.Parse(element.Value.ToString());
            }
            else
            {
                //直至可以获取到上一个有数据的时刻 2017-08-03
                int index = 0;
                do
                {
                    index ++;
                    DateTime NewDateTime = DateTime.AddHours(-1 * index);
                    query = Query.And(
                         Query.EQ("MeterID", MeterID),
                         Query.EQ("DateTime", NewDateTime)
                    );
                    documents = col.FindAs<BsonDocument>(query).ToList();
                } while (documents.Count == 0);


                BsonElement element = documents[0].GetElement(ValueType);
                return double.Parse(element.Value.ToString());
            }
        }


        #endregion


        #region 日志记录


        /// <summary>
        /// 
        /// </summary>
        /// <param name="log"></param>
        public static void WriteLog(string log)
        {
            string spath1 = System.AppDomain.CurrentDomain.BaseDirectory + @"\GetInterupt.Log";
            string spath = System.AppDomain.CurrentDomain.BaseDirectory + @"\" + DateTime.Now.ToString("yyyy") + @"\GetInterupt" + DateTime.Now.ToString("MM") + ".Log";
            if (!FileC.IsExistFile(spath))
            {
                FileC.CreateDirectory(FileC.GetDirectoryName(spath));
                FileC.CreateFile(spath);
                FileC.WriteText(spath1, "");
            }
            FileC.AppendText(spath, log + "\r\n");
            FileC.AppendText(spath1, log + "\r\n");
        }

        #endregion

    }
}



    

相关实践学习
MongoDB数据库入门
MongoDB数据库入门实验。
快速掌握 MongoDB 数据库
本课程主要讲解MongoDB数据库的基本知识,包括MongoDB数据库的安装、配置、服务的启动、数据的CRUD操作函数使用、MongoDB索引的使用(唯一索引、地理索引、过期索引、全文索引等)、MapReduce操作实现、用户管理、Java对MongoDB的操作支持(基于2.x驱动与3.x驱动的完全讲解)。 通过学习此课程,读者将具备MongoDB数据库的开发能力,并且能够使用MongoDB进行项目开发。 &nbsp; 相关的阿里云产品:云数据库 MongoDB版 云数据库MongoDB版支持ReplicaSet和Sharding两种部署架构,具备安全审计,时间点备份等多项企业能力。在互联网、物联网、游戏、金融等领域被广泛采用。 云数据库MongoDB版(ApsaraDB for MongoDB)完全兼容MongoDB协议,基于飞天分布式系统和高可靠存储引擎,提供多节点高可用架构、弹性扩容、容灾、备份回滚、性能优化等解决方案。 产品详情: https://www.aliyun.com/product/mongodb
相关文章
|
10天前
|
存储 SQL NoSQL
什么是 MongoDB,为什么它是当今最受欢迎的数据库之一?
什么是 MongoDB,为什么它是当今最受欢迎的数据库之一?
|
12天前
|
JSON NoSQL MongoDB
理解Nosql数据库的mongodb
【5月更文挑战第5天】MongoDB是2009年发布的一款通用型NoSQL数据库,结合了关系模型和NoSQL的优点,适用于各种现代应用。其特点包括图形界面、数据服务、云基础设施集成(AWS, Azure, Google Cloud)。它具备全面的查询能力、ACID事务、可调整的一致性保证,并有多语言驱动及工具,可在任何地方运行。
77 4
|
12天前
|
存储 NoSQL MongoDB
MongoDB数据库转换为表格文件的Python实现
MongoDB数据库转换为表格文件的Python实现
49 0
|
12天前
|
存储 NoSQL 关系型数据库
Percona XtraBackup是否支持MongoDB数据库备份?
【5月更文挑战第13天】Percona XtraBackup是否支持MongoDB数据库备份?
41 1
|
8天前
|
存储 NoSQL MongoDB
使用mongodb数据库实例
【5月更文挑战第9天】MongoDB中的集合类似关系数据库的表,但不强制模式,允许嵌入式文档以实现更灵活的数据布局。安装MongoDB在Ubuntu上涉及添加源列表和更新,CentOS则需创建配置文件。MongoDB支持备份和恢复,以及全文搜索。其灵活模式和动态模式减少了开发中的复杂性,但并非无模式,大部分数据仍具结构化特点。
86 2
|
12天前
|
NoSQL atlas MongoDB
Nosql数据库MongoDB的使用场景
【5月更文挑战第5天】 MongoDB是全球性的多云数据库,可在私有、公共和混合云中运行,提供高可用性、扩展性和合规性。 安全特性包括认证、授权、审计、网络隔离和加密。可提供跨云操作、可视化工具、搜索功能和数据湖支持,适用于现代应用开发,包括边缘数据处理。
45 1
|
12天前
|
存储 NoSQL 关系型数据库
【MongoDB 专栏】MongoDB 与传统关系型数据库的比较
【5月更文挑战第10天】本文对比了MongoDB与传统关系型数据库在数据模型、存储结构、扩展性、性能、事务支持、数据一致性和适用场景等方面的差异。MongoDB以其灵活的文档模型、优秀的扩展性和高性能在处理非结构化数据和高并发场景中脱颖而出,而关系型数据库则在事务处理和强一致性上更具优势。两者各有适用场景,选择应根据实际需求来定。随着技术发展,两者正相互融合,共同构建更丰富的数据库生态。
【MongoDB 专栏】MongoDB 与传统关系型数据库的比较
|
12天前
|
存储 NoSQL 关系型数据库
MongoDB非关系型数据库实战
【5月更文挑战第6天】MongoDB,流行的NoSQL数据库,以其灵活的数据模型和高性能备受青睐。本文介绍了MongoDB的基础,包括文档型数据库特性、安装配置、数据操作。通过电商订单管理的实战案例,展示了MongoDB在处理复杂数据结构和大规模数据时的优势,适用于电商、游戏、视频直播等场景。MongoDB的索引、全文搜索和地理空间功能进一步增强了其实用性。注意性能优化和扩展性以确保系统稳定性和可靠性。
|
12天前
|
弹性计算 NoSQL Shell
一键安装 MongoDB 数据库脚本
【4月更文挑战第29天】
21 4
|
12天前
|
NoSQL MongoDB 数据库
MongoDB数据恢复—MongoDB数据库文件被破坏的数据恢复案例
服务器数据恢复环境: 一台Windows Server操作系统服务器,服务器上部署MongoDB数据库。 MongoDB数据库故障&检测: 工作人员在未关闭MongoDB数据库服务的情况下,将数据库文件拷贝到其他分区。拷贝完成后将原MongoDB数据库所在分区进行了格式化操作,然后将数据库文件拷回原分区,重新启动MongoDB服务,服务无法启动。

热门文章

最新文章