正文

C#连接MySQL的两个简单代码示例

︶ㄣ米米素材网 メ
米米素材网V管理员 / 阅读
0708

这篇文章主要介绍了C#连接MySQL的简单代码示例,需要的朋友可以参考下

实现代码一、使用的是mysql自带的驱动安装一下即可

这是一个简单的例子。
在这里有个问题：dataset如果没设主键的话，可能会引起一些对数库操作的问题，比如会造成updata出现错误。

?
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
static void Main(string[] args)
    {
      string sqlstr = "select * from manavatar";
      MySQLConnection DBConn = new MySQLConnection(new MySQLConnectionString("192.168.0.13", "flashdata", "root", "root", 3306).AsString);
      DBConn.Open();
      //MySQLDataAdapter myadap = new MySQLDataAdapter(sqlstr, conn);
      MySQLCommand DBComm = new MySQLCommand(sqlstr,DBConn);
      MySQLDataReader DBReader = DBComm.ExecuteReaderEx(); //DBComm.ExecuteReaderEx();
      MySQLDataAdapter DTAdapter = new MySQLDataAdapter(sqlstr,DBConn);
      
      DataSet myDataSet = new DataSet();
      DTAdapter.Fill(myDataSet,"manavatar");
     
     
      try
      {
        while (DBReader.Read())
        {
          //Console.WriteLine("11");
          Console.WriteLine("DBReader:{0},\t\t\tddddd:{1},\t\t {2}",DBReader.GetString(0), DBReader.GetString(1),DBReader.GetString(3));
        }
        Console.WriteLine("0000");
      }
      catch (Exception e)
      {
        Console.WriteLine("读入失败！"+e.ToString());
      }
      finally
      {
        Console.WriteLine("DBReader关闭");
        Console.WriteLine("DBConn关闭");
        DBReader.Close();
        //DBConn.Close();
      }
      
      for (int i = 0; i < myDataSet.Tables["manavatar"].Rows.Count; i++)
      {
        Console.WriteLine("{0}",myDataSet.Tables["manavatar"].Rows[2]["user"]);
      }
      
      
    }

方法二、

贴一份示例代码。非常适合于初学者使用。
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
using System;
using System.Collections.Generic;
using System.Text;
 
using MySql.Data.MySqlClient;
using System.Data;
using System.Data.Common;
 
namespace SybaseUtilTest
{
  class Program
  {
    // http://bugs.mysql.com/47422, 有兴趣的朋友,可以看看这个bug是怎么回事
    static void testDataAdapter()
    {
      try
      {
        MySqlClientFactory factory = MySqlClientFactory.Instance;
        DbConnection conn = factory.CreateConnection();
        conn.ConnectionString = string.Format("server={0};user id={1}; password={2}; database={3}; port={4}; pooling=false",
              "localhost", "root", "passwd", "test", 3306);
        conn.Open();
 
        DbDataAdapter da = factory.CreateDataAdapter();
 
        da.SelectCommand = conn.CreateCommand();
        da.SelectCommand.CommandText = "select * from t12345";
 
 
        da.DeleteCommand = conn.CreateCommand();
        da.DeleteCommand.CommandText = "delete from t12345 where id = @id";
 
        DbParameter param = factory.CreateParameter();
        param.ParameterName = "@id";
        param.DbType = DbType.Int32;
        param.SourceColumn = "id";
        param.SourceVersion = DataRowVersion.Current;
 
        da.DeleteCommand.Parameters.Add(param);
        da.DeleteCommand.UpdatedRowSource = UpdateRowSource.None;
 
        DataTable dt = new DataTable("t12345");
        da.Fill(dt);
 
        int index = 0;
        foreach ( DataRow o in dt.Rows )
        {
          if (o["id"].Equals(4))
          {
            Console.WriteLine(String.Format("index={0}, to delete id = 4, col2 = {1}" , index, o["col2"]));
            break;
          }
          index++;
        }
        dt.Rows[index].Delete();
        da.Update(dt);
        dt.AcceptChanges();
 
        da.Dispose();
        conn.Close();
      }
      catch (Exception ex)
      {
        Console.WriteLine(ex.Source + " "
          + ex.Message + " "
          + ex.StackTrace);
      }
       
    }
     
    static void Main(string[] args)
    {
      testDataAdapter();
    }
  }
}

以上就是米米素材网小编为大家整理的c#连接mysql数据库的方法，需要的朋友可以参考一下。