《连载 | 物联网框架ServerSuperIO教程》- 15．数据持久化接口的使用。附：3.2发布与版本更新说明。

2022-10-29 18:41:40

ServerSuperIO 3.2更新说明：

1.增加IDataPersistence数据持久化接口，可以以多种形式存储设备的参数和实时数据。现在仅支持Xml序列化的方式，后期会支持MongoDB、influxdb和实时数据库（类似PI）等。
2.增加r配制参数ComNullInterval和NetNullInterval等，轮询模式下，串口和网络IO通道为空的情况下，中断时间间隔。

下载地址：http://pan.baidu.com/s/1c1ZZLOO

更新说明地址：http://www.bmpj.net/thread-36-1-1.html

15．数据持久化接口的使用... 2

15.1 概述... 2

15.2 定义IDataPersistence数据持久化接口... 2

15.3 使用IDataPersistence数据持久化接口... 5

15．数据持久化接口的使用

15.1 概述

ServerSuperIO 3.2版本以前，设备数据仅支持Xml序列化的方式，如果以其他方式存储数据，那么只能把持久化操作写在设备驱动中，本质上失去了模块化的灵活性。3.2 版本以后增加了数据持久化接口，方便支持多种形式存储设备的参数数据和实时数据，3.2版本里现在仅支持Xml序列化的方式，后期会支持MongoDB、influxdb和实时数据库（类似PI）等

15.2 定义IDataPersistence数据持久化接口

1.接口定义

凡是涉及到不同数据存储方式的都可以继承IDataPersistence接口，具体代码定义发下：

public interface IDataPersistence

    {

        /// <summary>

        /// 连接数据源

        /// </summary>

        void Connect();

        /// <summary>

        /// 选择数据对象

        /// </summary>

        /// <param name="devid"></param>

        /// <param name="objType"></param>

        /// <returns></returns>

        object Select(string devid, Type objType);

        /// <summary>

        /// 插入数据对象

        /// </summary>

        /// <param name="devid"></param>

        /// <param name="obj"></param>

        void Insert(string devid, object obj);

        /// <summary>

        /// 更新数据对象

        /// </summary>

        /// <param name="devid"></param>

        /// <param name="obj"></param>

        void Update(string devid, object obj);

        /// <summary>

        /// 删除数据对象

        /// </summary>

        /// <param name="devid"></param>

        /// <param name="obj"></param>

        void Delete(string devid,object obj);

        /// <summary>

        /// 判断是否存在

        /// </summary>

        /// <param name="devid"></param>

        /// <param name="obj"></param>

        /// <returns></returns>

        bool Exist(string devid,object obj);

}

2.接口实现形式

如果以MongoDB、influxdb和实时数据库，那么都可以继承IDataPersistence接口，下面以Xml存储数据为例，代码如下：

public class XmlPersistence:IXmlPersistence

    {

        public void Connect()

        {}

        public object Select(string devid, Type objType)

        {

            string path = GetSavePath(devid,objType);

            return SerializeUtil.XmlDeserailize(path, objType);

        }

        public void Insert(string devid, object obj)

        {

            string path = GetSavePath(devid,obj.GetType());

            SerializeUtil.XmlSerialize(path, obj);

        }

        public void Update(string devid, object obj)

        {

            this.Insert(devid, obj);

        }

        public void Delete(string devid,object obj)

        {

            string path = GetSavePath(devid,obj.GetType());

            if (System.IO.File.Exists(path))

            {

                System.IO.File.Delete(path);

            }

        }

        public bool Exist(string devid, object obj)

        {

            string path = GetSavePath(devid, obj.GetType());

            return System.IO.File.Exists(path);

        }

        ......

    }

15.3 使用IDataPersistence数据持久化接口

ServerSuperIO框架二次开发的设备驱动涉及到两类数据：设备参数和实时数据。这两类数据都对应着基类：DeviceParameter和DeviceDynamic。每个设备驱动可能对应着不同的设备参数（系数等）和实时数据（温度、湿度、流量等），因为涉及到不同的硬件设备和传感器。可以分别继承DeviceParameter和DeviceDynamic两个基类，这两个基类都具有InitDataPersistence(IDataPersistence dataPersistence)接口，实现不同的数据持久化存储接口，并进行Save、Load和Delete操作。

具体定义方法，如下代码：

public class DeviceDyn:DeviceDynamic

{

        public DeviceDyn() : base()

        {

             this.InitDataPersistence(new XmlPersistence());

        }

        public override string GetAlertState()

        {

            throw new NotImplementedException("无报警信息");

        }

        public float Flow{set;get;}

}

具体使用方法，如下代码：

DeviceDyn dyn=new DeviceDyn();

 dyn.Save();  //保存

 dyn.Load();  //加载

 dyn.Delete();//删除

注：this.InitDataPersistence()不进行此操作，默认使用XmlPersistence进行数据持久化。

1.[连载]《C#通讯（串口和网络）框架的设计与实现》

2.[开源]C#跨平台物联网通讯框架ServerSuperIO（SSIO）介绍

2.应用SuperIO（SIO）和开源跨平台物联网框架ServerSuperIO（SSIO）构建系统的整体方案

3.C#工业物联网和集成系统解决方案的技术路线（数据源、数据采集、数据上传与接收、ActiveMQ、Mongodb、WebApi、手机App）

5.ServerSuperIO开源地址：https://github.com/wxzz/ServerSuperIO

物联网&集成技术(.NET) QQ群：

码农公寓

15．数据持久化接口的使用

15.1 概述

15.2 定义IDataPersistence数据持久化接口

15.3 使用IDataPersistence数据持久化接口

相关文章