C#操作MYSQL自定义类
时间: 2023-11-23 18:54:19 浏览: 81
您可以使用以下代码来自定义一个C#类,以便在C#中操作MYSQL数据库:
```csharp
using MySql.Data.MySqlClient;
public class MySQLHelper
{
private MySqlConnection connection;
private string server;
private string database;
private string uid;
private string password;
// 构造函数
public MySQLHelper()
{
Initialize();
}
// 初始化连接字符串
private void Initialize()
{
server = "localhost";
database = "mydatabase";
uid = "username";
password = "password";
string connectionString;
connectionString = "SERVER=" + server + ";" + "DATABASE=" +
database + ";" + "UID=" + uid + ";" + "PASSWORD=" + password + ";";
connection = new MySqlConnection(connectionString);
}
// 打开连接
private bool OpenConnection()
{
try
{
connection.Open();
return true;
}
catch (MySqlException ex)
{
// 处理异常
return false;
}
}
// 关闭连接
private bool CloseConnection()
{
try
{
connection.Close();
return true;
}
catch (MySqlException ex)
{
// 处理异常
return false;
}
}
// 执行查询
public List<string>[] Select()
{
string query = "SELECT * FROM tableinfo";
// 创建一个列表来存储查询结果
List<string>[] list = new List<string>[3];
list[0] = new List<string>();
list[1] = new List<string>();
list[2] = new List<string>();
// 打开连接
if (this.OpenConnection() == true)
{
// 创建命令
MySqlCommand cmd = new MySqlCommand(query, connection);
// 创建数据读取器
MySqlDataReader dataReader = cmd.ExecuteReader();
// 读取数据并将其添加到列表中
while (dataReader.Read())
{
list[0].Add(dataReader["id"] + "");
list[1].Add(dataReader["name"] + "");
list[2].Add(dataReader["age"] + "");
}
// 关闭数据读取器
dataReader.Close();
// 关闭连接
this.CloseConnection();
// 返回查询结果
return list;
}
else
{
return list;
}
}
// 执行插入、更新、删除操作
public void Execute(string query)
{
// 打开连接
if (this.OpenConnection() == true)
{
// 创建命令
MySqlCommand cmd = new MySqlCommand(query, connection);
// 执行命令
cmd.ExecuteNonQuery();
// 关闭连接
this.CloseConnection();
}
}
}
```
使用该类,您可以执行查询、插入、更新和删除操作。例如,要执行查询操作,请使用以下代码:
```csharp
MySQLHelper db = new MySQLHelper();
List<string>[] result = db.Select();
```
要执行插入、更新或删除操作,请使用以下代码:
```csharp
MySQLHelper db = new MySQLHelper();
string query = "INSERT INTO tableinfo (name, age) VALUES('John Smith', '33')";
db.Execute(query);
```
阅读全文