MySql用のSqlHelper
36848 ワード
MySql用のSqlHelper
1 /// <summary>
2
3 /// Title :MySqlHelper
4 /// Author :WinterT
5 /// Date :2015-1-8 08:12:54
6 /// Description:
7 /// ExecuteNonQuery
8 /// ExecuteScalar
9 /// ExecuteReader
10 /// ExecuteTable
11 /// </summary>
12 public static class MySqlHelper
13 {
14 /// <summary>
15 ///
16 /// </summary>
17 /// <returns> </returns>
18 private static MySqlConnection GetConnection()
19 {
20 string connString = ConfigurationManager.ConnectionStrings[1].ConnectionString;
21 return new MySqlConnection(connString);
22 }
23 #region ExecuteNonQuery
24 /// <summary>
25 /// sql
26 /// </summary>
27 /// <param name="sql">sql </param>
28 /// <returns> </returns>
29 public static int ExecuteNonQuery(string sql)
30 {
31 using (MySqlConnection conn = GetConnection())
32 {
33 using (MySqlCommand cmd = conn.CreateCommand())
34 {
35 cmd.CommandText = sql;
36 return cmd.ExecuteNonQuery();
37 }
38 }
39 }
40 /// <summary>
41 /// , SQL
42 /// </summary>
43 /// <param name="conn"> 、 。</param>
44 /// <param name="sql"> sql </param>
45 /// <param name="paras"> </param>
46 /// <returns> </returns>
47 public static int ExecuteNonQuery
48 (MySqlConnection conn, string sql, params MySqlParameter[] paras)
49 {
50 using (MySqlCommand cmd = conn.CreateCommand())
51 {
52 cmd.CommandText = sql;
53 cmd.Parameters.AddRange(paras);
54 return cmd.ExecuteNonQuery();
55 }
56 }
57 /// <summary>
58 /// SQL
59 /// </summary>
60 /// <param name="sql"> sql </param>
61 /// <param name="paras"> </param>
62 /// <returns> </returns>
63 public static int ExecuteNonQuery
64 (string sql, params MySqlParameter[] paras)
65 {
66 using (MySqlConnection conn = GetConnection())
67 {
68 return ExecuteNonQuery(conn, sql, paras);
69 }
70 }
71 #endregion
72 #region ExecuteScalar
73 /// <summary>
74 /// sql ,
75 /// </summary>
76 /// <param name="sql">sql </param>
77 /// <returns> </returns>
78 public static Object ExecuteScalar(string sql)
79 {
80 using (MySqlConnection conn = GetConnection())
81 {
82 using (MySqlCommand cmd = conn.CreateCommand())
83 {
84 cmd.CommandText = sql;
85 return cmd.ExecuteScalar();
86 }
87 }
88 }
89 /// <summary>
90 /// Connection , sql ,
91 /// </summary>
92 /// <param name="conn"> </param>
93 /// <param name="sql">sql </param>
94 /// <param name="paras"> </param>
95 /// <returns> </returns>
96 public static object ExecuteScalar
97 (MySqlConnection conn, string sql, MySqlParameter[] paras)
98 {
99 using (MySqlCommand cmd = conn.CreateCommand())
100 {
101 cmd.CommandText = sql;
102 cmd.Parameters.AddRange(paras);
103 return cmd.ExecuteScalar();
104 }
105 }
106 /// <summary>
107 /// sql ,
108 /// </summary>
109 /// <param name="sql">sql </param>
110 /// <param name="paras"> </param>
111 /// <returns> </returns>
112 public static object ExecuteScalar
113 (string sql, MySqlParameter[] paras)
114 {
115 using (MySqlConnection conn = GetConnection())
116 {
117 return ExecuteScalar(conn, sql, paras);
118 }
119 }
120 #endregion
121 #region ExecuteReader
122 /// <summary>
123 /// sql , MySqlDataReader
124 /// </summary>
125 /// <param name="sql">sql </param>
126 /// <returns> MySqlDataReader </returns>
127 public static MySqlDataReader ExecuteReader(string sql)
128 {
129 MySqlConnection conn = GetConnection();
130 using (MySqlCommand cmd = conn.CreateCommand())
131 {
132 cmd.CommandText = sql;
133 conn.Open();
134 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
135 }
136 }
137 /// <summary>
138 /// , sql , Reader
139 /// </summary>
140 /// <param name="conn"> </param>
141 /// <param name="sql">sql </param>
142 /// <param name="paras"> </param>
143 /// <returns> MySqlDataReader </returns>
144 public static MySqlDataReader ExecuteReader
145 (MySqlConnection conn, string sql, params MySqlParameter[] paras)
146 {
147 using (MySqlCommand cmd = conn.CreateCommand())
148 {
149 cmd.CommandText = sql;
150 cmd.Parameters.AddRange(paras);
151 conn.Open();
152 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
153 }
154 }
155 /// <summary>
156 /// sql , Reader
157 /// </summary>
158 /// <param name="sql">sql </param>
159 /// <param name="paras"> </param>
160 /// <returns> MySqlDataReader </returns>
161 public static MySqlDataReader ExecuteReader
162 (string sql, params MySqlParameter[] paras)
163 {
164 MySqlConnection conn = GetConnection();
165 using (MySqlCommand cmd = conn.CreateCommand())
166 {
167 return ExecuteReader(conn, sql, paras);
168 }
169 }
170 #endregion
171 #region ExecuteTable
172 /// <summary>
173 /// sql , DataTable
174 /// </summary>
175 /// <param name="sql">sql </param>
176 /// <returns>DataTable</returns>
177 public static DataTable ExecuteTable(string sql)
178 {
179 using (MySqlConnection conn = GetConnection())
180 {
181 using (MySqlCommand cmd = conn.CreateCommand())
182 {
183 cmd.CommandText = sql;
184 using (MySqlDataReader reader = cmd.ExecuteReader())
185 {
186 DataTable table = new DataTable();
187 table.Load(reader);
188 return table;
189 }
190 }
191 }
192 }
193 /// <summary>
194 /// , sql , DataTable
195 /// </summary>
196 /// <param name="conn"> , </param>
197 /// <param name="sql">sql </param>
198 /// <param name="paras"> </param>
199 /// <returns>DataTable</returns>
200 public static DataTable ExecuteTable
201 (MySqlConnection conn, string sql, params MySqlParameter[] paras)
202 {
203 using (MySqlCommand cmd = conn.CreateCommand())
204 {
205 cmd.CommandText = sql;
206 cmd.Parameters.AddRange(paras);
207 using (MySqlDataReader reader = cmd.ExecuteReader())
208 {
209 DataTable table = new DataTable();
210 table.Load(reader);
211 return table;
212 }
213 }
214 }
215 /// <summary>
216 /// sql
217 /// </summary>
218 /// <param name="sql">sql </param>
219 /// <param name="paras"> </param>
220 /// <returns>DataTable</returns>
221 public static DataTable ExecuteTable
222 (string sql, params MySqlParameter[] paras)
223 {
224 using (MySqlConnection conn = GetConnection())
225 {
226 return ExecuteTable(conn, sql, paras);
227 }
228 }
229
230 #endregion
231 }