Dapper如何连接PostgreSQL Dapper Npgsql使用教程

用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 就很稳。