databaseoper.cs

该项目实现在.net 2003上

using System;
using System.Data;
using System.Data.Common;
using System.Data.SqlServerCe;
using System.Diagnostics;


namespace ctd.E1Analyzer.DatabaseOper
{
	/// <summary>
	/// DatabaseOper 的摘要说明。
	/// </summary>
	public class Database
	{
		public Database()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
			localDatabaseName = "\\My Documents\\DataContainer.sdf";
			m_strConn = "Provider = Microsoft.SQLSERVER.OLEDB.CE.2.0;Data Source=\\My Documents\\DataContainer.sdf";
		}
		public Database(string strConn)
		{
			m_strConn = strConn;
		}
		private string localDatabaseName;
		private string m_strConn;//
		public System.Data.SqlServerCe m_Conn;//数据库连接
		private void CreateDatabase()
		{

		}
		public bool CreateDatabase()
		{
			
			if(System.IO.File.Exists(LocalDatabase) == false) 
			{ 
				//
				System.Data.SqlServerCe.Engine SQLCEEngine = 
					new System.Data.SqlServerCe.Engine(m_strConn); 
				SQLCEEngine.CreateDatabase();
 
				return true; 
			}
			else
 			{ 
				return false;
			} 
			
		}
		public bool OpenDatabase()
		{ 
			m_Conn = new SqlCeConnection(m_strConn); 
			m_Conn.Open();
           
		}
		/// <summary>
		/// 执行无返回记录集的动作，譬如，delete,insert,edit ...
		/// </summary>
		/// <param name="strSQL"></param>
		/// <returns></returns>
		public bool ExcuteCommand(string strSQL)
		{
			try
			{
				SqlCeCommand  command = new SqlCeCommand(strSQL,this.m_Conn);
				command.ExecuteNonQuery();
			}
			catch(Exception e)
			{
				Debug.WriteLine("public bool ExcuteCommand(string strSQL)" + e.Message);
				Debug.WriteLine(strSQL);
				return false;
			}
			return true;
		}
		/// <summary>
		/// 执行返回记录集的动作，譬如，select
		/// </summary>
		/// <param name="strSQL"></param>
		/// <returns>
		/// 如果返回值为null,表示执行动作发生错误
		/// </returns>
		public SqlCeDataReader ExcuteQuery(string strSQL)
		{
			SqlCeCommand command ;
			SqlCeDataReader reader = null;
			try
			{
				command = new SqlCeCommand(strSQL,this.m_Conn);
				reader = command.ExecuteReader();
			}
			catch(Exception e)
			{
				Debug.WriteLine("public OleDbDataReader ExcuteQuery(string strSQL) happen errors" + e.Message);
			}
			return reader;
		}

        

	}
}