Asp.net-Mysql数据库的增删改查

点击(此处)折叠或打开

1. using System;
   
2. using System.Data;
   
3. using System.Text;
   
4. using System.Configuration;
   
5. using System.Web;
   
6. using System.Web.Security;
   
7. using System.Web.UI;
   
8. using System.Web.UI.HtmlControls;
   
9. using System.Web.UI.WebControls;
   
10. using System.Web.UI.WebControls.WebParts;
    
11. using MySql.Data.MySqlClient;
12. //☆qau 555 2015.11 博盈杯
13. namespace DB_
    
14. {
    
15.     public class DB
    
16.     {
    
17. 
    
18.         public DB()
    
19.         {
    
20.             // 在此处添加构造函数逻辑
    
21.         }
    
22. 
    
23.         public MySqlConnection conntent()
    
24.         {
    
25.             string constr = "Data Source=127.0.0.1;port=3306;Database=test;User Id=root;Password=root;CharSet=utf8;allow zero datetime=true";
    
26.             MySqlConnection con = new MySqlConnection(constr);
    
27.             try
    
28.             {
    
29.                 con.Open();
    
30.                 return con;// 成功
    
31.             }
    
32.             catch (Exception ex)
    
33.             {
    
34.                 return null;//连接打开出现异常
    
35.             }
    
36.         }//连接字符串，返回MySqlConnection 链接对象
    
37. 
    
38.         public DataSet Select(string sqlstr)//返回一个DataSet数据集或NULL
    
39.         {
    
40.             MySqlDataAdapter myadapter = new MySqlDataAdapter(sqlstr, conntent());
    
41.              DataSet select = new DataSet();
    
42.             int suc_count = myadapter.Fill(select);
    
43.            if (select != null) { return select; }
    
44.             else { return null; }
    
45.         }
    
46. 
    
47.         public MySqlDataReader Select1(string sqlstr)//返回一个MySqlDataReader对象，或null
    
48.         {
    
49.             MySqlCommand mycmd = new MySqlCommand(sqlstr,conntent());
    
50.             try
    
51.             {
    
52.                 MySqlDataReader select1 = mycmd.ExecuteReader();
    
53.                 if (select1 != null){ return select1; }
    
54.                 else { return null; }
    
55.             }
    
56.             catch (Exception ex)
    
57.             {
    
58.                 return null;
    
59.             }
    
60.         }
    
61. 
    
62.         public bool ZSG(string sqlstr)//根据传人的sqlstr 和 连接对象，执行操作
    
63.         {//调用ZSG()函数进行增删改的操作,成功TRUE，失败FALSE
    
64.                 MySqlCommand mycmd = new MySqlCommand(sqlstr, conntent());
    
65.                 try
    
66.                 {
    
67.                     if (mycmd.ExecuteNonQuery() > 0)
    
68.                     { return true;//成功 }
    
69.                     else
    
70.                     { return false; }
    
71.                 }
    
72.                 catch{ return false; }
    
73.         }
    
74.     }
    
75. }