您的位置：首页 > 游戏 > 手游 > 《网页设计与制作》实验报告_网页编程代码_移动排名提升软件_成都seo的方法

《网页设计与制作》实验报告_网页编程代码_移动排名提升软件_成都seo的方法

2024/12/7 12:55:08 来源：https://blog.csdn.net/sunsddd/article/details/143646537  浏览:  次   关键词：《网页设计与制作》实验报告_网页编程代码_移动排名提升软件_成都seo的方法
《网页设计与制作》实验报告_网页编程代码_移动排名提升软件_成都seo的方法

摘要

        本篇文章主要介绍C#链接MySQL数据库的接口介绍，使用实例及注意事项，辅助类的封装及调用实例，可以直接移植到项目里面使用。

目录

1、添加引用
2、接口介绍
     2.1、MySqlConnection
     2.2、MySqlCommand
     2.3、MySqlDataReader
     2.4、MySqlDataAdapter
     2.5、MySqlTransaction
3、全网功能最全辅助类实现
4、辅助类调用实例

1、添加引用

IDE为Visual Studio 2022，选择工具->NuGet包管理器->管理解决方案的NuGet程序包

选择浏览，在输入框中输入MySql进行搜索，选中MySql.Data选项

版本选择和数据库安装版本最接近的，我这里选择8.0.33版本，然后点击安装，安装完成后引用自动添加完成。

2、接口介绍

访问数据库主要用到如下几个类，下面对其功能进行依次介绍

2.1、MySqlConnection

功能：建立数据库连接，通过MySqlConnection对象，可以建立与MySQL数据库的连接，以便执行SQL语句和访问数据。

常用方法和属性：

Open()用于打开连接

Close()用于关闭连接

State获取当前MySqlConnection对象数据库链接状态

使用实例

static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作//关闭数据库conn.Close();
}

2.2、MySqlCommand

MySqlCommand类是.NET Framework中用于与MySQL数据库交互的一个重要类，它属于MySql.Data.MySqlClient命名空间。这个类提供了一系列方法和属性，用于执行SQL语句、管理事务、处理参数化查询等。以下是对MySqlCommand类接口的详细说明：

MySqlCommand类的构造函数

MySqlCommand类提供了多个构造函数，允许用户以不同的方式创建MySqlCommand对象。常用的构造函数包括：

接受一个SQL语句字符串和一个MySqlConnection对象作为参数的构造函数。

仅接受一个SQL语句字符串作为参数的构造函数（但通常需要在后续操作中设置Connection属性以指定数据库连接）。

主要方法和属性

CommandText属性：获取或设置要执行的SQL语句或存储过程的名称。

Connection属性：获取或设置与MySQL数据库的连接。

CommandType属性：获取或设置CommandText属性的类型（如Text、StoredProcedure等）。

Parameters属性：获取表示参数集合的MySqlParameterCollection对象，用于参数化查询。

ExecuteNonQuery方法：执行诸如INSERT、UPDATE、DELETE等非查询SQL语句，并返回受影响的行数。

ExecuteReader方法：执行诸如SELECT等查询SQL语句，并返回一个MySqlDataReader对象，用于读取查询结果。

ExecuteScalar方法：执行查询，并返回查询结果中的第一行第一列的值。如果查询结果为空，则返回null。

2.3、MySqlDataReader

MySqlDataReader是.NET Framework中用于从MySQL数据库中读取数据的一个快速、高效的类。以下是对MySqlDataReader接口的详细说明：

基本功能

MySqlDataReader允许你从MySQL数据库中读取数据行，并且以只读、向前只进的方式访问数据集中的每一行。它提供了一种从数据库中检索数据的高效方法，特别是在处理大量数据时。

使用方法

创建数据库连接：首先，你需要创建一个MySqlConnection对象，并使用适当的连接字符串打开与MySQL数据库的连接。

执行SQL查询：然后，创建一个MySqlCommand对象，将你的SQL查询语句传递给该对象，并指定要使用的MySqlConnection对象。

