using System;
using MySql.Data.MySqlClient;
class Program
{
static void Main()
{
string connectionString = "server=localhost;user=root;database=testdb;port=3306;password=yourpassword";
using (MySqlConnection connection = new MySqlConnection(connectionString))
{
try
{
connection.Open();
Console.WriteLine("Connection Opened Successfully");
// 创建一个查询命令
string query = "SELECT * FROM users";
MySqlCommand command = new MySqlCommand(query, connection);
// 执行查询并读取结果
using (MySqlDataReader reader = command.ExecuteReader())
{
while (reader.Read())
{
Console.WriteLine($"ID: {reader["id"]}, Name: {reader["name"]}");
}
}
}
catch (Exception ex)
{
Console.WriteLine("An error occurred: " + ex.Message);
}
finally
{
if (connection.State == System.Data.ConnectionState.Open)
{
connection.Close();
Console.WriteLine("Connection Closed");
}
}
}
}
}
引入命名空间:using MySql.Data.MySqlClient; 用于引入 MySQL 数据库连接相关的类和方法。
连接字符串:string connectionString 定义了连接到 MySQL 数据库所需的参数,包括服务器地址、用户名、数据库名称、端口和密码。请根据实际情况修改这些参数。
创建连接对象:MySqlConnection connection = new MySqlConnection(connectionString) 创建了一个 MySQL 连接对象,并使用前面定义的连接字符串进行初始化。
打开连接:connection.Open() 打开与数据库的连接。如果成功,会输出 "Connection Opened Successfully"。
执行查询:
string query = "SELECT * FROM users"; 定义了要执行的 SQL 查询语句。MySqlCommand command = new MySqlCommand(query, connection); 创建了一个命令对象,用于执行查询。using (MySqlDataReader reader = command.ExecuteReader()) 执行查询并获取结果集,使用 while (reader.Read()) 循环读取每一行数据并输出。异常处理:try-catch-finally 块用于捕获可能发生的异常,并确保在程序结束前关闭数据库连接。
关闭连接:在 finally 块中检查连接状态,如果连接是打开的,则关闭它,并输出 "Connection Closed"。
上一篇:c#连接mysql
下一篇:c# mysqlhelper
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站