dataaccessinfo.cs

来自「主要用C#写的代码」· CS 代码 · 共 121 行

using System;
using System.Data.SqlClient;

using System.Data;

namespace DataAccess
{
	/// <summary>
	/// 对数据库所有的操作
	/// <summary>
	public class DataAccessInfo
	{
		/// <summary>
		/// insert update delete
		/// </summary>
		/// <param name="sql">需要执行的SQL语句</param>
		/// <returns>执行成功返回1 否则返回0</returns>
		public int ExecuteSQL(string sql)
		{
			int n = 0;

			try
			{
				MyConn.Conn.Open();
				SqlCommand cmd = new SqlCommand(sql,MyConn.Conn);

				cmd.ExecuteNonQuery();

				n = 1;
			}
			catch(SqlException EX)
			{
				throw EX;
			}
			finally
			{
				MyConn.Close();
			}

			return n;
		}

		/// <summary>
		/// 返回的DataSet数据集合
		/// </summary>
		/// <param name="sql"></param>
		/// <returns></returns>
		public DataSet GetDataSet(string sql)
		{
			DataSet ds = new DataSet();


			SqlDataAdapter sdap = new SqlDataAdapter(sql, MyConn.Conn);
			sdap.Fill(ds);
			

			return ds;
		}


		/// <summary>
		/// 根据SQL语句获得查询结果中第一行第一列的置（一般用在聚合函数）
		/// </summary>
		/// <param name="sql"></param>
		/// <returns></returns>
		public int GetScalarBySql(string sql)
		{
			int returnInt = 0;

			try
			{
				MyConn.Conn.Open();
				SqlCommand cmd = new SqlCommand(sql,MyConn.Conn);

				returnInt = Convert.ToInt32(cmd.ExecuteScalar().ToString());

			
			}
			catch(Exception ex)
			{
				throw ex;
			}
			finally
			{
				MyConn.Close();
			}

			return returnInt;
		}
		/// <summary>
		/// 
		/// </summary>
		/// <param name="sql"></param>
		/// <returns></returns>
		public double GetScalarSql(string sql)
		{
			double returnInt = 0;

			try
			{
				MyConn.Conn.Open();
				SqlCommand cmd = new SqlCommand(sql,MyConn.Conn);

				returnInt = Convert.ToDouble(cmd.ExecuteScalar().ToString());

			
			}
			catch(Exception ex)
			{
				throw ex;
			}
			finally
			{
				MyConn.Close();
			}

			return returnInt;
		}
	}
}