您好,登錄后才能下訂單哦!
實(shí)現(xiàn)代碼一、使用的是mysql自帶的驅(qū)動安裝一下即可
這是一個簡單的例子。
在這里有個問題:dataset如果沒設(shè)主鍵的話,可能會引起一些對數(shù)庫操作的問題,比如會造成updata出現(xiàn)錯誤。
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關(guān)閉"); Console.WriteLine("DBConn關(guān)閉"); DBReader.Close(); //DBConn.Close(); } for (int i = 0; i < myDataSet.Tables["manavatar"].Rows.Count; i++) { Console.WriteLine("{0}",myDataSet.Tables["manavatar"].Rows[2]["user"]); } }
方法二、
貼一份示例代碼。非常適合于初學(xué)者使用。
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數(shù)據(jù)庫的方法,需要的朋友可以參考一下。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。