用于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 }