实现代码一、使用的是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测试数据/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数据库的方法，需要的朋友可以参考一下。
dy("nrwz");
查看更多关于C#连接MySQL的两个简单代码示例的详细内容...