dboperatesite.cs

用vs2005写的一个生产任务管理系统。数据的统计和综合查询是主要功能

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

namespace RWSB
{
	/// <summary>
	/// DBOperateSite 的摘要说明。
	/// </summary>
	public class DBOperateSite
	{
		public DBOperateSite()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}

		//输入SELECT语句，获得返回数据集
		public static DataTable SelectFormSite(string sql,int start,int size,string tablename)
		{
			try
			{
				SqlConnection sqlConnection=new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["conn"]);
				SqlDataAdapter sqlAdapter1 = new SqlDataAdapter(sql, sqlConnection);
				DataSet returns = new DataSet();
				sqlAdapter1.Fill(returns,start,size,tablename);
				return returns.Tables[0];
			}
			catch (Exception ex)
			{
				throw (ex);
			}	
		}
		
		public static DataTable SelectFormSite(string sql)
		{
			try
			{
				SqlConnection sqlConnection=new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["conn"]);
				SqlDataAdapter sqlAdapter1 = new SqlDataAdapter(sql, sqlConnection);
				DataSet returns = new DataSet();
				sqlAdapter1.Fill(returns);
				return returns.Tables[0];
			}
			catch (Exception ex)
			{
				throw (ex);
			}	
		}

		//返回一条记录
		public static DataRow GetDataRow(string sql,string TableName) 
		{
			try
			{
				SqlConnection sqlConnection=new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["conn"]);
				SqlDataAdapter sqlAdapter1 = new SqlDataAdapter(sql, sqlConnection);
				DataSet product = new DataSet();
				sqlAdapter1.Fill(product, TableName);
				return product.Tables[0].Rows[0];
			}
			catch (Exception ex)
			{
				throw (ex);
			}	
		}

		//执行SQL语句，如UPDATE，INSERT等
		public static void ExcSQL(string s)
		{
			SqlConnection sqlConnection=new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["conn"]);
			try
			{
				SqlCommand sqlCmd =new SqlCommand(s,sqlConnection);
				sqlConnection.Open();
				sqlCmd.ExecuteNonQuery();
			}
			catch (Exception ex)
			{
				throw (ex);
			}
			finally
			{
				sqlConnection.Close();
			}
		}

		//检查用户是否存在
		public static int CalculateURecord(string User_Name,string Password)
		{
			try
			{
				string s="SELECT COUNT(*) AS co FROM Users WHERE (username ='"+User_Name+"') AND (password = '"+Password+"')";
				DataRow dr=GetDataRow(s,"Users");
				return System.Convert.ToInt32(dr["co"].ToString());
			}
			catch
			{
				return 0;
			}
		}
		//获取用户级别
		public static string GetUserGrade(string UserName)
		{
			try
			{
				if (UserName=="")
					return "浏览用户";
				else
				{
					string s="SELECT (SELECT rolename FROM roles WHERE roleid = qxid) AS UG, qxid FROM Users WHERE (username ='"
						+UserName+"')";
					DataRow dr=GetDataRow(s,"users");
					return dr["UG"].ToString();
				}
			}
			catch
			{
				return null;
			}
		}
		//获取用户管理级别
		public static string GetUserPopedom(string UserName)
		{
			try
			{
				if (UserName=="")
					return "浏览用户";
				else
				{
					string s="SELECT (SELECT rolename FROM roles WHERE roleid = qxid) AS UG, qxid FROM Users WHERE (username ='"
						+UserName+"')";
					DataRow dr=GetDataRow(s,"users");
					return dr["UG"].ToString();
				}
			}
			catch
			{
				return null;
			}
		}
	}
}