根据自己平时的经验写的针对SQLSERVER操作的通用类库
1using System;
2using System.Data;
3using System.Data.SqlClient;
4using System.Web;
5
6namespace 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
2using System.Data;
3using System.Data.SqlClient;
4using System.Web;
5
6namespace 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