根据自己平时的经验写的针对SQLSERVER操作的通用类库
1
using System;
2
using System.Data;
3
using System.Data.SqlClient;
4
using System.Web;
5
6
namespace Whgw_lc
7
{
8
/// <summary>
9
/// Data 的摘要说明。
10
/// </summary>
11
/// <summary>
12
/// 数据库相关操作类
13
/// 作者:DarkAngel
14
/// 时间:2004-9-24
15
/// </summary>
16
public class Data
17
{
18
/// <summary>
19
///连接数据库字符串
20
/// </summary>
21
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";
22
/// <summary>
23
/// 数据库连接对象
24
/// </summary>
25
protected System.Data .SqlClient.SqlConnection DataConnection;
26
/// <summary>
27
/// SqlDataAdapter对象
28
/// </summary>
29
protected System.Data.SqlClient.SqlDataAdapter DataAdapter;
30
/// <summary>
31
/// SqlCommand对象
32
/// </summary>
33
protected System.Data.SqlClient.SqlCommand DataCommand;
34
/// <summary>
35
/// SqlCommandBuilder对象
36
/// </summary>
37
protected System.Data.SqlClient.SqlCommandBuilder DataComBuilder;
38
/// <summary>
39
/// DataSet对象
40
/// </summary>
41
protected System.Data.DataSet DataSet;
42
/// <summary>
43
/// DataRow对象
44
/// </summary>
45
protected System.Data.DataRow DataRow;
46
/// <summary>
47
/// SqlDataReader对象
48
/// </summary>
49
protected System.Data.SqlClient.SqlDataReader DataReader;
50
//protected System.Web.UI.Page mypage;
51
/// <summary>
52
///构造函数
53
/// </summary>
54
55
public Data()
56
{
57
//
58
// TODO: 连接数据库参数
59
//
60
//con=
61
DataConnection=DataConn();
62
63
}
64
/// <summary>
65
/// 数据库连接参数属性
66
/// </summary>
67
public string Con
68
{
69
70
get{return con;}
71
set{con= value;}
72
}
73
/// <summary>
74
/// 建立数据库连接
75
/// </summary>
76
/// <returns>返回数据库连接对象</returns>
77
public SqlConnection DataConn()
78
{
79
SqlConnection DataConnection=new SqlConnection(Con);
80
return DataConnection;
81
}
82
/// <summary>
83
/// 查询结果,返回
84
/// </summary>
85
/// <param name="mysql">查询语句</param>
86
/// <returns>返回datareader</returns>
87
public SqlDataReader DataQuery(string Sql)
88
{
89
90
DataConnection=DataConn();
91
DataConnection.Open();
92
DataReader=null;
93
DataCommand=new SqlCommand(Sql,DataConnection);
94
DataReader=DataCommand.ExecuteReader();
95
return DataReader;
96
}
97
/// <summary>
98
/// 查询结果,返回DataSet
99
/// </summary>
100
/// <param name="mysql">查询语句</param>
101
/// <param name="tabName">表名</param>
102
/// <returns>DataSet</returns>
103
public virtual DataSet DataSetQuery(string Sql,string TableName)
104
{
105
DataConnection=DataConn();
106
DataConnection.Open();
107
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
108
DataSet=new DataSet();
109
DataAdapter.Fill(DataSet,TableName);
110
return DataSet;
111
}
112
public DataSet DataSetQuery(DataSet myds,string TableName,string Sql)
113
{
114
DataConnection=DataConn();
115
DataConnection.Open();
116
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
117
118
DataAdapter.Fill(myds,TableName);
119
return DataSet;
120
121
}
122
/// <summary>
123
/// 查询结果,返回DataSet,带起始和结束
124
/// </summary>
125
/// <param name="mysql">查询语句</param>
126
/// <param name="tabName">表名</param>
127
/// <param name="starIndex">起始行</param>
128
/// <param name="count">终止行</param>
129
/// <returns>返回DataSet</returns>
130
public DataSet DataSetQuery(string Sql,string TableName,int StarIndex,int Count)
131
{
132
DataConnection=DataConn();
133
DataConnection.Open();
134
DataAdapter=new SqlDataAdapter(Sql,DataConnection);
135
DataSet=new DataSet();
136
DataAdapter.Fill(DataSet,StarIndex,Count,TableName);
137
return DataSet;
138
}
139
/// <summary>
140
/// 修改数据库内容
141
/// </summary>
142
/// <param name="mysql">查询语句</param>
143
/// <returns>如果执行成功返回真,否者返回假</returns>
144
public bool EditData(string Sql)
145
{
146
DataConnection=DataConn();
147
DataConnection.Open();
148
DataCommand=new SqlCommand(Sql,DataConnection);
149
try
150
{
151
DataCommand.ExecuteNonQuery();
152
return true;
153
}
154
catch(Exception ex)
155
{
156
System.Console.Write(ex.Message.ToString());
157
return false;
158
}
159
DataConnection.Close();
160
}
161
/// <summary>
162
/// 修改DataSet内容,并更新数据库
163
/// </summary>
164
/// <param name="DataSet">DataSet对象</param>
165
/// <param name="myda">SqlDataAdapter容器</param>
166
/// <param name="tbName">表名</param>
167
/// <returns>返回DataSet</returns>
168
public DataSet EditData(DataSet DataSet,SqlDataAdapter myda,string TableName)
169
{
170
171
172
DataComBuilder=new SqlCommandBuilder(myda);
173
myda.UpdateCommand=DataComBuilder.GetUpdateCommand();
174
myda.DeleteCommand=DataComBuilder.GetDeleteCommand();
175
myda.InsertCommand=DataComBuilder.GetInsertCommand();
176
myda.Update(DataSet,TableName);
177
DataSet.AcceptChanges();
178
return DataSet;
179
}
180
/// <summary>
181
/// 无参数存储过程的执行
182
/// </summary>
183
/// <param name="proName">存储过程名称</param>
184
/// <returns>是否执行成功</returns>
185
public bool DataProcedure(string ProcedureName)
186
{
187
DataConnection=DataConn();
188
DataConnection.Open();
189
DataCommand=new SqlCommand();
190
DataCommand.CommandText=ProcedureName;
191
DataCommand.Connection=DataConnection;
192
DataCommand.CommandType=System.Data.CommandType.StoredProcedure;
193
try
194
{
195
DataCommand.ExecuteNonQuery();
196
return true;
197
}
198
catch(Exception ex)
199
{
200
System.Console.Write(ex.Message.ToString());
201
return false;
202
}
203
}
204
/// <summary>
205
/// 关闭数据库连接
206
/// </summary>
207
public void CloseConnection()
208
{
209
DataConnection.Close();
210
}
211
212
}
213
}
214
215
using System;2
using System.Data;3
using System.Data.SqlClient;4
using System.Web;5

