做展览的网站,公共法律服务网站平台建设预算,中山百度seo,外贸大楼27号介绍
Dapper是一个轻量级的ORM#xff08;对象关系映射#xff09;框架#xff0c;它可以方便地将数据库查询结果映射到.NET对象上#xff0c;同时也支持执行原生SQL查询。下面我将详细介绍Dapper的使用方法。
安装Dapper
首先#xff0c;你需要通过NuGet包管理器将Dap…介绍
Dapper是一个轻量级的ORM对象关系映射框架它可以方便地将数据库查询结果映射到.NET对象上同时也支持执行原生SQL查询。下面我将详细介绍Dapper的使用方法。
安装Dapper
首先你需要通过NuGet包管理器将Dapper添加到你的项目中。你可以在Visual Studio中的NuGet包管理器控制台中运行以下命令来添加Dapper
Install-Package Dapper创建数据库连接
在使用Dapper之前你需要创建数据库连接。可以使用.NET Core中的任何数据库提供程序来创建连接对象。例如对于SQL Server数据库可以使用SqlConnection类来创建连接对象
using System.Data.SqlClient;var connectionString your_connection_string;
using (var connection new SqlConnection(connectionString))
{// 在此处使用Dapper
}请确保将上述代码中的your_connection_string替换为你的数据库连接字符串。
查询数据
使用Dapper进行数据库查询非常简洁方便。以下是一些查询数据的示例
1. Query方法执行数据库查询并将结果映射到.NET对象的集合中。
var sql SELECT * FROM Customers;
var customers connection.QueryCustomer(sql).ToList();// 异步版本
var asyncCustomers await connection.QueryAsyncCustomer(sql);2. QueryFirstOrDefault方法执行数据库查询并将结果的第一行映射到.NET对象。
var sql SELECT * FROM Customers WHERE Id id;
var customer connection.QueryFirstOrDefaultCustomer(sql, new { id 1 });// 异步版本
var asyncCustomer await connection.QueryFirstOrDefaultAsyncCustomer(sql, new { id 1 });3. QuerySingleOrDefault方法执行数据库查询并将结果的单行映射到.NET对象。如果结果集不唯一则抛出异常。
var sql SELECT * FROM Customers WHERE Email email;
var customer connection.QuerySingleOrDefaultCustomer(sql, new { email testexample.com });// 异步版本
var asyncCustomer await connection.QuerySingleOrDefaultAsyncCustomer(sql, new { email testexample.com });4. Execute方法执行数据库操作例如插入、更新或删除记录。
var sql INSERT INTO Customers (Name, Email) VALUES (Name, Email);
var parameters new { Name John Doe, Email johndoeexample.com };
connection.Execute(sql, parameters);// 异步版本
await connection.ExecuteAsync(sql, parameters);5. ExecuteScalar方法执行数据库查询并返回结果的第一行第一列的值。
var sql SELECT COUNT(*) FROM Customers;
var count connection.ExecuteScalarint(sql);// 异步版本
var asyncCount await connection.ExecuteScalarAsyncint(sql);6. QueryMultiple方法执行多个查询语句并将结果存储在SqlMapper.GridReader对象中。
var sql SELECT * FROM Customers; SELECT * FROM Orders;
using (var multi connection.QueryMultiple(sql))
{var customers multi.ReadCustomer().ToList();var orders multi.ReadOrder().ToList();
}// 异步版本
var multi await connection.QueryMultipleAsync(sql);
var customers multi.ReadCustomer().ToList();
var orders multi.ReadOrder().ToList();这些示例展示了Dapper常用方法以及它们的异步版本的使用情况。异步方法可以更好地支持并发操作提高应用程序的性能。
这里的Customer是一个自定义的实体类用于映射数据库中的表结构。Query方法将会自动执行SQL查询并将结果映射到Customer对象的集合中。
如果你需要使用参数化查询可以使用Query方法的第二个参数来传递查询参数
var sql SELECT * FROM Customers WHERE Age age;
var parameters new { age 18 };
var customers connection.QueryCustomer(sql, parameters).ToList();插入记录
var sql INSERT INTO Customers (Name, Email) VALUES (Name, Email);
var parameters new { Name John Doe, Email johndoeexample.com };
connection.Execute(sql, parameters);更新记录
var sql UPDATE Customers SET Email Email WHERE Id Id;
var parameters new { Email newemailexample.com, Id 1 };
connection.Execute(sql, parameters);删除记录
var sql DELETE FROM Customers WHERE Id Id;
var parameters new { Id 1 };
connection.Execute(sql, parameters);通过使用Execute方法你可以执行任何对数据库的增加、删除和修改操作只需提供相应的SQL语句和参数即可。
当然你也可以使用其他方法来执行上述操作例如使用ExecuteScalar方法获取插入操作的自增长ID或者使用QueryFirstOrDefault方法来检查是否成功执行了修改操作等。
执行操作
除了查询数据Dapper也支持执行数据库操作例如插入、更新或删除记录。以下是一些示例
var sql INSERT INTO Customers (Name, Email) VALUES (Name, Email);
var parameters new { Name John Doe, Email johndoeexample.com };
connection.Execute(sql, parameters);在上述示例中我们执行了一个插入操作将新的顾客记录插入到数据库中。
存储过程
如果你需要执行存储过程Dapper也提供了相应的支持。以下是一个示例
var parameters new DynamicParameters();
parameters.Add(productId, 1);
parameters.Add(quantity, 10, DbType.Int32, ParameterDirection.InputOutput);connection.Execute(UpdateStock, parameters, commandType: CommandType.StoredProcedure);var updatedQuantity parameters.Getint(quantity);在上述示例中我们通过DynamicParameters类创建了存储过程的参数。然后通过Execute方法执行了存储过程。在存储过程执行后我们可以通过Get方法获取输出参数的值。
事务
当在Dapper中执行多个数据库操作时你可以使用事务来保证这些操作要么全部成功要么全部回滚。Dapper提供了简单且灵活的方式来处理事务。
下面是一个使用Dapper执行事务的示例
using (var connection new SqlConnection(connectionString))
{connection.Open(); // 事务开启using (var transaction connection.BeginTransaction()){try{var insertSql INSERT INTO Customers (Name, Email) VALUES (Name, Email);var updateSql UPDATE Orders SET Status Status WHERE CustomerId CustomerId;var insertParameters new { Name John Doe, Email johndoeexample.com };var updateParameters new { Status Completed, CustomerId 1 };connection.Execute(insertSql, insertParameters, transaction);connection.Execute(updateSql, updateParameters, transaction);transaction.Commit(); // 事务提交}catch{transaction.Rollback(); // 事务回滚throw;}}
}在这个示例中我们首先创建了一个SqlConnection对象并打开连接。然后我们使用BeginTransaction方法开始一个事务。
在事务内部我们可以执行任意数量的数据库操作。在本例中我们执行了一个插入操作和一个更新操作。每个操作都使用Execute方法在同一个事务中执行并传递了transaction参数。
如果所有的操作都成功执行我们调用Commit方法提交事务。如果在任何操作期间出现错误我们使用Rollback方法回滚事务并重新抛出异常。
通过使用事务你可以确保在执行一系列数据库操作时保持数据的一致性和完整性。
请注意在上述示例中我们使用了SqlConnection和SqlTransaction类这是因为Dapper使用ADO.NET提供程序作为底层数据库访问。因此你仍然可以通过Dapper使用事务处理。
IDEA
