using System.Collections.Generic;
using System.Data;
using CnasSynchronusDAL;
using CnasSynchronusIDAL;
using CnasSynchrousModel;

namespace CnasSynchronusClient
{
    internal class OracleCnasDataOperation : ICnasDataOperation
    {
        public IOracleService oracleDatabaseService
        {
            get
            {
                return new OracleDBService();
            }
        }

        public bool CheckMacMessage(DataBaseInfo dataBase, string strMac)
        {
            return oracleDatabaseService.CheckMacMessage(dataBase, strMac);
        }

        public DataTable GetAllCNASTablesName(DataBaseInfo dataBase)
        {
            return oracleDatabaseService.GetAllCNASTablesName(dataBase);
        }

        public DataTable GetCNASTablesStruct(string strTableName, DataBaseInfo dataBase)
        {
            return oracleDatabaseService.GetCNASTablesStruct(strTableName, dataBase);
        }

        public DataTable GetCNASTableTypeLenth(string strTableName, DataBaseInfo dataBase)
        {
            return oracleDatabaseService.GetCNASTableTypeLenth(strTableName, dataBase);
        }

        public DataTable GetLoginNameByPwd(DataBaseInfo dataBase, string strUserName, string strPwd)
        {
            return oracleDatabaseService.GetLoginNameByPwd(dataBase, strUserName, strPwd);
        }

        public string GetMaxTimeByTableName(DataBaseInfo dataBase, string strTableName, string strDateColumn, string strInstrumentColumn, string strInstrumentValue)
        {
            return oracleDatabaseService.GetMaxTimeByTableName(dataBase, strTableName, strDateColumn, strInstrumentColumn, strInstrumentValue);
        }

        public DataTable GetTableData(DataBaseInfo dataBase, string strSql)
        {
            throw new System.NotImplementedException();
        }

        public int InsertDataToCNASTable(DataTable dt, DataBaseInfo dataBase, List<SyncParamasInfo> syncParamasInfos, string strInstrumentColumn, List<CnasConditionMapValue> lstFixedValue = null)
        {
            return oracleDatabaseService.InsertDataToCNASTable(dt, dataBase, syncParamasInfos, strInstrumentColumn, lstFixedValue);
        }

        public bool InsertTableData(DataBaseInfo dataBase, string strSql)
        {
            throw new System.NotImplementedException();
        }

        public bool TestConnect(DataBaseInfo dataBase)
        {
            return oracleDatabaseService.TestConnect(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
        }
    }
}