6
namespace Whgw_lc7
{8
/// <summary>9
/// Data 的摘要说明。10
/// </summary>11
/// <summary>12
/// 数据库相关操作类13
/// 作者:DarkAngel14
/// 时间:2004-9-2415
/// </summary>16
public class Data17
{18
/// <summary>19
///连接数据库字符串 20
/// </summary>21
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";22
/// <summary>23
/// 数据库连接对象24
/// </summary>25
protected System.Data .SqlClient.SqlConnection DataConnection;26
/// <summary>27
/// SqlDataAdapter对象28
/// </summary>29
protected System.Data.SqlClient.SqlDataAdapter DataAdapter;30
/// <summary>31
/// SqlCommand对象32
/// </summary>33
protected System.Data.SqlClient.SqlCommand DataCommand;34
/// <summary>35
/// SqlCommandBuilder对象36
/// </summary>37
protected System.Data.SqlClient.SqlCommandBuilder DataComBuilder;38
/// <summary>39
/// DataSet对象40
/// </summary>41
protected System.Data.DataSet DataSet;42
/// <summary>43
/// DataRow对象44
/// </summary>45
protected System.Data.DataRow DataRow;46
/// <summary>47
/// SqlDataReader对象48
/// </summary>49
protected System.Data.SqlClient.SqlDataReader DataReader;50
//protected System.Web.UI.Page mypage;51
/// <summary>52
///构造函数53
/// </summary>54
55
public Data()56
{57
//58
// TODO: 连接数据库参数59
//60
//con=61
DataConnection=DataConn(); 62
63
}64
/// <summary>65
/// 数据库连接参数属性66
/// </summary>67
public string Con68
{69
70
get{return con;}71
set{con= value;}72
}73
/// <summary>74
/// 建立数据库连接75
/// </summary>76
/// <returns>返回数据库连接对象</returns>77
public SqlConnection DataConn()78
{79
SqlConnection DataConnection=new SqlConnection(Con);80
return DataConnection;81
}82
/// <summary>83
/// 查询结果,返回84
/// </summary>85
/// <param name="mysql">查询语句</param>86
/// <returns>返回datareader</returns>87
public SqlDataReader DataQuery(string Sql)88
{89
90
DataConnection=DataConn();91
DataConnection.Open();92
DataReader=null;93
DataCommand=new SqlCommand(Sql,DataConnection);94
DataReader=DataCommand.ExecuteReader();95
return DataReader;96
}97
/// <summary>98
/// 查询结果,返回DataSet99
/// </summary>100
/// <param name="mysql">查询语句</param>101
/// <param name="tabName">表名</param>102
/// <returns>DataSet</returns>103
public virtual DataSet DataSetQuery(string Sql,string TableName)104
{105
DataConnection=DataConn();106
DataConnection.Open();107
DataAdapter=new SqlDataAdapter(Sql,DataConnection);108
DataSet=new DataSet();109
DataAdapter.Fill(DataSet,TableName);110
return DataSet;111
}112
public DataSet DataSetQuery(DataSet myds,string TableName,string Sql)113
{114
DataConnection=DataConn();115
DataConnection.Open();116
DataAdapter=new SqlDataAdapter(Sql,DataConnection);117
118
DataAdapter.Fill(myds,TableName);119
return DataSet;120

121
}122
/// <summary>123
/// 查询结果,返回DataSet,带起始和结束124
/// </summary>125
/// <param name="mysql">查询语句</param>126
/// <param name="tabName">表名</param>127
/// <param name="starIndex">起始行</param>128
/// <param name="count">终止行</param>129
/// <returns>返回DataSet</returns>130
public DataSet DataSetQuery(string Sql,string TableName,int StarIndex,int Count)131
{132
DataConnection=DataConn();133
DataConnection.Open();134
DataAdapter=new SqlDataAdapter(Sql,DataConnection);135
DataSet=new DataSet();136
DataAdapter.Fill(DataSet,StarIndex,Count,TableName);137
return DataSet;138
}139
/// <summary>140
/// 修改数据库内容141
/// </summary>142
/// <param name="mysql">查询语句</param>143
/// <returns>如果执行成功返回真,否者返回假</returns>144
public bool EditData(string Sql)145
{146
DataConnection=DataConn();147
DataConnection.Open();148
DataCommand=new SqlCommand(Sql,DataConnection);149
try150
{151
DataCommand.ExecuteNonQuery();152
return true;153
}154
catch(Exception ex)155
{ 156
System.Console.Write(ex.Message.ToString());157
return false;158
}159
DataConnection.Close();160
}161
/// <summary>162
/// 修改DataSet内容,并更新数据库163
/// </summary>164
/// <param name="DataSet">DataSet对象</param>165
/// <param name="myda">SqlDataAdapter容器</param>166
/// <param name="tbName">表名</param>167
/// <returns>返回DataSet</returns>168
public DataSet EditData(DataSet DataSet,SqlDataAdapter myda,string TableName)169
{170
171
172
DataComBuilder=new SqlCommandBuilder(myda);173
myda.UpdateCommand=DataComBuilder.GetUpdateCommand();174
myda.DeleteCommand=DataComBuilder.GetDeleteCommand();175
myda.InsertCommand=DataComBuilder.GetInsertCommand();176
myda.Update(DataSet,TableName);177
DataSet.AcceptChanges();178
return DataSet;179
}180
/// <summary>181
/// 无参数存储过程的执行182
/// </summary>183
/// <param name="proName">存储过程名称</param>184
/// <returns>是否执行成功</returns>185
public bool DataProcedure(string ProcedureName)186
{187
DataConnection=DataConn();188
DataConnection.Open();189
DataCommand=new SqlCommand();190
DataCommand.CommandText=ProcedureName;191
DataCommand.Connection=DataConnection;192
DataCommand.CommandType=System.Data.CommandType.StoredProcedure;193
try194
{195
DataCommand.ExecuteNonQuery();196
return true;197
}198
catch(Exception ex)199
{ 200
System.Console.Write(ex.Message.ToString());201
return false;202
}203
}204
/// <summary>205
/// 关闭数据库连接206
/// </summary>207
public void CloseConnection()208
{209
DataConnection.Close();210
}211
212
}213
}214

215


