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}, ddddd:{1}, {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 { // , 有兴趣的朋友,可以看看这个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(); } } }