CNAS/CnasSynchronusDAL/Service/KingbaseDBService.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Entity;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using CnasSynchronousCommon;
using CnasSynchronusIDAL;
using CnasSynchrousModel;

namespace CnasSynchronusDAL
{
    public class KingbaseDBService : IKingbaseDBService
    {
        public bool TestConnect(string strHost, string strName, string strUser, string strPwd, string strPort)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(strHost, strPort, strName, strUser, strPwd);
            return mySQLBase.LinkCnasTest();
        }

        public Dictionary<string, DataTable> GetInstrumentData(KingbaseOpenParams t)
        {
            KingbaseDAL mySQL = new KingbaseDAL();
            mySQL.CreateConnectString(t.StrHost, t.StrPort, t.StrServer, t.StrUser, t.StrPwd);
            return mySQL.GetAllTableNameAndStructure(t.StrServer);
        }

        public DataTable GetInstrumentDataByDate(KingbaseOpenParams t, ConditionParams u)
        {
            KingbaseDAL mySQL = new KingbaseDAL();
            mySQL.CreateConnectString(t.StrHost, t.StrPort, t.StrServer, t.StrUser, t.StrPwd);
            return mySQL.GetDataByDateColumn(
                t.StrServer,
                t.autoSql?.KingbaseViewName,
                t.autoSql?.KingbaseViewSql,
                u.TableName, 
                u.DateColumn,
                u.DateValue);
        }

        public DataTable GetInstrumentDataStruct(KingbaseOpenParams t, ConditionParams u)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(t.StrHost, t.StrPort, t.StrServer, t.StrUser, t.StrPwd);
            return mySQLBase.GetTableStruct(
                u.TableName,
                t.autoSql.KingbaseViewName,
                t.autoSql.KingbaseViewSql
                );
        }

        public DataTable GetAllCNASTablesName(DataBaseInfo dataBase)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.GetTableNames(dataBase.DBName);
        }

        public DataTable GetCNASTablesStruct(string strTableName, DataBaseInfo dataBase)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.GetTableStruct(strTableName,"","");
        }

        public int InsertDataToCNASTable(DataTable dt, DataBaseInfo dataBase, List<SyncParamasInfo> syncParamasInfos, string strInstrumentColumn,List<CnasConditionMapValue> lstFixedValue = null)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.InsertCnasData(dt, syncParamasInfos, lstFixedValue, strInstrumentColumn);
        }

        public DataTable GetCNASTableTypeLenth(string strTableName, DataBaseInfo dataBase)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.GetTableTypeAndLenth(strTableName);
        }

        public DataTable GetLoginNameByPwd(DataBaseInfo dataBase, string strUserName, string strPwd)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            strPwd = EncryptionOperation.GetMD5Hash(strPwd);
            AppLog.Info(strPwd);
            return mySQLBase.GetLoginNameByPwd(strUserName, strPwd);
        }

        public bool CheckMacMessage(DataBaseInfo dataBase, string strMac)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.CheckMacMessage(strMac);
        }

        public bool CheckMacMessage(string strConnectionString, string strMac)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(strConnectionString);
            return mySQLBase.CheckMacMessage(strMac);
        }

        public string GetMaxTimeByTableName(DataBaseInfo dataBase, string strTableName, string strDateColumn, string strInstrumentColumn, string strInstrumentValue)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
            return mySQLBase.GetMaxTimeByTableName(strTableName, strDateColumn, strInstrumentColumn, strInstrumentValue);
        }


        /// <summary>
        /// 获取某个表的数据
        /// </summary>
        /// <param name="dataBase"></param>
        /// <param name="strSql"></param>
        /// <returns></returns>
        public DataTable GetTableData(DataBaseInfo dataBase, string strSql)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);
   
            return mySQLBase.GetTableData(strSql);
        }

        /// <summary>
        /// 插入某个表的数据
        /// </summary>
        /// <param name="dataBase"></param>
        /// <param name="strSql"></param>
        /// <returns></returns>
        public bool InsertTableData(DataBaseInfo dataBase, string strSql)
        {
            KingbaseDAL mySQLBase = new KingbaseDAL();
            mySQLBase.CreateConnectString(dataBase.DBHost, dataBase.DBPort, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd);

            return mySQLBase.InsertTableData(strSql);
        }
     
    }
}