从数据库中读取数据，创建XML文件并更新维护XML

    public class OperateXML{/// <summary>/// 文件全路径/// </summary>private  string fullFilePath;private string DbName= "SpiderWeb";private string DbCollectionName= "Data";MongoClient _Client = null;public FilterDefinitionBuilder<BsonDocument> Filter { get; private set; }public ProjectionDefinitionBuilder<BsonDocument> Projection { get; private set; }/// <summary>/// 文件方式/// </summary>private FileInfo InfoFile{get{return new FileInfo(fullFilePath);}}/// <summary>/// 添加XML节点/// </summary>/// <param name="item"></param>public void  AddItem(DataBaseItem item){XmlDocument xmlDoc = new XmlDocument();xmlDoc.Load(fullFilePath);XmlNode root = xmlDoc.SelectSingleNode("ArrayOfDataBaseItem");XmlElement xe = xmlDoc.CreateElement("DataBaseItem");//创建一个具有指定名称的子节点Type t = item.GetType();foreach(PropertyInfo ppi in  t.GetProperties()){object value = ppi.GetValue(item, null);string name = ppi.Name;XmlElement xmlsub = xmlDoc.CreateElement(name);//创建一个具有指定名称的元素if (value == null)value = string.Empty;xmlsub.InnerText = value.ToString();//设置该元素的值xe.AppendChild(xmlsub);//将该元素添加到item子节点的尾部}root.AppendChild(xe);//将创建的item子节点添加到items节点的尾部xmlDoc.Save(fullFilePath);//保存xml文件，}/// <summary>/// 修改XML节点/// </summary>/// <param name="item"></param>public void AlterItem(DataBaseItem item,string NodeName){XmlDocument xmlDoc = new XmlDocument();xmlDoc.Load(this.fullFilePath);XmlNode xn = xmlDoc.SelectSingleNode("ArrayOfDataBaseItem");XmlNodeList xnl = xn.ChildNodes;if(xnl.Count>0){int i = 0;foreach (XmlElement e in xnl[0].ChildNodes){if (e.Name == NodeName){break;}i++;}foreach (XmlNode xnf in xnl){XmlNodeList xnf1 = xnf.ChildNodes;if (xnf1[i].InnerText == item.SpiderName){Type t = item.GetType();int j = 0;foreach (PropertyInfo ppi in t.GetProperties()){object value = ppi.GetValue(item, null);xnf1[j].InnerText = value.ToString();//设置该元素的值 j++;}}}xmlDoc.Save(this.fullFilePath);//再一次强调 ，一定要记得保存的该XML文件}}/// <summary>/// 删除指定的XML节点/// </summary>/// <param name="spiderName"></param>private void DelXml(string  spiderName,string NodeName){XmlDocument xmlDoc = new XmlDocument();xmlDoc.Load(this.fullFilePath);XmlNodeList xnl = xmlDoc.SelectSingleNode("ArrayOfDataBaseItem").ChildNodes;if (xnl.Count>0){int i = 0;foreach (XmlElement e in xnl[0].ChildNodes){if (e.Name == NodeName){break;}i++;}foreach (XmlNode xn in xnl){XmlNodeList xnchilds = xn.ChildNodes;if (xnchilds[i].InnerText == spiderName){xn.ParentNode.RemoveChild(xn);}}xmlDoc.Save(this.fullFilePath);}}private DataBaseItem GetDataBaseItem(string spiderName,string NodeName){var item = new DataBaseItem();return item;}/// <summary>/// 获取数据库信息/// </summary>/// <returns></returns>public List<DataBaseItem> GetDBsInfoFromXML(){var dataBaseList = new List<DataBaseItem>();if (InfoFile.Exists){XmlSerializer xml = new XmlSerializer(dataBaseList.GetType());using (Stream s = InfoFile.OpenRead()){try{dataBaseList = xml.Deserialize(s) as List<DataBaseItem>;}catch(Exception e){Console.WriteLine(e.Message);}}}return dataBaseList;}/// <summary>/// 获取数据库信息/// </summary>/// <returns></returns>public List<DataBaseItem> GetDBsInfoFromMongoDB(){var dataBaseList = new List<DataBaseItem>();var SpiderDataBase = _Client.GetDatabase(DbName);var SpiderColletion = SpiderDataBase.GetCollection<BsonDocument>(DbCollectionName);//var Spiders = SpiderColletion.Find(Filter.Empty).Project(Projection.As<SpiderRunEntity>()).ToList();var Filter = Builders<BsonDocument>.Filter;var builder = Builders<BsonDocument>.Sort;var sort = builder.Descending("_id");IAsyncCursor<BsonDocument> Cursor;try{Cursor = SpiderColletion.Find(Filter.Empty).Sort(sort).ToCursor();}catch (Exception e){Console.WriteLine(e.Message);return null;}while (Cursor.MoveNext()){foreach (var Document in Cursor.Current){DataBaseItem item = new DataBaseItem();foreach (var val in Document.Elements){Type Ts = item.GetType();object v = Convert.ChangeType(val.Value, Ts.GetProperty(val.Name).PropertyType);Ts.GetProperty(val.Name).SetValue(item, v, null);}dataBaseList.Add(item);}}return dataBaseList;}/// <summary>/// 生成Xml文件/// </summary>private void CreateXmlFile(List<DataBaseItem> dataBases){XmlSerializer xmls = new XmlSerializer(dataBases.GetType());using (Stream s = InfoFile.OpenWrite()){xmls.Serialize(s, dataBases);}}/// <summary>/// 从数据库中获取数据，更新XML文件/// </summary>private void UpdateXmlFile(){var databaseListMongodb = GetDBsInfoFromMongoDB();try{Dictionary<string, DataBaseItem> databaseDicXML = GetDBsInfoFromXML().ToDictionary(key => key.SpiderName, value => value);foreach (var db in databaseListMongodb){if (!databaseDicXML.ContainsKey(db.SpiderName))AddItem(db);}}catch(Exception e){Console.WriteLine(e.Message);}}/// <summary>/// 创建XML文件/// </summary>private void CreateXmlFile(){if(!File.Exists( this.fullFilePath)){List<DataBaseItem> dataBaseList = new List<DataBaseItem>();XmlSerializer xmls = new XmlSerializer(dataBaseList.GetType());using (Stream s = InfoFile.OpenWrite()){xmls.Serialize(s, dataBaseList);}}}public OperateXML(string filename,string dbName,string collectionName){_Client = new MongoClient("mongodb://192.168.106.56:27017");DbName = dbName;DbCollectionName=collectionName;string appStartPath = System.IO.Path.GetDirectoryName(System.Diagnostics.Process.GetCurrentProcess().MainModule.FileName);StringBuilder builder = new StringBuilder();builder.Append(appStartPath);builder.Append("\\DatebaseXML\\");System.IO.DirectoryInfo directoryInfo = new DirectoryInfo(builder.ToString());if (!directoryInfo.Exists){directoryInfo.Create();//创建一个}builder.Append(filename);this.fullFilePath = builder.ToString();CreateXmlFile();UpdateXmlFile();}public OperateXML(){_Client = new MongoClient("mongodb://192.168.106.56:27017");string appStartPath = System.IO.Path.GetDirectoryName(System.Diagnostics.Process.GetCurrentProcess().MainModule.FileName);StringBuilder builder = new StringBuilder();builder.Append(appStartPath);builder.Append("\\DatebaseXML\\");System.IO.DirectoryInfo directoryInfo = new DirectoryInfo(builder.ToString());if (!directoryInfo.Exists){directoryInfo.Create();//创建一个}builder.Append("DateBasesXml.xml");this.fullFilePath = builder.ToString();CreateXmlFile();UpdateXmlFile();}}public class DataBaseItem{public string _id { get; set; }public string SpiderName { get;  set; }public string WebName { get;  set; }public DateTime LastDateTime { get;  set; }public int RunningStatus { get;  set; }public string IndexUrl { get;  set; }public string Describe { get;  set; }}

从数据库中读取数据，创建XML文件并更新维护XML相关推荐

基于JDBC从数据库中读取数据，在百度地图批量标注地点
基于JDBC从数据库中读取数据,在百度地图批量标注地点一.相关技术 JSP,JDBC,JSON,JS,百度地图API 二.基于JDBC从数据库读取数据见"JSP基于JDBC操作MSSQL ...
我刚做的一个TreeView的CheckBox进行选中插入数据库，从数据库中读取数据后让CheckBox勾选的代码!...
#region 绑定角色 /// <summary> /// 绑定权限信息 /// </summary> protected void Bind ...
python读文件和写文件-python开发--从文件中读取数据和写入文件
#! /usr/bin/env python -*- coding:utf-8 -*- """ @Author:gcan @Email:1528667112@qq.com ...
java实现k-means算法（用的鸢尾花iris的数据集，从mysq数据库中读取数据）
k-means算法又称k-均值算法,是机器学习聚类算法中的一种,是一种基于形心的划分方法,其中每个簇的中心都用簇中所有对象的均值来表示.其思想如下: 输入: k:簇的数目: D:包含n个对象的数据集. ...
【存储过程】从数据库中读取数据保存到文件中
2019独角兽企业重金招聘Python工程师标准>>> 由于初期规划不好,项目管理的action都存入到数据库中了,而实际上应该以配置文件的形式保存的,所以现在想改过来.一条条复制是 ...
mysql数据库中插入数据并进行自动迭代更新
问题我们知道在数据库中保证数据的唯一性是十分必要的,这也就是有主键的一个原因,但是数据肯定是需要更新的,当然我们可以按照日期或者其他维度进行数据的永不冲突的更新.但是还有一种情况下需要我们迭代的去更 ...
使用python实现微博评论分词与关键词提取（从MySQL数据库中读取数据）
一.实验环境 (1)Windows操作系统: (2)PyCharm 2019.1. (3)数据库用户名为 root,密码为 123456. (4) 学校机房电脑,带有mysql 二.获取数据库信息 ...
R从文件中读取数据，输出文件
看了几天的书,终于到这一步了,说实话,用R来做统计,很少有人手动的去输入那些数字,肯定是从别的地方导入的,我们用来处理就可以了,所以到这里才算是真正的入门,前面都是做基础的练手. 我学习R从<R ...
html读mysql数据_html从数据库中读取数据
展开全部 html只能通过ajax接口跟后台数据库接口通信,然后取出来的数据在页面上显636f70793231313335323631343130323136353331333337626135示. ...
PHP从数据库中读取数据并打印
示例如下: $con=mysql_connect('localhost','root','');//数据库信息 mysql_select_db('shop');//数据库名 mysql_query(& ...

从数据库中读取数据，创建XML文件并更新维护XML

从数据库中读取数据，创建XML文件并更新维护XML相关推荐

最新文章

热门文章