dataaccess.cs

主要用语管理系统中的sql数据库备份和数据库恢复,可以完全备份和差异备份

                str = Convert.ToString(cmd.ExecuteScalar()).ToString();
            }
            close();
            return str;
        }

        /// <summary>
        /// 截取字符串
        /// </summary>
        /// <param name="Str">要处理字符串</param>
        /// <param name="StrLen">截取长度</param>
        /// <returns></returns>
        public string CutStr(string Str, int StrLen)
        {
            if (Str != null && Convert.IsDBNull(StrLen) == false)
            {
                int t = 0;
                for (int i = 0; i <= StrLen; i++)
                {
                    if (t >= StrLen)
                    {
                        Str = Str.Substring(0, i) + "…";
                        break;
                    }
                    else
                    {
                        if (i >= Str.Length)
                        {
                            Str = Str.Substring(0, i);
                            break;
                        }
                    }
                    int c = Math.Abs((int)Str[i]);
                    if (c > 255)
                    {
                        t += 2;
                    }
                    else
                    {
                        t++;
                    }
                }
            }
            else
            {
                Str = null;
            }
            return Str;
        }

        /// <summary>
        /// 获得某个字符串在另个字符串第一次出现时前面所有字符
        /// </summary>
        /// <param name="strOriginal">要处理字符</param>
        /// <param name="strSymbol">符号</param>
        /// <returns>返回值</returns>
        public string GetSecondStr(string strOriginal, string strSymbol)
        {
            string[] arr = strOriginal.Split(',');

            strOriginal = arr[1];
            return strOriginal;
        }

        public int GetStrAppearTime(string strOriginal, string strSymbol)
        {
            return strOriginal.Length - strOriginal.Replace(strSymbol, "").Length;
        }

        public bool WriteReport(string strOmtID,  string RecData,string type,string stel)
        {
            bool WriteReport = false;

            string strSQL = "";

            strSQL = "insert into Omt_Report values('" + Convert.ToString(strOmtID) + "', '" + Convert.ToString(RecData) + "','" + Convert.ToString(type) + "',  '" + DateTime.Now + "','"+stel+"')";
            if (ExecuteSQL(strSQL))
            {
                WriteReport = true;
            }
            else
            {
                WriteReport = false;
            }
            return WriteReport;
        }
    
        /// <summary>
        /// 设置参数记录
        /// </summary>
        /// <param name="strEmpId">操作ID</param>
        /// <param name="Operation_ObjectID">操作对象字符串：0411 0422（04110422）</param>
        /// <param name="Parametar">设置参数</param>
        /// <returns></returns>
        public bool WriteSetParametr(string strtype, string omtcode, string strObject, string stel, string netsign, string setdatetime,string omtID)
        {
            bool WriteSetParametr = false;

            string strSQL = "";

            strSQL = "insert into OmtSet_parameter values('" + Convert.ToString(strtype) + "', '" + Convert.ToString(omtcode) + "','" + Convert.ToString(strObject) + "', '" + Convert.ToString(stel) + "','" + netsign + "','" + DateTime.Now + "'," + omtID + ")";
            if (ExecuteSQL(strSQL))
            {
                WriteSetParametr = true;
            }
            else
            {
                WriteSetParametr = false;
            }
            return WriteSetParametr;
        }

        public bool WriteAlarm(string omtID, string strObjectP, string strDateP,string stel,string type)
        {
            bool WriteSetParametr = false;

            string strSQL = "";

            strSQL = "insert into OmtTimesAlarm values('" + Convert.ToString(omtID) + "', '" + Convert.ToString(strObjectP) + "','" + Convert.ToString(strDateP) + "','" + stel + "','"+type+"')";
            if (ExecuteSQL(strSQL))
            {
                WriteSetParametr = true;
            }
            else
            {
                WriteSetParametr = false;
            }
            return WriteSetParametr;
        }
        public bool WritePollRecord(string omtID, string ComType, string strRevc, string sTel, string EQID, string Pollresult, string strDateP, int sFlag, string Cmd,string dt,string ID)
        {
            bool WritePollRecord = false;

            string strSQL = "";
            if (sFlag == 0)
            {
                strSQL = "insert into OmtPollRecord(Omtcode,ComType,Parameter,TelNumber,EQID,SetDate,SendResult,NetSign,omtid) values('" + Convert.ToString(omtID) + "','" + Convert.ToString(ComType) + "','" + Convert.ToString(strRevc) + "','" + Convert.ToString(sTel) + "','" + Convert.ToString(EQID) + "','" + Convert.ToString(strDateP) + "','" + Convert.ToString(Pollresult) + "','" + Cmd + "',"+ID+")";
            }
            else if (sFlag == 1)
            {
                strSQL = "update OmtPollRecord set Poll_Result='" + Convert.ToString(Pollresult) + "'  where OmtCode='" + omtID + "' and TelNumber='" + sTel + "' and setdate>'"+dt+"' ";
            }
            else
            {
                strSQL = "update OmtPollRecord set Poll_Result='" + Convert.ToString(Pollresult) + "',Parameter='" + Convert.ToString(strRevc) + "'   where OmtCode='" + omtID + "' and TelNumber='" + sTel + "' and NetSign='" + Cmd + "' and setdate>'" + dt + "'";
            }
            if (ExecuteSQL(strSQL))
            {
                WritePollRecord = true;
            }
            else
            {
                WritePollRecord = false;
            }
            return WritePollRecord;
        }
        /// <summary>
        /// 日志记录
        /// </summary>
        /// <param name="strEmpID">操作人员记录</param>
        /// <param name="strOmtID">站点id</param>
        /// <param name="strOPerateType">操作类型</param>
        /// <param name="strResult">操作结果</param>
        /// <returns></returns>
        ///
        ///使用方法 例如: WriteLog("用户登录信息","直放站","uuuu","" );
        ///
        public bool WriteLog(string strEmpID, string strOmtID,string strOPerateType,string strResult)
        {
            bool WriteLog = false;   
            string strSQL = "";

            strSQL = "insert into Operate_Log values(" + (int.Parse(this.GetMaxId("id", "Operate_Log").ToString()) + 1) + ",'" + Convert.ToString(strEmpID) + "', '" + Convert.ToString(strOmtID) + "', '" + Convert.ToString(strOPerateType) + "', '" + Convert.ToString(strResult) + "',  '" + DateTime.Now + "','" + DateTime.Now + "')";
            if (ExecuteSQL(strSQL))
            {
                WriteLog = true;
            }
            else
            {
                WriteLog = false;
            }
            return WriteLog;

        }

        public bool UpdateParamater(string strOmtID, string strResult)
        {
            bool UpdateParamater = false;
            string strSQL = "";
            if (GetRsCount(" OmtParameter where omtid=" + strOmtID + "") > 0)
            {
                strSQL = "update OmtParameter set ObjList='" + strResult + "' where OmtID=" + strOmtID + "";

            }
            else
            {
                strSQL = "insert into OmtParameter values('" + strOmtID + "', '" + Convert.ToString(strResult) + "')";
            }
            if (ExecuteSQL(strSQL))
            {
                UpdateParamater = true;
            }
            else
            {
                UpdateParamater = false;
            }
            return UpdateParamater;

        }

        public bool UpdateCode(string strOmtid,string code)
        {
            bool UpdateCode = false;
            string strSQL = "";
            strSQL = "update Omt_Name set omt_code='"+code+"' where id="+strOmtid;
            if (ExecuteSQL(strSQL))
            {
                UpdateCode=true;
            }
            else
            {
                UpdateCode = false;
            }
            return UpdateCode;
        }
        public bool UpdateID(string strOmtid, string id)
        {
            bool UpdateID = false;
            string strSQL = "";
            strSQL = "update Omt_Name set EqCode='" + id + "' where id=" + strOmtid;
            if (ExecuteSQL(strSQL))
            {
                UpdateID = true;
            }
            else
            {
                UpdateID = false;
            }
            return UpdateID;
        }
        public bool UpdateOmtEq(int intOmtID, string EqCode)
        {
            bool UpdateOmtEq = false;

            string strSQL = "";

            strSQL = "update Omt_name set eqcode='" + EqCode + "' where id=" + intOmtID;
            if (ExecuteSQL(strSQL))
            {
                UpdateOmtEq = true;
            }
            else
            {
                UpdateOmtEq = false;
            }
            return UpdateOmtEq;
        
        }
        /// <summary>
        /// 更新直放站站点号和设备号
        /// </summary>
        /// <param name="intOmtID">直放站ID</param>
        /// <param name="omtCode">直放站编号</param>
        /// <param name="EqCode">设备编号</param>
        /// <returns></returns>
        public bool UpdateOmtCode(int intOmtID, string omtCode)
        {
            bool UpdateOmtCode = false;

            string strSQL = "";

            strSQL = "update Omt_name set omt_code='" + omtCode + "' where id=" + intOmtID;
            if (ExecuteSQL(strSQL))
            {
                UpdateOmtCode = true;
            }
            else
            {
                UpdateOmtCode = false;
            }
            return UpdateOmtCode;

        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="strSQL">插入表</param>
        /// <returns></returns>
        public bool ExecuteSQL(string strSQL)
        {
            bool ExecuteSQL = false;
            open();
            SqlCommand cmd = new SqlCommand(strSQL, myConn);
            
            try
            {
                cmd.ExecuteNonQuery();
                myConn.Close();
                ExecuteSQL = true;
            }
            catch
            {
                ExecuteSQL = false;
            }
            finally
            {

                myConn.Dispose();
                cmd.Dispose();
            }

            return ExecuteSQL;
        }
 
     
	}
}