C#访问MySQL数据库的方法

今天药忘吃喽~ 2022-08-08 05:06 231阅读 0赞

原文地址：

http://blog.csdn.net/hsg77/article/details/7302880

C\#访问MySQL数据库的方法

(1)首先需要下载C\#访问MySQL数据库的ADO.NET驱动程序

下载地址为：

http://dev.mysql.com/downloads/connector/net/6.0.html

我下载的版本为： mysql-connector-net-6.3.8.msi

下载地址如下url:

[http://dev.mysql.com/downloads/mirror.php?id=405442][http_dev.mysql.com_downloads_mirror.php_id_405442]

(2)安装mysql-connector-net

然后直接在Windows操作系统安装 mysql-connector-net-6.3.8.msi

默认是安装在C盘：

C:\\Program Files\\MySQL\\MySQL Connector Net 6.3.8\\Assemblies

v2.0

v4.0

安装完后我选择的是v2.0版本的

然后在应用工程中引用组件MySQL.Data.dll

(3)封装数据库访问组件DbConnectionMySQL

**\[csharp\]**  [view plain][] [copy][view plain]

1.  /// <summary>  
2.      /// MySQL数据库   
3.      /// 版本 mysql-connector-net-6.3.8.msi  
4.      /// vp:hsg  
5.      /// create date:2012-02-28  
6.      /// </summary>  
7.      \[Serializable\]  
8.      **public** **class** DbConnectionMySQL : DbConnectionWrapper  
9.      \{  
10.         **public** DbConnectionMySQL(**string** pConnectionString)  
11.             : **base**(pConnectionString)  
12.         \{  
13.               
14.             **this**.m\_dbconn = **new** MySqlConnection(pConnectionString);  
15.             **this**.m\_DbConnState = DbConnState.Free;  
16.         \}  
17.   
18.         //--  
19.         **public** **override** DbDataAdapter GetDbDataAdapter()  
20.         \{  
21.             **return** **new** MySqlDataAdapter();  
22.         \}  
23.         **public** **override** DbDataAdapter GetDbDataAdapter(DbCommand dbCommand)  
24.         \{  
25.             **return** **new** MySqlDataAdapter(dbCommand **as** MySqlCommand);  
26.         \}  
27.         **public** **override** DbCommand GetDbCommand()  
28.         \{  
29.             **return** **new** MySqlCommand();  
30.         \}  
31.         **public** **override** DbConnection GetDbConnection()  
32.         \{  
33.             **return** **new** MySqlConnection();  
34.         \}  
35.         **public** **override** DbCommandBuilder GetDbCommandBuilder()  
36.         \{  
37.             **return** **new** MySqlCommandBuilder();  
38.         \}  
39.   
40.         **public** **override** DataProviderType GetCurrentDataProviderType()  
41.         \{  
42.             **return** DataProviderType.Sql;  
43.         \}  
44.   
45.         **public** **override** **bool** IsExistsTable(**string** TableName, **string** UserName)  
46.         \{  
47.             \#region information  
48.             **bool** rbc = **false**;    //TABLES表中去查询 table\_name  
49.             **string** dSql = "select \* from TABLES where table\_name='" + TableName + "'";  
50.             DataSet ds = **this**.ExecuteDataSet(dSql);  
51.             **if** (ds != **null**)  
52.             \{  
53.                 **if** (ds.Tables\[0\].Rows.Count > 0)  
54.                 \{  
55.                     rbc = **true**;  
56.                 \}  
57.                 **else**  
58.                 \{  
59.                     rbc = **false**;  
60.                 \}  
61.             \}  
62.             **else**  
63.             \{  
64.                 rbc = **false**;  
65.             \}  
66.             **return** rbc;  
67.             \#endregion  
68.         \}  
69.         **public** **override** **bool** IsExistsField(**string** FieldName, **string** TableName)  
70.         \{  
71.             \#region information  
72.             **bool** rbc = **false**;  
73.             **string** dSql = "";  
74.             dSql = "select \* from " + TableName + " where 1<>1";  
75.             DataSet ds = **this**.ExecuteDataSet(dSql);  
76.             **if** (ds != **null**)  
77.             \{  
78.                 DataTable dt = ds.Tables\[0\];  
79.                 **for** (**int** j = 0; j < dt.Columns.Count; j++)  
80.                 \{  
81.                     **if** (dt.Columns\[j\].ColumnName.ToString().ToUpper() == FieldName.ToString().ToUpper())  
82.                     \{  
83.                         rbc = **true**;  
84.                         **goto** Return\_End;  
85.                     \}  
86.                 \}  
87.                 dt.Dispose();  
88.                 dt = **null**;  
89.             \}  
90.             ds.Dispose();  
91.             ds = **null**;  
92.   
93.         Return\_End:  
94.   
95.             **return** rbc;  
96.             \#endregion  
97.         \}  
98.   
99.         **public** **override** **char** ParameterChar  
100.         \{  
101.             **get**  
102.             \{  
103.                 **return** ':';   //SQLite的参数符号为:  
104.             \}  
105.         \}  
106.   
107.         **public** **override** DbParameter CreateParameter(**string** name, **object** value)  
108.         \{  
109.             **return** **new** MySqlParameter(name, value);  
110.         \}  
111.   
112.         **public** **override** DbParameter CreateParameter(**string** name)  
113.         \{  
114.             DbParameter dbp = **new** MySqlParameter();  
115.             dbp.ParameterName = name;  
116.             **return** dbp;  
117.         \}  
118.         **public** **override** DbParameter CreateParameter(**string** name, DbType dbtype, **object** value)  
119.         \{  
120.             DbParameter dbp = **new** MySqlParameter();  
121.             dbp.ParameterName = name;  
122.             dbp.Value = value;  
123.             dbp.DbType = dbtype;  
124.             **return** dbp;  
125.         \}  
126.         **public** **override** DbParameter CreateParameter(**string** name, DbType dbtype, **int** size, **object** value)  
127.         \{  
128.             DbParameter dbp = **new** MySqlParameter();  
129.             dbp.ParameterName = name;  
130.             dbp.Value = value;  
131.             dbp.DbType = dbtype;  
132.             dbp.Size = size;  
133.             **return** dbp;  
134.         \}  
135.     \}

(4)客户端访问测试开发实例

**\[csharp\]**  [view plain][] [copy][view plain]

1.  **public** **void** TestCShape\_MySQL()  
2.          \{  
3.              **string** constr = "server=localhost;User Id=root;password=root;Database=xp\_users";  
4.              DbConnectionWrapper dbw = **new** DbConnectionMySQL(constr);  
5.              **bool** rbc=dbw.TestConnection();  
6.              **this**.Context.Response.Write(rbc);  
7.                           
8.    
9.              **string** x = "";  
10.             //删除语句  
11.             x = "delete from xp\_users";  
12.             **if** (dbw.ExecuteQuery(x) > 0)  
13.             \{  
14.                 **this**.Context.Response.Write("删除语句成功!下面是SQL语句<br>" + x);  
15.             \}  
16.             //插入语句  
17.             x = "insert into xp\_users(gid,uid,uname,sex,email,pwd) values('";  
18.             x += "1','hsg77','何XXX',1,'hsg77@163.com','1')";  
19.             **if** (dbw.ExecuteQuery(x) > 0)  
20.             \{  
21.                 **this**.Context.Response.Write("插入语句成功!下面是SQL语句<br>"\+x);  
22.             \}  
23.             //查询语句  
24.             DataTable dt = dbw.ExecuteDataTable("select \* from xp\_users");  
25.             **if** (dt != **null** && dt.Rows.Count > 0)  
26.             \{  
27.                 **this**.Context.Response.Write("<br>用户数:"\+dt.Rows.Count);  
28.             \}  
29.             **if** (dt != **null**)  
30.             \{  
31.                 dt.Dispose();  
32.                 dt = **null**;  
33.             \}  
34.             dbw.Dispose();  
35.             dbw = **null**;  
36.         \}

\----the---end---

[http_dev.mysql.com_downloads_mirror.php_id_405442]: http://dev.mysql.com/downloads/mirror.php?id=405442
[view plain]: http://blog.csdn.net/hsg77/article/details/7302880#