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

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

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

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

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数据库的方法，需要的朋友可以参考一下。