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

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"]);
      }
      
      
    }

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(); 
    } 
  } 
}