dbconnection.cs

我自己些的小程序

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

namespace myTravelSoft.DBAccess
{
	public class DBConnection
	{
		private static SqlConnection Create()
		{
			return new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["myCnn"]);
		}

		public static bool myCount(string queryString)
		{
			SqlConnection myCnn = DBConnection.Create();
			myCnn.Open();
			SqlCommand myCmd = new SqlCommand(queryString, myCnn);
			int count = Convert.ToInt32(myCmd.ExecuteScalar());
			myCnn.Close();
			if (count > 0)
			{
				return true;
			}
			return false;
		}
		
		public static int myCount(string queryString,string flag)
		{
			SqlConnection myCnn = DBConnection.Create();
			myCnn.Open();
			SqlCommand myCmd = new SqlCommand(queryString, myCnn);
			int count = Convert.ToInt32(myCmd.ExecuteScalar());
			myCnn.Close();
			return count;
		}

		public static DataView myConn_DV(string queryString)
		{
			SqlConnection myCnn = DBConnection.Create();
			SqlDataAdapter adapter = new SqlDataAdapter(queryString, myCnn);
			DataSet ds = new DataSet();
			adapter.Fill(ds);
			return ds.Tables[0].DefaultView;
		}

		public static DataTable myConn_DT(string queryString, string tableName)
		{
			SqlConnection myCnn = DBConnection.Create();
			SqlDataAdapter adapter = new SqlDataAdapter(queryString, myCnn);
			DataSet ds = new DataSet();
			adapter.Fill(ds, tableName);
			return ds.Tables[tableName];
		}

		public static DataTable myConn_DT(string queryString)
		{
			SqlConnection myCnn = DBConnection.Create();
			SqlDataAdapter adapter = new SqlDataAdapter(queryString, myCnn);
			DataSet ds = new DataSet();
			adapter.Fill(ds);
			return ds.Tables[0];
		}

		public static DataSet myConn_DS(string queryString)
		{
			SqlConnection myCnn = DBConnection.Create();
			SqlDataAdapter adapter = new SqlDataAdapter(queryString, myCnn);
			DataSet ds = new DataSet();
			adapter.Fill(ds);
			return ds;
		}

		public static SqlDataReader myConn_DR(string queryString)
		{
			SqlConnection myCnn = DBConnection.Create();
			SqlCommand myCmd=new SqlCommand(queryString,myCnn);
			if (myCnn.State == ConnectionState.Open )
				myCnn.Close();

			myCnn.Open();
			try
			{
				SqlDataReader myDR=myCmd.ExecuteReader();
				return myDR;
			}
			catch
			{
				return null;
			}
			finally
			{
				//myCnn.Close();
			}
		}

		public static bool Execute(string queryString)
		{
			try
			{
				SqlConnection myCnn = DBConnection.Create();
				myCnn.Open();
				SqlCommand cmd = new SqlCommand(queryString, myCnn);
				cmd.ExecuteNonQuery();
				myCnn.Close();
				return true;
			}
			catch (Exception)
			{
				return false;
			}
		}
		
		public static bool Execute(SqlCommand Cmd)
		{
			try
			{
				SqlConnection myCnn = DBConnection.Create();
				myCnn.Open();
				//Cmd = new SqlCommand(queryString, myCnn);
				Cmd.Connection=myCnn;
				Cmd.ExecuteNonQuery();
				myCnn.Close();
				return true;
			}
			catch (Exception)
			{
				return false;
			}
		}

	}
}