aspnet如何连接数据库读取数据？详细步骤与示例分享
在ASP.NETCore中高效安全地连接数据库并读取数据是开发Web应用的核心能力，以下是基于ADO.NET的专业实现方案，遵循最佳实践确保性能与安全：
环境准备与配置
-
引用必要NuGet包
Install-PackageSystem.Data.SqlClient#SQLServer#或Install-PackageMySql.Data#MySQL
-
配置连接字符串(appsettings.json)
{"ConnectionStrings":{"DefaultConnection":"Server=.;Database=YourDB;UserId=sa;Password=YourPwd;Encrypt=True;TrustServerCertificate=True;"}}
分层架构实现（推荐）
数据访问层(DAL)
publicclassProductRepository{privatereadonlyIConfiguration_config;publicProductRepository(IConfigurationconfig){_config=config;}publicList<Product>GetProducts(){varproducts=newList<Product>();//使用using确保资源释放using(varconn=newSqlConnection(_config.GetConnectionString("DefaultConnection"))){//参数化查询防SQL注入varsql="SELECTProductId,Name,PriceFROMProductsWHEREStock>@MinStock";using(varcmd=newSqlCommand(sql,conn)){cmd.Parameters.AddWithValue("@MinStock",10);conn.Open();using(varreader=cmd.ExecuteReader()){while(reader.Read()){products.Add(newProduct(){Id=reader.GetInt32(0),Name=reader.GetString(1),Price=reader.GetDecimal(2)});}}}}returnproducts;}}publicclassProduct{publicintId{get;set;}publicstringName{get;set;}publicdecimalPrice{get;set;}}
服务层调用(ServiceLayer)
publicclassProductService{privatereadonlyProductRepository_repo;publicProductService(ProductRepositoryrepo){_repo=repo;}publicIEnumerable<Product>GetAvailableProducts(){return_repo.GetProducts();}}
控制器注入(Controller)
[ApiController][Route("api/[controller]")]publicclassProductsController:ControllerBase{privatereadonlyProductService_service;publicProductsController(ProductServiceservice){_service=service;}[HttpGet]publicIActionResultGet(){returnOk(_service.GetAvailableProducts());}}
关键安全与性能优化
-
防御性编程
- 参数化查询：彻底杜绝SQL注入
- 连接池：默认启用，通过
Pooling=true控制
- 错误日志：捕获
SqlException并记录
-
异步操作提升吞吐量
publicasyncTask<List<Product>>GetProductsAsync(){using(varconn=newSqlConnection(_config.GetConnectionString("DefaultConnection"))){awaitconn.OpenAsync();using(varcmd=newSqlCommand("SELECT...",conn)){using(varreader=awaitcmd.ExecuteReaderAsync()){//异步读取逻辑}}}}
-
企业级扩展方案
- ORM选择：EntityFrameworkCore（复杂业务场景）
- Dapper：高性能微ORM（适合读密集型操作）
- 连接管理：使用
IDbConnectionFactory
不同数据库适配方案
| 数据库类型 |
连接包 |
连接字符串示例 |
| SQLServer |
System.Data.SqlClient |
Server=.;Database=DB;User=sa;Pwd=xxx; |
| MySQL |
MySql.Data |
Server=localhost;Database=DB;Uid=root;Pwd=xxx; |
| PostgreSQL |
Npgsql |
Host=localhost;Database=DB;Username=postgres;Password=xxx; |
常见陷阱解决方案
-
连接泄露
- 错误：未调用
Dispose()
- 修复：严格使用
using块
-
密码硬编码
- 错误：代码中写死连接串
- 修复：通过
IConfiguration注入+使用AzureKeyVault
-
查询超时
- 错误：复杂查询未设超时
- 修复：
cmd.CommandTimeout=30;
架构师建议：在微服务场景下，建议将数据库访问封装为独立服务，通过gRPC或RESTAPI提供数据，对于高并发读取，可引入Redis缓存查询结果，响应速度可提升10倍以上。
互动讨论：你在实际项目中如何处理分库分表的数据读取？是否遇到过连接池耗尽的情况？欢迎在评论区分享你的实战经验与解决方案！
微信 
电话 
QQ