用 Dapper 连 PostgreSQL,核心就三步:装对包、连对库、写对 SQL。它不搞自动建模,也不藏连接逻辑,所以简单直接,但得把细节理清楚。
安装 Dapper 和 Npgsql 包
必须同时引入两个 NuGet 包:
Dapper:提供 Query/Execute 等扩展方法 Npgsql:PostgreSQL 的 .NET 官方驱动(不是 SqlClient 或 MySqlConnector)命令行安装(推荐):
dotnet add package Dapper<br>dotnet add package Npgsql
Visual Studio 中右键项目 → “管理 NuGet 包” → 搜索并安装这两个包即可。注意别装错驱动,比如误装 Microsoft.Data.SqlClient,那连不上 PostgreSQL。
配置连接字符串并创建连接
在 appsettings.json 里加连接配置(注意字段名是 PostgreSQL 风格):
{<br> "ConnectionStrings": {<br> "DefaultConnection": "Host=localhost;Port=5432;Database=mydb;Username=postgres;Password=123456;"<br> }<br>}封装一个轻量连接工厂(避免每次 new):
public IDbConnection CreateConnection() => new NpgsqlConnection(_configuration.GetConnectionString("DefaultConnection"));⚠️ 关键点:Dapper 不自动打开连接,你得手动调
Open();或者用
using var conn = new NpgsqlConnection(...); conn.Open();—— 忘了 Open 会报“connection is not open”。
执行查询与参数化写法
PostgreSQL 对参数名敏感,Dapper 支持
@param(SQL Server 风格),也支持
:param(原生 pg 风格),但建议统一用
@,兼容性更好。
示例(查用户列表):
var users = connection.Query<User>("SELECT * FROM users WHERE status = @Status AND age > @MinAge",<br> new { Status = "active", MinAge = 18 });IN 查询要小心:PostgreSQL 不支持
WHERE id IN @Ids直接传数组。正确写法是用
ANY(@Ids):
var ids = new[] { 1, 2, 3 };<br>var products = connection.Query<Product>("SELECT * FROM products WHERE id = ANY(@Ids)", new { Ids = ids });异步操作和连接池优化
生产环境务必用异步方法(如
QueryAsync、
ExecuteAsync),避免线程阻塞:
var list = await connection.QueryAsync<Product>("SELECT * FROM products");连接池默认开 100 个,高并发时可能不够。可在连接字符串末尾加参数:
...;Pooling=true;MaxPoolSize=200;MinPoolSize=10;CommandTimeout=30;
另外,Dapper 执行完不会自动关连接,靠
using语句块释放最稳妥 —— 别依赖 GC 回收连接。
基本上就这些。没魔法,不封装,但每一步都得踩准。连得上、参数对、异步用、池配好,PostgreSQL + Dapper 就很稳。
