用Dapper连PostgreSQL需三步:安装Dapper和Npgsql包、配置连接字符串并手动Open()连接、执行SQL时用@参数化(IN查询用ANY(@Ids))并优先异步操作。

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









