C#数据连接MySQL数据库代码是指使用C#编程语言连接和操作MySQL数据库的代码。MySQL是一种开源的关系型数据库管理系统,常用于Web应用程序的后端数据存储和管理。
以下是一个示例的C#代码,用于建立与MySQL数据库的连接,并执行一些常见的数据库操作,例如查询、插入、更新和删除数据:
using System;
using MySql.Data.MySqlClient;
public class MySQLConnector
{
private MySqlConnection connection;
private string server;
private string database;
private string uid;
private string password;
public MySQLConnector()
{
Initialize();
}
private void Initialize()
{
server = "localhost"; // MySQL数据库服务器的地址
database = "mydatabase"; // 数据库名称
uid = "username"; // 用户名
password = "password"; // 密码
string connectionString = $"SERVER={server};DATABASE={database};UID={uid};PASSWORD={password};";
connection = new MySqlConnection(connectionString);
}
// 打开数据库连接
private bool OpenConnection()
{
try
{
connection.Open();
return true;
}
catch (MySqlException ex)
{
Console.WriteLine(ex.Message);
return false;
}
}
// 关闭数据库连接
private bool CloseConnection()
{
try
{
connection.Close();
return true;
}
catch (MySqlException ex)
{
Console.WriteLine(ex.Message);
return false;
}
}
// 执行查询语句,并返回结果集
public MySqlDataReader ExecuteQuery(string query)
{
if (OpenConnection() == true)
{
MySqlCommand cmd = new MySqlCommand(query, connection);
return cmd.ExecuteReader();
}
else
{
return null;
}
}
// 执行插入、更新、删除等非查询语句
public bool ExecuteNonQuery(string query)
{
if (OpenConnection() == true)
{
MySqlCommand cmd = new MySqlCommand(query, connection);
int rowsAffected = cmd.ExecuteNonQuery();
CloseConnection();
return rowsAffected > 0;
}
else
{
return false;
}
}
}
在上述代码中,首先创建了一个MySQLConnector
类,用于封装数据库连接和操作的相关方法。在构造函数Initialize()
中,定义了MySQL数据库的连接信息,包括服务器地址、数据库名称、用户名和密码。然后,在OpenConnection()
和CloseConnection()
方法中,分别实现了打开和关闭数据库连接的功能。
该类还提供了两个常用的方法,ExecuteQuery()
用于执行查询语句并返回结果集,ExecuteNonQuery()
用于执行插入、更新、删除等非查询语句。这些方法内部首先打开数据库连接,然后创建MySqlCommand
对象来执行相应的SQL语句,最后关闭连接。
使用该类的示例代码如下:
MySQLConnector connector = new MySQLConnector();
// 执行查询语句
string query = "SELECT * FROM users";
MySqlDataReader reader = connector.ExecuteQuery(query);
if (reader != null)
{
while (reader.Read())
{
Console.WriteLine($"User ID: {reader["id"]}, Name: {reader["name"]}, Email: {reader["email"]}");
}
reader.Close();
}
// 执行插入语句
string insertQuery = "INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')";
bool insertSuccess = connector.ExecuteNonQuery(insertQuery);
if (insertSuccess)
{
Console.WriteLine("Insertion successful.");
}
// 执行更新语句
string updateQuery = "UPDATE users SET email='updated@example.com' WHERE id=1";
bool updateSuccess = connector.ExecuteNonQuery(updateQuery);
if (updateSuccess)
{
Console.WriteLine("Update successful.");
}
// 执行删除语句
string deleteQuery = "DELETE FROM users WHERE id=2";
bool deleteSuccess = connector.ExecuteNonQuery(deleteQuery);
if (deleteSuccess)
{
Console.WriteLine("Deletion successful.");
}
上述示例代码演示了如何使用MySQLConnector
类执行MySQL数据库的查询、插入、更新和删除操作。请注意,这只是一个简单的示例,实际情况下可能需要更复杂的数据操作和错误处理逻辑。
推荐的腾讯云相关产品:腾讯云数据库 MySQL,详细介绍请参考腾讯云数据库 MySQL产品介绍。腾讯云提供稳定可靠、高性能的MySQL数据库服务,支持数据备份、容灾、监控等功能,可满足各类应用场景的需求。
领取专属 10元无门槛券
手把手带您无忧上云