---

前言

C#和MySQL数据库是常见的数据交互，标准的查询和执行方法如下，做个记录。

一、查询方法

private static int QueryTable(string tableName, DateTime today, string stepName){int result = 0; // 返回数据行DataTable dataTable = new DataTable();string sqlQuery = "SELECT " + stepName + " FROM " + tableName + " WHERE DTime = '" + today.ToString("yyyy-MM-dd") + "'";MySqlConnection connection = new MySqlConnection("Server=0.0.0.0;Database=aaa;User Id=bbb;PASSWORD=ccc;Allow User Variables=True;");try{// 打开数据库连接connection.Open();// 创建SqlCommand对象using (MySqlCommand command = new MySqlCommand(sqlQuery, connection)){// 使用SqlDataAdapter来填充DataTableusing (MySqlDataAdapter adapter = new MySqlDataAdapter(command)){adapter.Fill(dataTable);}}}catch (Exception ex){MessageBox.Show(ex.ToString());}if (dataTable.Rows.Count > 0){result = Convert.ToInt32(dataTable.Rows[0][stepName].ToString());}return result;}

1. 功能

• 这个方法从指定的MySQL表中查询特定日期下某列的数据。如果查询到数据，就把数据转换为整数返回，没查询到就返回0。
  2. 步骤
• 首先定义变量存储结果和用于存放查询数据的DataTable。
• 构建查询语句，按特定日期筛选特定列。
• 建立数据库连接，打开连接后执行查询，用DataAdapter填充DataTable。如果有异常就显示异常信息。
• 最后根据DataTable是否有数据行来确定返回值。

二、执行方法

 
string sqlStr = "DELETE FROM " + tableName + ";";private static int ExcuteTable(string sqlStr){int result = 0;string connStr = "Server=0.0.0.0;Database=aaa;User Id=bbb;PASSWORD=ccc;Allow User Variables=True;";using (MySqlConnection conn = new MySqlConnection(connStr)){try{// 打开数据库连接conn.Open();// 创建SqlCommand对象using (MySqlCommand command = new MySqlCommand(sqlStr, conn)){result = command.ExecuteNonQuery();}}catch (Exception ex){MessageBox.Show(ex.ToString());}}return result;}

1. 功能

• 此方法用于删除指定MySQL表中的所有数据，并返回被删除数据的行数。

2. 步骤

• 先初始化变量来存储受影响的行数。
• 构建DELETE语句。
• 建立数据库连接，打开连接后执行DELETE语句，获取受影响行数。如果有异常就显示异常信息。
• 最后返回受影响的行数。