其中包括2个变量:message、number。
下载mysql-connector-net-8.0.12并安装,在引用里添加mysql.data。
using mysql.data.mysqlclient;这句话要写上。如图所示
建立在已经安装mysql数据库的前提,默认安装在c:\program files (x86)\mysql,建议在安装时选中connector.net 8.0.12的安装,里面有mysql与c#连接的动态链接库。
帮助文档c:\program files (x86)\mysql\connector.net 8.0.12\documentation\connectornet.chm是我撰写此文章的主要依据。其中users guide下,programming是对动态链接库8个类的介绍,tutorial是案例代码。
连接数据库、操作数据库,本质是利用数据库提供的动态链接库mysql.data.dll进行操作。mysql.data.dll提供以下8个类:
mysqlconnection: 连接mysql服务器数据库。
mysqlcommand:执行一条sql语句。
mysqldatareader: 包含sql语句执行的结果,并提供一个方法从结果中阅读一行。
mysqltransaction: 代表一个sql事务在一个mysql数据库。
mysqlexception: mysql报错时返回的exception。
mysqlcommandbuilder: automatically generates single-table commands used to reconcile changes made to a dataset with the associated mysql database.
mysqldataadapter: represents a set of data commands and a database connection that are used to fill a data set and update a mysql database.
mysqlhelper: helper class that makes it easier to work with the provider.
1.添加动态链接库文件方法一:visual studio,在 项目(右键)-管理nuget程序包(n) 然后在浏览里面搜索mysql.data并进行安装。
方法二:安装数据库mysql时要选中connector.net 6.9的安装,将c:\program files (x86)\mysql\connector.net 8.0.12\assemblies里v4.0或v4.5中的mysql.data.dll添加到项目的引用。v4.0和v4.5,对应visual studio具体项目 属性-应用程序-目标框架 里的.net framework的版本号。
2.建立连接(mysqlconnection类)= =
3.捕捉异常(mysqlexception类)连接错误时mysqlconnection会返回一个mysqlexception,其中包括2个变量:
message: a message that describes the current exception.
number: the mysql error number. (0: cannot connect to server. 1045: invalid user name and/or password.)
catch (mysqlexception ex){ switch (ex.number) { case 0: console.writeline("cannot connect to server. contact administrator"); break; case 1045: console.writeline("invalid username/password, please try again"); break; }}
4.增删查改的代码(mysqlcommand类、mysqldatareader类)executereader——用于查询数据库。查询结果是返回mysqldatareader对象,mysqldatareader包含sql语句执行的结果,并提供一个方法从结果中阅读一行。
executenonquery——用于插入、更新和删除数据。
executescalar——用于查询数据时,返回查询结果集中第一行第一列的值,即只返回一个值。
(1) 查询
a.查询条件固定
string sql= "select * from user";mysqlcommand cmd = new mysqlcommand(sql,conn);mysqldatareader reader =cmd.executereader();//执行executereader()返回一个mysqldatareader对象while (reader.read())//初始索引是-1,执行读取下一行数据,返回值是bool{ //console.writeline(reader[0].tostring() + reader[1].tostring() + reader[2].tostring()); //console.writeline(reader.getint32(0)+reader.getstring(1)+reader.getstring(2)); console.writeline(reader.getint32("userid") + reader.getstring("username") + reader.getstring("password"));//"userid"是数据库对应的列名,推荐这种方式}
b.查询条件不固定
//string sql = "select * from user where username='"+username+"' and password='"+password+"'"; //我们自己按照查询条件去组拼string sql = "select * from user where username=@para1 and password=@para2";//在sql语句中定义parameter,然后再给parameter赋值mysqlcommand cmd = new mysqlcommand(sql, conn);cmd.parameters.addwithvalue("para1", username);cmd.parameters.addwithvalue("para2", password);mysqldatareader reader = cmd.executereader();if (reader.read())//如果用户名和密码正确则能查询到一条语句,即读取下一行返回true{ return true;}
c.需要查询返回一个值
string sql = "select count(*) from user";mysqlcommand cmd = new mysqlcommand(sql, conn);object result=cmd.executescalar();//执行查询,并返回查询结果集中第一行的第一列。所有其他的列和行将被忽略。select语句无记录返回时,executescalar()返回null值if (result != null){ int count = int.parse(result.tostring());}
(2) 插入、删除、更改
string sql = "insert into user(username,password,registerdate) values('啊宽','123','"+datetime.now+"')";//string sql = "delete from user where userid='9'";//string sql = "update user set username='啊哈',password='123' where userid='8'";mysqlcommand cmd = new mysqlcommand(sql,conn);int result =cmd.executenonquery();//3.执行插入、删除、更改语句。执行成功返回受影响的数据的行数,返回1可做true判断。执行失败不返回任何数据,报错,下面代码都不执行
5.事务(mysqltransaction类)string connetstr = "server=127.0.0.1;user=root;password=root;database=minecraftdb;";mysqlconnection conn = new mysqlconnection(connetstr);conn.open();//必须打开通道之后才能开始事务mysqltransaction transaction = conn.begintransaction();//事务必须在try外面赋值不然catch里的transaction会报错:未赋值console.writeline("已经建立连接");try{ string date = datetime.now.year + "-" + datetime.now.month + "-" + datetime.now.day; string sql1= "insert into user(username,password,registerdate) values('啊宽','123','" + date + "')"; mysqlcommand cmd1 = new mysqlcommand(sql1,conn); cmd1.executenonquery(); string sql2 = "insert into user(username,password,registerdate) values('啊宽','123','" + date + "')"; mysqlcommand cmd2 = new mysqlcommand(sql2, conn); cmd2.executenonquery();}catch (mysqlexception ex){ console.writeline(ex.message); transaction.rollback();//事务executenonquery()执行失败报错,username被设置unique conn.close();}finally{ if (conn.state != connectionstate.closed) { transaction.commit();//事务要么回滚要么提交,即rollback()与commit()只能执行一个 conn.close(); }}
结语:连接数据库、操作数据库,本质是利用数据库提供的动态链接库mysql.data.dll进行操作。动态链接库中的8个类上面常用操作只用到了类1-5,类6-8 的相关操作未涉及, 大家可以去看帮助文档c:\program files (x86)\mysql\connector.net 8.0.12\documentation\connectornet.chm学习。
相关文章:
c# using mysql
mysql connector c/c++ 多线程封装
以上就是c#如何连接mysql数据库?详解报错异常和增删改查的详细内容。
