实现代码一、使用的是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数据库的方法，需要的朋友可以参考一下。