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

来源:这里教程网 时间:2026-02-21 17:38:03 作者:

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

相关推荐