MyCaffeStreamDatabase.cs

using MyCaffe.basecode;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
 
namespace MyCaffe.db.stream
{
    public partial class MyCaffeStreamDatabase : Component, IXStreamDatabase
    {
        Log m_log;
        IXQuery m_iquery;
        List<IXCustomQuery> m_rgCustomQueryToAdd = new List<IXCustomQuery>();
 
        public MyCaffeStreamDatabase(Log log)
        {
            m_log = log;
            InitializeComponent();
        }
 
        public MyCaffeStreamDatabase(IContainer container)
        {
            container.Add(this);
 
            InitializeComponent();
        }
 
        private void dispose()
        {
            m_iquery.Shutdown();
        }
 
        public void Initialize(QUERY_TYPE qt, string strSchema)
        {
            if (qt == QUERY_TYPE.SYNCHRONIZED)
            {
                PropertySet ps = new PropertySet(strSchema);
                int nQueryCount = ps.GetPropertyAsInt("QueryCount", 0);
                DateTime dtStart = ps.GetPropertyAsDateTime("Start");
                int nTimeSpanInMs = ps.GetPropertyAsInt("TimeSpanInMs");
                int nSegmentSize = ps.GetPropertyAsInt("SegmentSize");
                int nMaxCount = ps.GetPropertyAsInt("MaxCount");
                
                m_iquery = new MgrQueryTime(nQueryCount, dtStart, nTimeSpanInMs, nSegmentSize, nMaxCount, strSchema, m_rgCustomQueryToAdd);
            }
            else
            {
                m_iquery = new MgrQueryGeneral(strSchema, m_rgCustomQueryToAdd);
            }
        }
 
        public void Shutdown()
        {
            m_iquery.Shutdown();
        }
 
        public void AddDirectQuery(IXCustomQuery iqry)
        {
            m_rgCustomQueryToAdd.Add(iqry);
        }
 
        public SimpleDatum Query(int nWait)
        {
            return m_iquery.Query(nWait);
        }
 
        public int[] QuerySize()
        {
            List<int> rg = m_iquery.GetQuerySize();
 
            if (rg == null)
                return null;
 
            return rg.ToArray();
        }
 
        public Dictionary<string, float> QueryInfo()
        {
            return m_iquery.QueryInfo();
        }
 
        public void Reset(int nStartOffset = 0)
        {
            m_iquery.Reset(nStartOffset);
        }
 
        public byte[] ConvertOutput(float[] rg, out string type)
        {
            return m_iquery.ConvertOutput(rg, out type);
        }
    }
}