dboperate.cs

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

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

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

		//输入SELECT语句，获得返回数据集
		public static DataTable SelectFormForum(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 SelectFormForum(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,string dbname) 
		{
			try
			{
				SqlConnection sqlConnection=new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings[dbname]);
				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();
			}
		}

		
		
		

	}
}