ccosearchfromdatabase.cs

很具有学习参考价值的OA办公自动化系统,完整源码.ＯＡｄｅ

using System;
using System.Data;
using System.Data.SqlClient;
using System.IO;

namespace MOAS
{
	/// <summary>
	/// CCoSearchFromDatabase 的摘要说明。
	/// </summary>
	public class CCoSearchFromDatabase
	{
        
	public CCoSearchFromDatabase()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}
  //根据传入的sql得到返回值DataSet
		public DataSet getDataSet(string strSql)
		{
          SqlConnection m_Connection=null;
			try
			{
				CCoOptionFile m_FileRead=new CCoOptionFile ("/AppProConfig/connectionStr.txt",0);
				m_Connection =new SqlConnection (m_FileRead.strLineText );
				m_Connection.Open ();
				SqlDataAdapter m_DataAdapter=new SqlDataAdapter (strSql,m_Connection);
				System.Data .DataSet m_DateSet=new DataSet ();
				m_DataAdapter.Fill (m_DateSet);
				return m_DateSet;
			}
			catch(Exception ex)
			{
				CCoOptionFile file=new CCoOptionFile();
				file.StartWrite(ex.ToString());         //产生异常后，把异常信息作为参数，调用StartWrite()，把错误信息写入指定的文本中；
			    return null;
			}
			finally
			{
			  m_Connection.Close ();
			}
   
   
		}
		public DataSet getDataSet(string[] strSql)
		{
           SqlConnection m_Connection=null;
			try
			{
				CCoOptionFile m_FileRead=new CCoOptionFile ("/AppProConfig/connectionStr.txt",0);
				m_Connection =new SqlConnection (m_FileRead.strLineText );
				m_Connection.Open ();
				SqlDataAdapter m_DataAdapter=new SqlDataAdapter (""+strSql[0]+"",m_Connection);
				System.Data .DataSet m_DateSet=new DataSet ();
				m_DataAdapter.Fill(m_DateSet,""+strSql[1]+"");
				return m_DateSet;
			}
			catch(Exception ex)
			{
				CCoOptionFile file=new CCoOptionFile();
				file.StartWrite(ex.ToString());         //产生异常后，把异常信息作为参数，调用StartWrite()，把错误信息写入指定的文本中；
			    return null;
			}
			finally
			{
			m_Connection.Close ();
			}
   
   
		}
	//根据传入的sql得到string[,]返回值
		public string[,] getList(string strSql)
		{
			SqlConnection m_Connection=null;
			try
			{
				//return all of the list by strArray
				CCoOptionFile m_FileRead=new CCoOptionFile ("/AppProConfig/connectionStr.txt",0);
				string s=m_FileRead.strLineText;

				 m_Connection =new SqlConnection (m_FileRead.strLineText );
				m_Connection.Open ();
				 SqlCommand myCommand = new SqlCommand(strSql,m_Connection);
				SqlDataReader  m_DataReader=myCommand.ExecuteReader ();
				int iDataCount=0;
				while(m_DataReader.Read())
				{
					iDataCount++;
				}
				m_DataReader.Close();
				m_DataReader=myCommand.ExecuteReader ();
				//save the counts of the colm
				string[,] m_String=new string [iDataCount,m_DataReader.FieldCount];
				if(iDataCount!=0)
				{
					for(int i=0;m_DataReader.Read();i++)
					{
						for(int j=0;j<m_DataReader.FieldCount;j++)
						{
							//save into strGetValue
							m_String[i,j]=m_DataReader.GetValue(j).ToString ();
						}
						//save into arryGetValue
					}
				}
				else
				{
					return null;
				}
			
				m_DataReader.Close ();
				myCommand.Dispose();
				return  m_String;
			}
			catch(Exception ex)
			{
				CCoOptionFile file=new CCoOptionFile();
				file.StartWrite(ex.ToString());         //产生异常后，把异常信息作为参数，调用StartWrite()，把错误信息写入指定的文本中；
				return null;
			}
			finally
			{
								m_Connection.Close ();
			}
		}
  
	//执行sql语句对数据库进行操作	
		public void Execute(string strSql)
		{
			SqlConnection m_Connection=null;
			try
			{
				CCoOptionFile m_FileRead=new CCoOptionFile ("/AppProConfig/connectionStr.txt",0);
				m_Connection =new SqlConnection (m_FileRead.strLineText );
				m_Connection.Open ();
				SqlCommand myCommand = new SqlCommand(strSql,m_Connection);
				myCommand.ExecuteNonQuery();
				myCommand.Dispose();

			}
			catch(Exception ex)
			{
				CCoOptionFile file=new CCoOptionFile();
				file.StartWrite(ex.ToString());         //产生异常后，把异常信息作为参数，调用StartWrite()，把错误信息写入指定的文本中；
			   
			}
			finally
			{
				m_Connection.Close();
			}
		}
	}

}