// 导入 MySql.Data.MySqlClient 命名空间
using MySql.Data.MySqlClient;
// 连接 MySQL 数据库
string connStr = "server=localhost;user=root;database=mydb;port=3306;password=123456;";
MySqlConnection conn = new MySqlConnection(connStr);
try
{
conn.Open();
Console.WriteLine($"Connection State: {conn.State}");
// 执行查询语句
string sql = "SELECT * FROM mytable";
MySqlCommand cmd = new MySqlCommand(sql, conn);
MySqlDataReader rdr = cmd.ExecuteReader();
// 输出查询结果
while (rdr.Read())
{
Console.WriteLine($"{rdr["id"]}, {rdr["name"]}");
}
rdr.Close();
}
catch (Exception ex)
{
Console.WriteLine($"Exception: {ex.Message}");
}
finally
{
conn.Close();
}
以上代码中的 connStr 变量定义了 MySQL 数据库的连接参数,包括服务器地址、用户名、密码、数据库名称等。conn.Open() 方法打开与数据库的连接。
查询语句通过 MySqlCommand 对象执行,ExecuteReader() 方法返回一个 MySqlDataReader 对象,可以使用 while 循环读取查询结果。关闭数据库连接可以使用 conn.Close() 方法。
这是一个简单的 MySQL 查询示例,在实际应用中可能需要更复杂的查询,也可以使用 LINQ 或 ORM 框架来简化数据库操作。