C#连接mysql数据库完整实例

内容摘要
本文实例讲述了C#连接mysql数据库的方法。分享给大家供大家参考。具体实现方法如下：


using System;
using System.Configuration;
using MySql.Data.MySqlClient;
/// <sum
文章正文

本文实例讲述了C#连接mysql数据库的方法。分享给大家供大家参考。具体实现方法如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
using System;
using System.Configuration;
using MySql.Data.MySqlClient;
/// <summary>
/// TestDatebase 的摘要说明
/// </summary>
public class TestDatebase
{
  public TestDatebase()
  {
    //
    // TODO: 在此处添加构造函数逻辑
    //
  }
  public static void Main(String[] args)
  {
    MySqlConnection mysql = getMySqlCon();
    //查询sql
    String sqlSearch = "select * from student";
    //插入sql
    String sqlInsert = "insert into student values (12,'张三',25,'大专')";
    //修改sql
    String sqlUpdate = "update student set name='李四' where id= 3";
    //删除sql
    String sqlDel = "delete from student where id = 12";
    //打印SQL语句
    Console.WriteLine(sqlDel);
    //四种语句对象
    //MySqlCommand mySqlCommand = getSqlCommand(sqlSearch, mysql);
    //MySqlCommand mySqlCommand = getSqlCommand(sqlInsert, mysql);
    //MySqlCommand mySqlCommand = getSqlCommand(sqlUpdate, mysql);
    MySqlCommand mySqlCommand = getSqlCommand(sqlDel, mysql);
    mysql.Open();
    //getResultset(mySqlCommand);
    //getInsert(mySqlCommand);
    //getUpdate(mySqlCommand);
    getDel(mySqlCommand);
    //记得关闭
    mysql.Close();
    String readLine = Console.ReadLine();
  }
  /// <summary>
  /// 建立mysql数据库链接
  /// </summary>
  /// <returns></returns>
  public static MySqlConnection getMySqlCon()
  {
    String mysqlStr = "Database=test;Data Source=127.0.0.1;User Id=root;Password=root;pooling=false;CharSet=utf8;port=3306";
    // String mySqlCon = ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
    MySqlConnection mysql = new MySqlConnection(mysqlStr);
    return mysql;
  }
  /// <summary>
  /// 建立执行命令语句对象
  /// </summary>
  /// <param name="sql"></param>
  /// <param name="mysql"></param>
  /// <returns></returns>
  public static MySqlCommand getSqlCommand(String sql,MySqlConnection mysql)
  {
    MySqlCommand mySqlCommand = new MySqlCommand(sql, mysql);
    // MySqlCommand mySqlCommand = new MySqlCommand(sql);
    // mySqlCommand.Connection = mysql;
    return mySqlCommand;
  }
  /// <summary>
  /// 查询并获得结果集并遍历
  /// </summary>
  /// <param name="mySqlCommand"></param>
  public static void getResultset(MySqlCommand mySqlCommand)
  {
    MySqlDataReader reader = mySqlCommand.ExecuteReader();
    try
    {
      while (reader.Read())
      {
        if (reader.HasRows)
        {
          Console.WriteLine("编号:" + reader.GetInt32(0) + "|姓名:" + reader.GetString(1) + "|年龄:" + reader.GetInt32(2) + "|学历:" + reader.GetString(3));
        }
      }
    }
    catch (Exception)
    {
      Console.WriteLine("查询失败了！");
    }
    finally
    {
      reader.Close();
    }
  }
  /// <summary>
  /// 添加数据
  /// </summary>
  /// <param name="mySqlCommand"></param>
  public static void getInsert(MySqlCommand mySqlCommand)
  {
    try
    {
      mySqlCommand.ExecuteNonQuery();
    }
    catch (Exception ex)
    {
      String message = ex.Message;
      Console.WriteLine("插入数据失败了！" + message);
    }
    
  }
  /// <summary>
  /// 修改数据
  /// </summary>
  /// <param name="mySqlCommand"></param>
  public static void getUpdate(MySqlCommand mySqlCommand)
  {
    try
    {
      mySqlCommand.ExecuteNonQuery();
    }
    catch (Exception ex)
    {
      String message = ex.Message;
      Console.WriteLine("修改数据失败了！" + message);
    }
  }
  /// <summary>
  /// 删除数据
  /// </summary>
  /// <param name="mySqlCommand"></param>
  public static void getDel(MySqlCommand mySqlCommand)
  {
    try
    {
      mySqlCommand.ExecuteNonQuery();
    }
    catch (Exception ex)
    {
      String message = ex.Message;
      Console.WriteLine("删除数据失败了！" + message);
    }
  }
}

希望本文所述对大家的C#程序设计有所帮助。
代码注释
上一篇网页右侧悬浮滚动在线qq客服代码示例下一篇如何学习Javascript入门指导

作者：喵哥笔记

IDC笔记

学的不仅是技术，更是梦想！