sqlfactory.cs

分布式图书管理系统

using System;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;

namespace lib.factory
{
	/// <summary>
	/// 针对SqlServer专用连接的工厂
	/// </summary>
	public class SqlFactory : AbstractDbFactory
	{
		/// <summary>
		/// 构造函数
		/// </summary>
		public SqlFactory()
		{
		}

		/// <summary>
		/// 建立默认Connection对象
		/// </summary>
		/// <returns>Connection对象</returns>
		public IDbConnection CreateConnection()
		{
			return new SqlConnection();
		}

		/// <summary>
		/// 根据连接字符串建立Connection对象
		/// </summary>
		/// <param name="strConn">连接字符串</param>
		/// <returns>Connection对象</returns>
		public IDbConnection CreateConnection(string strConn)
		{
			return new SqlConnection(strConn);
		}

		/// <summary>
		/// 建立Command对象
		/// </summary>
		/// <returns>Command对象</returns>
		public IDbCommand CreateCommand()
		{
			return new SqlCommand();
		}

		/// <summary>
		/// 建立DataAdapter对象
		/// </summary>
		/// <returns>DataAdapter对象</returns>
		public IDbDataAdapter CreateDataAdapter()
		{
			return new SqlDataAdapter();
		}

		/// <summary>
		/// 根据Connection建立Transaction
		/// </summary>
		/// <param name="myDbConnection">Connection对象</param>
		/// <returns>Transaction对象</returns>
		public IDbTransaction CreateTransaction(IDbConnection myDbConnection)
		{
			return myDbConnection.BeginTransaction();
		}

		/// <summary>
		/// 根据Command建立DataReader
		/// </summary>
		/// <param name="myDbCommand">Command对象</param>
		/// <returns>DataReader对象</returns>
		public IDataReader CreateDataReader(IDbCommand myDbCommand)
		{
			return myDbCommand.ExecuteReader();
		}

		/// <summary>
		/// 获得连接字符串
		/// </summary>
		/// <returns>连接字符串</returns>
		public string GetConnectionString()
		{
//			ConfigurationSettings.
			string strServer = ConfigurationSettings.AppSettings["SqlServerServer"];
			string strDatabase = ConfigurationSettings.AppSettings["SqlServerDatabase"];
			string strUid = ConfigurationSettings.AppSettings["SqlServerUid"];
			string strPwd = ConfigurationSettings.AppSettings["SqlServerPwd"];
			string strConnectionString = "Server = " + strServer + "; Database = " + strDatabase + "; Uid = " + strUid + "; Pwd = " + strPwd 
				+ ";";
			return strConnectionString;
		}

	}
}