读取数据：接下来，使用MySqlCommand对象的ExecuteReader方法执行查询，并返回一个MySqlDataReader对象。你可以通过调用MySqlDataReader对象的Read方法逐行读取数据。

使用实例

static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接string strSql;//插入一条数据strSql = "insert into t_user (user_name,password,nick_name,user_no,status,phone) values('张三6','12345678','红太阳','131024685941523145',0,'13465231586')";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//修改一条数据strSql = "update t_user set nick_name = '王麻子' where id = 1";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//删除一条数据strSql = "delete from t_user where id = 11";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();//执行查询，并返回查询结果中的第一行第一列的值strSql = "select count(*) from t_user";cmd.CommandText = strSql;//执行的SQL语句Object resutl = cmd.ExecuteScalar();Console.WriteLine(resutl.ToString());//查看所有数据strSql = "select * from t_user";cmd.CommandText = strSql;MySqlDataReader reader = cmd.ExecuteReader();for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if(i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();//关闭数据库conn.Close();Console.ReadKey();
}

2.4、MySqlDataAdapter

MySqlDataAdapter类是ADO.NET提供的一个用于与MySQL数据库进行交互的重要类，它充当DataSet和MySQL数据库之间的桥梁，用于检索和保存数据。以下是对MySqlDataAdapter类的详细说明：

主要功能

数据检索：MySqlDataAdapter通过Fill方法从MySQL数据库中检索数据，并将数据填充到DataSet或DataTable对象中。这允许开发人员在内存中存储和操作数据库数据。

数据更新：除了检索数据外，MySqlDataAdapter还可以通过Update方法将DataSet或DataTable对象中的更改保存回MySQL数据库。这实现了数据的双向同步。

命令管理：MySqlDataAdapter包含SelectCommand、InsertCommand、DeleteCommand和UpdateCommand等属性，这些属性允许开发人员指定用于执行相应数据库操作的SQL命令。

使用方法

创建连接：首先，需要创建一个MySqlConnection对象来打开与MySQL数据库的连接。

创建命令：然后，创建一个MySqlCommand对象，并设置其CommandText属性为要执行的SQL语句。此外，还可以根据需要设置其他属性，如CommandType和Parameters等。

创建适配器：接下来，创建一个MySqlDataAdapter对象，并将之前创建的MySqlCommand对象传递给它。这样，MySqlDataAdapter就知道要执行哪个SQL语句来检索或更新数据。

执行操作

要检索数据，调用MySqlDataAdapter的Fill方法，并将DataSet或DataTable对象作为参数传递给它。Fill方法将执行SQL语句，并将结果填充到指定的DataSet或DataTable对象中。

要更新数据，首先修改DataSet或DataTable对象中的数据，然后调用MySqlDataAdapter的Update方法。Update方法将使用适当的SQL语句（如INSERT、UPDATE或DELETE）将更改保存回MySQL数据库。

重要属性

SelectCommand：获取或设置用于从数据库中选择数据的SQL命令对象。

InsertCommand：获取或设置用于向数据库中插入数据的SQL命令对象。

UpdateCommand：获取或设置用于更新数据库中数据的SQL命令对象。

DeleteCommand：获取或设置用于从数据库中删除数据的SQL命令对象。

TableMappings：获取或设置用于简化数据的加载和更新操作的表映射信息。

注意事项

资源管理：由于MySqlDataAdapter使用了非托管资源，因此在使用完毕后应确保正确释放资源。通常，可以使用using语句来自动管理MySqlDataAdapter对象的生命周期。

异常处理：在执行数据库操作时，应始终考虑异常处理。可以使用try-catch块来捕获和处理可能发生的异常，如连接失败、查询错误等。

性能优化：在处理大量数据时，应注意性能优化。例如，可以使用参数化查询来提高查询效率和安全性；可以通过设置适当的命令超时时间来避免长时间等待数据库响应等

使用实例

