forum_dbobj.cs

ASP.net网站开发四“酷”全书：新闻、论坛、电子商城、博客_源码

/*进行数据库操作的服务器端组件
 * Forum_BusObj.cs
 * 2004-8-25
 * 梁剑
 * */
using System;
using System.Data;
using System.Data.SqlClient;
using System.Data.OleDb;

namespace DBObjectForum
{
	public class OperateDataSetC
	{
		//sqlServer DSN连接串名称
		private string m_DSN;
		//要运行的sql串
		private string m_SQL;
		//DataSet提取的源对象名称
		private string m_SrcObj;
		//默认构造函数
		public OperateDataSetC()
		{
			m_DSN = "";
			m_SQL = "";
			m_SrcObj = "";
		}
		//设置连接名称的构造函数
		public OperateDataSetC(string DSN,string SQL,string SRCOBJ)
		{
			m_DSN = DSN;
			m_SQL = SQL;
			m_SrcObj = SRCOBJ;
		}
		//属性设置连接串
		public string DBConnection
		{
			get {return m_DSN;}
			set {m_DSN = value;}
		}
		//属性设置sql串
		public string ExecutingSql
		{
			get {return m_SQL;}
			set {m_SQL = value;}
		}
		public string SourceObject
		{
			get {return m_SrcObj;}
			set {m_SrcObj = value;}
		}
		//获得数据库查询后返回DataSet对象
		public DataSet GetDataSet()
		{
			if(m_DSN == "")
			{
				throw new ArgumentNullException("数据库连接错误:","没有有效的ODBC数据源!");
			}
			if(m_SQL == "")
			{
				throw new ArgumentNullException("数据库查询串错误:","没有设置有效的查询串!");
			}
			if(m_SrcObj == "")
			{
				throw new ArgumentNullException("数据库源对象:","没有设置要返回的数据库数据源对象!");
			}
			//由于.net 需要新的ODBC组件才能进行ODBC连接(ODBC.NET组件可以通过http://msdn.microsoft.com/code/default.asp?url=/code/sample.asp?url=/msdn-files/027/001/668/msdncompositedoc.xml)
			SqlConnection oConn = new SqlConnection(m_DSN);
			SqlDataAdapter oAdapter = new SqlDataAdapter(m_SQL,oConn);
			DataSet oDataSet = new DataSet();
			oAdapter.Fill(oDataSet,m_SrcObj);
			oConn.Close();
			return oDataSet;
		}
		public DataSet GetDataSet(string DSN,string SQL,string SRCOBJ)
		{
			this.m_DSN = DSN;
			this.m_SQL = SQL;
			this.m_SrcObj = SRCOBJ;
			return GetDataSet();
		}
	}

	public class OperatorDataReaderC
	{
		private string m_DSN;
		private string m_SQL;
		public OperatorDataReaderC()
		{
			m_DSN = "";
			m_SQL = "";
		}
		public OperatorDataReaderC(string DSN,string SQL)
		{
			m_DSN = DSN;
			m_SQL = SQL;
		}
		public string DBConnection
		{
			get {return m_DSN;}
			set {m_DSN = value;}
		}
		public string ExecutingSql
		{
			get {return m_SQL;}
			set {m_SQL = value;}
		}
		public OleDbDataReader GetDataReader()
		{
			if(m_DSN == "")
			{
				throw new ArgumentNullException("数据库连接错误:","没有有效的ODBC数据源!");
			}
			if(m_SQL == "")
			{
				throw new ArgumentNullException("数据库查询串错误:","没有设置有效的查询串!");
			}
			OleDbConnection oConn = new OleDbConnection(m_DSN);
			oConn.Open();
			OleDbCommand oCommand = new OleDbCommand(m_SQL,oConn);
			OleDbDataReader oReader;
			oReader = oCommand.ExecuteReader();
			oConn.Close();
			return oReader;
		}
		public OleDbDataReader GerDataReader(string DSN,string SQL)
		{
			this.m_DSN = DSN;
			this.m_SQL = SQL;
			return this.GetDataReader();
		}
	}
}