C#连接mysql数据库完整实例
本文实例讲述了C#连接mysql数据库的方法。分享给大家供大家参考。具体实现方法如下:
usingSystem;
usingSystem.Configuration;
usingMySql.Data.MySqlClient;
///<summary>
///TestDatebase的摘要说明
///</summary>
publicclassTestDatebase
{
publicTestDatebase()
{
//
//TODO:在此处添加构造函数逻辑
//
}
publicstaticvoidMain(String[]args)
{
MySqlConnectionmysql=getMySqlCon();
//查询sql
StringsqlSearch="select*fromstudent";
//插入sql
StringsqlInsert="insertintostudentvalues(12,'张三',25,'大专')";
//修改sql
StringsqlUpdate="updatestudentsetname='李四'whereid=3";
//删除sql
StringsqlDel="deletefromstudentwhereid=12";
//打印SQL语句
Console.WriteLine(sqlDel);
//四种语句对象
//MySqlCommandmySqlCommand=getSqlCommand(sqlSearch,mysql);
//MySqlCommandmySqlCommand=getSqlCommand(sqlInsert,mysql);
//MySqlCommandmySqlCommand=getSqlCommand(sqlUpdate,mysql);
MySqlCommandmySqlCommand=getSqlCommand(sqlDel,mysql);
mysql.Open();
//getResultset(mySqlCommand);
//getInsert(mySqlCommand);
//getUpdate(mySqlCommand);
getDel(mySqlCommand);
//记得关闭
mysql.Close();
StringreadLine=Console.ReadLine();
}
///<summary>
///建立mysql数据库链接
///</summary>
///<returns></returns>
publicstaticMySqlConnectiongetMySqlCon()
{
StringmysqlStr="Database=test;DataSource=127.0.0.1;UserId=root;Password=root;pooling=false;CharSet=utf8;port=3306";
//StringmySqlCon=ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
MySqlConnectionmysql=newMySqlConnection(mysqlStr);
returnmysql;
}
///<summary>
///建立执行命令语句对象
///</summary>
///<paramname="sql"></param>
///<paramname="mysql"></param>
///<returns></returns>
publicstaticMySqlCommandgetSqlCommand(Stringsql,MySqlConnectionmysql)
{
MySqlCommandmySqlCommand=newMySqlCommand(sql,mysql);
//MySqlCommandmySqlCommand=newMySqlCommand(sql);
//mySqlCommand.Connection=mysql;
returnmySqlCommand;
}
///<summary>
///查询并获得结果集并遍历
///</summary>
///<paramname="mySqlCommand"></param>
publicstaticvoidgetResultset(MySqlCommandmySqlCommand)
{
MySqlDataReaderreader=mySqlCommand.ExecuteReader();
try
{
while(reader.Read())
{
if(reader.HasRows)
{
Console.WriteLine("编号:"+reader.GetInt32(0)+"|姓名:"+reader.GetString(1)+"|年龄:"+reader.GetInt32(2)+"|学历:"+reader.GetString(3));
}
}
}
catch(Exception)
{
Console.WriteLine("查询失败了!");
}
finally
{
reader.Close();
}
}
///<summary>
///添加数据
///</summary>
///<paramname="mySqlCommand"></param>
publicstaticvoidgetInsert(MySqlCommandmySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch(Exceptionex)
{
Stringmessage=ex.Message;
Console.WriteLine("插入数据失败了!"+message);
}
}
///<summary>
///修改数据
///</summary>
///<paramname="mySqlCommand"></param>
publicstaticvoidgetUpdate(MySqlCommandmySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch(Exceptionex)
{
Stringmessage=ex.Message;
Console.WriteLine("修改数据失败了!"+message);
}
}
///<summary>
///删除数据
///</summary>
///<paramname="mySqlCommand"></param>
publicstaticvoidgetDel(MySqlCommandmySqlCommand)
{
try
{
mySqlCommand.ExecuteNonQuery();
}
catch(Exceptionex)
{
Stringmessage=ex.Message;
Console.WriteLine("删除数据失败了!"+message);
}
}
}
希望本文所述对大家的C#程序设计有所帮助。