static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接//查看所有数据string strSql = "select * from t_user";cmd.CommandText = strSql;DataTable table = new DataTable();MySqlDataAdapter adapter = new MySqlDataAdapter(cmd);adapter.Fill(table);if (table.Rows.Count > 0){//打印所有列名string columnName = string.Empty;for (int i = 0; i < table.Columns.Count; i++){columnName += table.Columns[i].ColumnName + " | ";}Console.WriteLine(columnName);Console.WriteLine("-------------------------");//打印每一行的数据foreach (DataRow row in table.Rows){string columnStr = string.Empty;foreach (DataColumn column in table.Columns){columnStr += row[column] + " | ";}Console.WriteLine(columnStr);}}//关闭数据库conn.Close();Console.ReadKey();
}

2.5、MySqlTransaction

MySqlTransaction类是ADO.NET中用于在MySQL数据库上执行事务操作的类。事务是一组要么全都成功要么全都失败的数据库操作序列，它确保了数据的一致性和完整性。以下是对MySqlTransaction类接口的详细说明：

主要功能和用途

MySqlTransaction类主要用于在MySQL数据库上开始、提交和回滚事务。它提供了对事务边界的控制，确保了一组数据库操作要么全部成功，要么在遇到错误时全部回滚，从而保持数据的一致性和完整性。

重要方法和属性

BeginTransaction方法

功能：开始一个数据库事务。

返回值：返回一个MySqlTransaction对象，表示新开始的事务。

注意事项：在开始事务之前，必须确保已经建立了与MySQL数据库的连接，并且该连接是打开的。

Commit方法

功能：提交当前事务中的所有更改，并将它们永久保存到数据库中。

返回值：无。

注意事项：在调用Commit方法之前，必须确保所有的数据库操作都已经成功完成，并且没有发生任何错误。

Rollback方法

功能：回滚当前事务中的所有更改，撤销自事务开始以来所做的所有操作。

返回值：无。

注意事项：在发生错误或需要取消事务时，应调用Rollback方法来撤销所做的更改。

IsolationLevel属性

功能：获取或设置当前事务的隔离级别。

隔离级别选项：包括读未提交（ReadUncommitted）、读已提交（ReadCommitted）、可重复读（RepeatableRead）和可串行化（Serializable）等。

注意事项：隔离级别决定了事务之间的可见性和并发性。选择合适的隔离级别对于确保数据的一致性和优化性能至关重

使用步骤和示例

建立数据库连接：首先，需要创建一个MySqlConnection对象来打开与MySQL数据库的连接。

开始事务：通过调用BeginTransaction方法来开始一个新的事务。这将返回一个MySqlTransaction对象，用于表示该事务。

执行数据库操作：在事务的上下文中执行所需的数据库操作。这些操作可以是插入、更新、删除等。

提交或回滚事务：根据操作的结果，决定是调用Commit方法来提交事务，还是调用Rollback方法来回滚事务。

以下是一个使用MySqlTransaction类的示例代码：

static void Main(string[] args)
{//链接MySql数据库相关的IP地址、数据库名称、用户名称、密码string connstr = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";MySqlConnection conn = new MySqlConnection(connstr);//打开数据库if (conn.State != System.Data.ConnectionState.Open){conn.Open();}//数据库其他操作MySqlCommand cmd = new MySqlCommand();cmd.CommandType = CommandType.Text;//设置执行SQL语句cmd.Connection = conn;//数据库链接cmd.Transaction = conn.BeginTransaction();//插入一条数据string strSql = "insert into t_user (user_name,password,nick_name,user_no,status,phone) values('张三6','12345678','红太阳','131024685941523145',0,'13465231586')";cmd.CommandText = strSql;//执行的SQL语句cmd.ExecuteNonQuery();cmd.Transaction.Commit();//cmd.Transaction.Rollback();//查看所有数据strSql = "select * from t_user";cmd.CommandText = strSql;MySqlDataReader reader = cmd.ExecuteReader();for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if (i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();//关闭数据库conn.Close();Console.ReadKey();
}

3、全网功能最全辅助类实现 

