根据自己平时的经验写的针对SQLSERVER操作的通用类库
using System;
using System.Data;
using System.Data.SqlClient;
using System.Web;
namespace Whgw_lc
{
///
/// Data 的摘要说明。
///
///
/// 数据库相关操作类
/// 作者：DarkAngel
/// 时间：2004-9-24
///
public class Data
{
///
///连接数据库字符串
///
protected static string con="data source=10.68.19.203;initial catalog=Whgw;persist security info=False;user id=sa;password=sc2000;workstation id=DARKANGEL;packet size=4096";
///
/// 数据库连接对象
///
protected System.Data .SqlClient.SqlConnection DataConnection;
///
/// SqlDataAdapter对象
///
protected System.Data.SqlClient.SqlDataAdapter DataAdapter;
///
/// SqlCommand对象
///
protected System.Data.SqlClient.SqlCommand DataCommand;
///
/// SqlCommandBuilder对象
///
protected System.Data.SqlClient.SqlCommandBuilder DataComBuilder;
///
/// DataSet对象
///
protected System.Data.DataSet DataSet;
///
/// DataRow对象
///
protected System.Data.DataRow DataRow;
///
/// SqlDataReader对象
///
protected System.Data.SqlClient.SqlDataReader DataReader;
//protected System.Web.UI.Page mypage;
///
///构造函数
///
public Data()
{
//
// TODO: 连接数据库参数
//
//con=
DataConnection=DataConn();
}
///
/// 数据库连接参数属性
///
public string Con
{
get{return con;}
set{con= value;}
}
///
/// 建立数据库连接
///
///
public SqlConnection DataConn()
{
SqlConnection DataConnection=new SqlConnection(Con);
return DataConnection;
}
///
/// 查询结果，返回
///
/// 查询语句
///
public SqlDataReader DataQuery(string Sql)
{
DataConnection=DataConn();
DataConnection.Open();
DataReader=null;
DataCommand=new SqlCommand(Sql,DataConnection);
DataReader=DataCommand.ExecuteReader();
return DataReader;
}
///
/// 查询结果，返回DataSet
///
/// 查询语句
/// 表名
///
public virtual DataSet DataSetQuery(string Sql,string TableName)
{
DataConnection=DataConn();
DataConnection.Open();
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
DataSet=new DataSet();
DataAdapter.Fill(DataSet,TableName);
return DataSet;
}
public DataSet DataSetQuery(DataSet myds,string TableName,string Sql)
{
DataConnection=DataConn();
DataConnection.Open();
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
DataAdapter.Fill(myds,TableName);
return DataSet;
}
///
/// 查询结果，返回DataSet，带起始和结束
///
/// 查询语句
/// 表名
/// 起始行
/// 终止行
///
public DataSet DataSetQuery(string Sql,string TableName,int StarIndex,int Count)
{
DataConnection=DataConn();
DataConnection.Open();
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
DataSet=new DataSet();
DataAdapter.Fill(DataSet,StarIndex,Count,TableName);
return DataSet;
}
///
/// 修改数据库内容
///
/// 查询语句
///
public bool EditData(string Sql)
{
DataConnection=DataConn();
DataConnection.Open();
DataCommand=new SqlCommand(Sql,DataConnection);
try
{
DataCommand.ExecuteNonQuery();
return true;
}
catch(Exception ex)
{
System.Console.Write(ex.Message.ToString());
return false;
}
DataConnection.Close();
}
///
/// 修改DataSet内容,并更新数据库
///
/// DataSet对象
/// SqlDataAdapter容器
/// 表名
///
public DataSet EditData(DataSet DataSet,SqlDataAdapter myda,string TableName)
{
DataComBuilder=new SqlCommandBuilder(myda);
myda.UpdateCommand=DataComBuilder.GetUpdateCommand();
myda.DeleteCommand=DataComBuilder.GetDeleteCommand();
myda.InsertCommand=DataComBuilder.GetInsertCommand();
myda.Update(DataSet,TableName);
DataSet.AcceptChanges();
return DataSet;
}
///
/// 无参数存储过程的执行
///
/// 存储过程名称
///
public bool DataProcedure(string ProcedureName)
{
DataConnection=DataConn();
DataConnection.Open();
DataCommand=new SqlCommand();
DataCommand.CommandText=ProcedureName;
DataCommand.Connection=DataConnection;
DataCommand.CommandType=System.Data.CommandType.StoredProcedure;
try
{
DataCommand.ExecuteNonQuery();
return true;
}
catch(Exception ex)
{
System.Console.Write(ex.Message.ToString());
return false;
}
}
///
/// 关闭数据库连接
///
public void CloseConnection()
{
DataConnection.Close();
}
}
}