[.NET開發] C#鏈接MySQL的兩個簡單代碼示例

  實現代碼1、使用的是mysql自帶的驅動安裝一下便可mysql

  這是一個簡單的例子。程序員

  在這裏有個問題:dataset若是沒設主鍵的話,可能會引發一些對數庫操做的問題,好比會形成updata出現錯誤。sql

  static void Main(string[] args)數據庫

  {c#

  string sqlstr = "select * from manavatar";網絡

  MySQLConnection DBConn = new MySQLConnection(new MySQLConnectionString("192.168.0.13", "flashdata", "root", "root", 3306).AsString);spa

  DBConn.Open();orm

  //MySQLDataAdapter myadap = new MySQLDataAdapter(sqlstr, conn);server

  MySQLCommand DBComm = new MySQLCommand(sqlstr,DBConn);string

  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:小貝,\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"]);

  }

  }

  複製代碼

  方法2、

  貼一份示例代碼。很是適合於初學者使用。

  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=小貝; 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 = 小貝" , 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數據庫的方法,須要的朋友能夠參考一下。

  (編輯:雷林鵬 來源:網絡)

相關文章
相關標籤/搜索