using System;
using System.Collections.Generic;
using MySql.Data.MySqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data;namespace MySQLTestDemo
{public class MySqlHelper{#region 私有/// <summary>/// 数据库链接字符串/// </summary>private static readonly string strConn = "server=127.0.0.1;database=db_demo;username=root;password=luoboshou123";/// <summary>/// 数据库链接类/// </summary>private MySqlConnection conn = null;/// <summary>/// 数据库指令执行类/// </summary>private MySqlCommand cmd = null;#endregion/// <summary>/// 指令执行类/// </summary>public MySqlCommand Cmd{get { return cmd;}}/// <summary>/// 外部调用简化接口/// </summary>/// <returns></returns>public static MySqlHelper NewMySql{get{return new MySqlHelper();}}/// <summary>/// 初始化Mysql/// </summary>public void Init(string strSql = "", CommandType commandType = CommandType.Text){Close();if (conn == null){conn = new MySqlConnection(strConn);}if (cmd == null){cmd = new MySqlCommand();cmd.Connection = conn;cmd.CommandType = commandType;}if (strSql != ""){cmd.CommandText = strSql;}}/// <summary>/// 关闭MySql/// </summary>public void Close(){if (cmd != null){if (cmd.Transaction != null){cmd.Transaction = null;}cmd.Dispose();cmd = null;}if (conn != null){conn.Close();conn = null;}}/// <summary>/// 执行增、删、改操作/// </summary>/// <param name="strSql"></param>/// <returns></returns>public int ExecuteNonSql(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteNonQuery();}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行ExecuteNonSql方法时发生错误，具体信息：" + ex.Message;return -1;}finally{Close();}}/// <summary>/// 执行单一结果的查询/// </summary>/// <param name="strSql"></param>/// <returns></returns>public object ExecuteSingleResult(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteScalar();}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetSingleResult方法时发生错误，具体信息：" + ex.Message;return null;}finally{Close();}}/// <summary>/// 执行结果集的查询/// </summary>/// <param name="strSql"></param>/// <returns></returns>public MySqlDataReader ExecuteReader(string strSql, ref string errMsg, MySqlParameter[] param = null){Init(strSql);try{conn.Open();if (param != null){cmd.Parameters.AddRange(param);}return cmd.ExecuteReader(CommandBehavior.CloseConnection);}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetReader(string sql)时发生错误，具体信息：" + ex.Message;return null;}}/// <summary>/// 执行数据集返回DataTable/// </summary>/// <param name="strSql"></param>/// <returns></returns>public DataTable ExecuteDataTable(string strSql, ref string errMsg){Init(strSql);MySqlDataAdapter da = new MySqlDataAdapter(cmd);DataTable dt = new DataTable();try{conn.Open();da.Fill(dt);return dt;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行GetDataSet(string sql)时发生错误，具体信息：" + ex.Message;return null;}finally{Close();}}#region 事务/// <summary>/// 开启事务/// </summary>/// <returns></returns>public bool BeginTransaction(ref string errMsg){try{if (conn.State != ConnectionState.Open){conn.Open();}cmd.Transaction = conn.BeginTransaction();return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行BeginTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}/// <summary>/// 提交事务/// </summary>/// <returns></returns>public bool CommitTransaction(ref string errMsg){try{cmd.Transaction.Commit();//提交事务（同时自动清除事务）return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行CommitTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}/// <summary>/// 回滚事务/// </summary>/// <returns></returns>public bool RollbackTransaction(ref string errMsg){try{cmd.Transaction.Rollback();return true;}catch (Exception ex){//将错误信息写入日志文件errMsg = "执行RollbackTransaction方法时发生错误，具体信息：" + ex.Message;return false;}}#endregion}//class
}//namespace

4、辅助类调用实例

using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;namespace MySQLTestDemo
{internal class Program{static void Main(string[] args){//执行增删改操作{Console.WriteLine("----------------执行增删改操作---------------------");string strSql = "update t_user set nick_name = '王麻子1' where id = 1";string errMsg = string.Empty;int flag = MySqlHelper.NewMySql.ExecuteNonSql(strSql, ref errMsg);Console.WriteLine(flag);if (flag == -1){Console.WriteLine(errMsg);}}//执行单一结果操作{Console.WriteLine("-----------------执行单一结果操作--------------------");string strSql = "select count(*) from t_user";string errMsg = string.Empty;object obj = MySqlHelper.NewMySql.ExecuteSingleResult(strSql, ref errMsg);Console.WriteLine(obj);if(obj == null){Console.WriteLine(errMsg);}}//执行结果集操作{Console.WriteLine("----------------执行结果集操作---------------------");string strSql = "select * from t_user";string errMsg = string.Empty;MySqlHelper mySqlHelper = new MySqlHelper();MySqlDataReader reader = mySqlHelper.ExecuteReader(strSql, ref errMsg);if (reader == null){Console.WriteLine(errMsg);}for (int i = 0; i < reader.FieldCount; i++){string name = reader.GetName(i);//获取字段名称Console.Write(name);if (i != reader.FieldCount - 1){Console.Write(" | ");}else{Console.Write("\r\n");}}while (reader.Read())//循环读取每一行数据{Console.Write(reader["id"].ToString());Console.Write(" | ");Console.Write(reader["user_name"].ToString());Console.Write(" | ");Console.Write(reader["password"].ToString());Console.Write(" | ");Console.Write(reader["nick_name"].ToString());Console.Write(" | ");Console.Write(reader["user_no"].ToString());Console.Write(" | ");Console.Write(reader["status"].ToString());Console.Write(" | ");Console.Write(reader["phone"].ToString());Console.Write("\r\n");}reader.Close();mySqlHelper.Close();}//执行DataTable结果集操作{Console.WriteLine("----------------执行DataTable结果集操作---------------------");string strSql = "select * from t_user";string errMsg = string.Empty;MySqlHelper mySqlHelper = new MySqlHelper();DataTable table = mySqlHelper.ExecuteDataTable(strSql, ref errMsg);if (table.Rows.Count > 0){//打印所有列名string columnName = string.Empty;for (int i = 0; i < table.Columns.Count; i++){columnName += table.Columns[i].ColumnName + " | ";}Console.WriteLine(columnName);Console.WriteLine("-------------------------");//打印每一行的数据foreach (DataRow row in table.Rows){string columnStr = string.Empty;foreach (DataColumn column in table.Columns){columnStr += row[column] + " | ";}Console.WriteLine(columnStr);}}mySqlHelper.Close();}//执行事务操作{Console.WriteLine("----------------执行事务操作---------------------");MySqlHelper mySqlHelper = new MySqlHelper();string errMsg = "";try{mySqlHelper.Init();if(!mySqlHelper.BeginTransaction(ref errMsg)){Console.WriteLine(errMsg);}string strSql = "update t_user set nick_name = '王麻子3' where id = 1";mySqlHelper.Cmd.CommandText = strSql;mySqlHelper.Cmd.ExecuteNonQuery();if (!mySqlHelper.CommitTransaction(ref errMsg)){Console.WriteLine(errMsg);}//if (!mySqlHelper.RollbackTransaction(ref errMsg))//{//    Console.WriteLine(errMsg);//}Console.WriteLine("执行成功");}catch (Exception ex){if (!mySqlHelper.RollbackTransaction(ref errMsg)){Console.WriteLine(errMsg);}Console.WriteLine(ex.Message);}mySqlHelper.Close();}Console.ReadKey();}}
}

版权声明:

本网仅为发布的内容提供存储空间，不对发表、转载的内容提供任何形式的保证。凡本网注明“来源：XXX网络”的作品，均转载自其它媒体，著作权归作者所有，商业转载请联系作者获得授权，非商业转载请注明出处。

我们尊重并感谢每一位作者，均已注明文章来源和作者。如因作品内容、版权或其它问题，请及时与我们联系，联系邮箱：809451989@qq.com，投稿邮箱：809451989@qq.com

最新新闻

热搜词

12月 PHP 单页面在线聊天 使用 Ansys Fluent 技术进行大坝破裂仿真 24年12月6号 近期操作反思 长沙澜海科技带你走进微信小程序 交易与支付模块

声明：本站所有新闻及新闻图片来源于其他网站，如有侵权，请及时联系我们！

客户服务 | 关于我们 | 版权声明

版权所有：

Copyright 2024 尧图网 All Rights Reserved.QQ:809451989