C#中使用Dapper进行数据库访问的流程步骤

Install-Package Dapper

string connectionString = "数据库链接";
using (var connection = new SqlConnection(connectionString))
{
    // 在这里执行数据库操作
}

string sql = "SELECT * FROM Users";
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql); // User是一个与数据库表结构相匹配的类
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

string sql = "SELECT * FROM Users WHERE Age > @Age";
int ageThreshold = 30;
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql, new { Age = ageThreshold });
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

string sql = "SELECT * FROM Users WHERE Age > @age";
using (var connection = new SqlConnection(connectionString))
{
    var users = connection.Query<User>(sql, new { age = 30 });
    foreach (var user in users)
    {
        Console.WriteLine(user.Name);
    }
}

string insertSql = "INSERT INTO Users (Name, Age) VALUES (@Name, @Age)";
using (var connection = new SqlConnection(connectionString))
{
    var rowsAffected = connection.Execute(insertSql, new { Name = "John Doe", Age = 25 });
    Console.WriteLine($"Rows affected: {rowsAffected}");
}

using (var connection = new SqlConnection(connectionString))
{
    using (var transaction = connection.BeginTransaction())
    {
        try
        {
            // 执行一系列数据库操作
            // ...

            // 提交事务
            transaction.Commit();
        }
        catch
        {
            // 回滚事务
            transaction.Rollback();
            throw;
        }
    }
}