简洁的MysqlHelper_MySQL

 1 public class MySqlHelper
 2     {
 3       private static readonly  
 
 string connstr = ConfigurationManager.ConnectionStrings["connstr"].ConnectionString;
 4         public MySqlConnection CreateConnection()
 5         {
 6             MySqlConnection conn = new MySqlConnection(connstr);
 7             conn.Open();
 8             return conn;
 9         }
10         public int ExecuteNonQuery(string sql,params MySqlParameter[]parameters)
11         {
12             using (MySqlConnection conn=CreateConnection())
13             using(MySqlCommand cmd=conn.CreateCommand())
14             {
15                 cmd.CommandText = sql;
16                 cmd.Parameters.AddRange(parameters);
17                return cmd.ExecuteNonQuery();
18             }
19         }
20         public object ExecuteScalar(string sql,params MySqlParameter[]parameters)
21         {
22             using (MySqlConnection conn=CreateConnection())
23             using (MySqlCommand cmd=conn.CreateCommand())
24             {
25                 cmd.CommandText = sql;
26                 cmd.Parameters.AddRange(parameters);
27                return cmd.ExecuteScalar();
28             }
29            
30         }
31        
32         public MySqlDataReader ExecuteReader(string sql,params MySqlParameter[]ps)
33         {
34             using (MySqlConnection conn=CreateConnection())
35             using(MySqlCommand cmd=conn.CreateCommand())
36             {
37                 cmd.CommandText = sql;
38                 if (ps!=null)
39                 {
40                     cmd.Parameters.AddRange(ps);
41                 }
42                return cmd.ExecuteReader();
43             }
44         }
45         public DataTable ExecuteDataTable(string sql,params MySqlParameter[]ps)
46         {
47             DataTable table = new DataTable();
48             using (MySqlConnection conn=CreateConnection())
49             using(MySqlCommand cmd=conn.CreateCommand())
50             {
51                 cmd.CommandText = sql;
52                 if (ps!=null)
53                 {
54                     cmd.Parameters.AddRange(ps);
55                 }
56                 using ( MySqlDataAdapter adapter = new MySqlDataAdapter(cmd))
57                 {
58                     adapter.Fill(table);
59                 }
60                 return table;
61             }
62         }
63     }