C#项目连接MySQL数据库
C#项目连接MySQL数据库
- 这里我是将方法全部都放在一个新建的MySQL类中了。也可以单独实现方法。
- 这里只提供了简单的增删改查。
- 这里是用C#的控制台应用程序做示范。也可以在Web Form或者Win Form等C#项目中通过这个方法实现连接并操作MySQL数据库。
- 在进行操作前,请确保MySQL和Visual Studio已经安装完成,并且MySQL的服务已经打开。
- 数据库名字和表名:
1.新建C#控制台项目,添加MySQL的引用,新建MySQL类。
C:\Program Files (x86)\MySQL\Connector.NET 6.9\Assemblies\v4.5
2.编写MySQL类的代码。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;
using System.Data;
namespace _001_MySQL的连接
{
class MySQL
{
string connStr;
MySqlConnection conn;
string cmdText;
MySqlCommand cmd;
public MySQL(string dataBaseName)
{
connStr = string.Format(
"Database={0};DataSource=127.0.0.1;User=root;Pwd=root;port=3306",
dataBaseName
);
conn = new MySqlConnection(connStr);
}
/// <summary>
/// 通过DataAdapter类和DataSet类来实现查询一个表的数据。
/// 需要输入的形参是:想要查询的表名
/// </summary>
/// <param name="tableName"></param>
public void Select(string tableName)
{
conn.Open();
cmdText = string.Format(
"SELECT * FROM {0}", tableName
);
cmd = new MySqlCommand(cmdText, conn);
MySqlDataAdapter dad = new MySqlDataAdapter(cmd);
DataSet dset = new DataSet();
dad.Fill(dset, tableName);
for (int i = 0; i < dset.Tables[0].Rows.Count; i++)
{
for (int j = 0; j < dset.Tables[0].Columns.Count; j++)
{
if (j == dset.Tables[0].Columns.Count - 1)
Console.Write(dset.Tables[0].Rows[i][j].ToString());
else
Console.Write(dset.Tables[0].Rows[i][j].ToString() + ":");
}
Console.WriteLine();
}
conn.Close();
}
/// <summary>
/// 通过DataReader类来实现查询一个表的数据。
/// 需要输入的形参是:想要查询的表名,不固定个数的列名。
/// </summary>
/// <param name="tableName"></param>
/// <param name="columnsName"></param>
public void Select(string tableName, params string[] columnsName)
{
conn.Open();
cmdText = string.Format(
"SELECT * FROM {0}", tableName
);
cmd = new MySqlCommand(cmdText, conn);
MySqlDataReader dataReader = cmd.ExecuteReader();
while (dataReader.Read())
{
Console.WriteLine(
dataReader.GetString(columnsName[0])
+ ":" +
dataReader.GetString(columnsName[1])
);
}
dataReader.Close();
conn.Close();
}
/// <summary>
/// 输入表名、ID列和Name列的名称来插入一条数据。
/// </summary>
/// <param name="tableName"></param>
/// <param name="id"></param>
/// <param name="name"></param>
public void Insert(string tableName, int id, string name)
{
conn.Open();
cmdText = string.Format(
"INSERT INTO {0} VALUES({1},'{2}')",
tableName, id, name
);
cmd = new MySqlCommand(cmdText, conn);
cmd.ExecuteNonQuery();
conn.Close();
}
/// <summary>
/// 通过ID来删除表中的一条数据
/// </summary>
/// <param name="tableName"></param>
/// <param name="id"></param>
public void Delete(string tableName, int id)
{
conn.Open();
cmdText = string.Format(
"DELETE FROM {0} WHERE ID={1}",
tableName, id
);
cmd = new MySqlCommand(cmdText, conn);
cmd.ExecuteNonQuery();
conn.Close();
}
/// <summary>
/// 通过ID来修改表中的一条数据的Name值
/// </summary>
/// <param name="tableName"></param>
/// <param name="id"></param>
/// <param name="name"></param>
public void Update(string tableName, int id, string name)
{
conn.Open();
cmdText = string.Format(
"UPDATE {0} SET NAME='{1}' WHERE ID={2}",
tableName, name, id
);
cmd = new MySqlCommand(cmdText, conn);
cmd.ExecuteNonQuery();
conn.Close();
}
/// <summary>
/// @ 和 cmd.Parameters.AddWithValue("string","str");。
/// 这种方法不能用AddWithValue方法来添加表的名字,会报错,
/// 只能添加列的属性的值。
/// 因为通过这种方法来添加表名的时候,
/// 它会这样添加表名的信息:UPDATE 'TABLENAME' SET ...。
/// 多了一对单引号,所以会报错。
/// </summary>
/// <param name="id"></param>
/// <param name="name"></param>
public void UpdateByParameters(int id, string name)
{
conn.Open();
cmdText =
"UPDATE TEST_CONNECTION SET [email protected]_NAME WHERE [email protected]_ID";
cmd = new MySqlCommand(cmdText, conn);
//cmd.Parameters.AddWithValue("TABLENAME", tableName);
cmd.Parameters.AddWithValue("INPUT_NAME", name);
cmd.Parameters.AddWithValue("INPUT_ID", id);
cmd.ExecuteNonQuery();
conn.Close();
}
}
}
3.编写主函数的测试代码。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace _001_MySQL的连接
{
class Program
{
static void Main(string[] args)
{
MySQL mySql = new MySQL("yyymarshal");
Console.WriteLine("Select()方法:");
mySql.Select("test_connection");
Console.WriteLine("\nInsert()方法:\n插入id=5,name=Test的一条数据");
mySql.Insert("test_connection", 5, "Test");
Console.WriteLine("---------------");
Console.WriteLine("Select()方法:");
mySql.Select("test_connection", "id", "name");
Console.WriteLine("\nUpdate()方法:\n将id=5的数据的name修改为PPP");
mySql.Update("test_connection", 5, "PPP");
Console.WriteLine("---------------");
Console.WriteLine("Select()方法:");
mySql.Select("test_connection");
Console.WriteLine("\nUpdateByParameters()方法:\n将id=5的数据的name修改为OOO");
mySql.UpdateByParameters(5, "OOO");
Console.WriteLine("---------------");
Console.WriteLine("Select()方法:");
mySql.Select("test_connection");
Console.WriteLine("\nDelete()方法:\n删除id=5的数据");
mySql.Delete("test_connection", 5);
Console.WriteLine("---------------");
Console.WriteLine("Select()方法:");
mySql.Select("test_connection");
Console.ReadKey();
}
}
}
4.运行测试
运行前的数据表的数据:
运行结果: