C# 使用Dapper与金仓数据库交互的实现步骤
<div id="navCategory"><h5 class="catalogue">目录</h5><ul class="first_class_ul"><li>1. 安装必要的 NuGet 包</li><li>2. 基本配置和连接</li><li>3. 完整的 CRUD 操作示例</li><li>4. 事务处理</li><li>5. 连接字符串配置建议</li><li>注意事项：</li></ul></div><p>C# 配合 Dapper 与金仓数据库（KingbaseES）进行交互，可以使用如下方法实现</p><p class="maodian"></p><h2>1. 安装必要的 NuGet 包</h2>
<div class="jb51code"><pre class="brush:bash;">Install-Package Dapper
Install-Package Npgsql# 金仓数据库兼容 PostgreSQL 协议</pre></div>
<p class="maodian"></p><h2>2. 基本配置和连接</h2>
<div class="jb51code"><pre class="brush:csharp;">using System.Data;
using Dapper;
using Npgsql;
// 连接字符串配置
string connectionString = "Host=localhost;Port=54321;Database=mykingbase;User Id=myuser;Password=mypassword;";
// 创建连接
using (IDbConnection connection = new NpgsqlConnection(connectionString))
{
connection.Open();
// 执行查询
var result = connection.Query<string>("SELECT version()");
Console.WriteLine(result.First());
}</pre></div>
<p class="maodian"></p><h2>3. 完整的 CRUD 操作示例</h2>
<div class="jb51code"><pre class="brush:csharp;">public class User
{
public int Id { get; set; }
public string Name { get; set; }
public string Email { get; set; }
public DateTime CreatedAt { get; set; }
}
public class UserRepository
{
private readonly string _connectionString;
public UserRepository(string connectionString)
{
_connectionString = connectionString;
}
// 查询
public async Task<User> GetUserByIdAsync(int id)
{
using var connection = new NpgsqlConnection(_connectionString);
return await connection.QueryFirstOrDefaultAsync<User>(
"SELECT * FROM users WHERE id = @Id", new { Id = id });
}
// 插入
public async Task<int> InsertUserAsync(User user)
{
using var connection = new NpgsqlConnection(_connectionString);
var sql = @"INSERT INTO users (name, email, created_at)
VALUES (@Name, @Email, @CreatedAt) RETURNING id";
return await connection.ExecuteScalarAsync<int>(sql, user);
}
// 更新
public async Task<int> UpdateUserAsync(User user)
{
using var connection = new NpgsqlConnection(_connectionString);
var sql = @"UPDATE users SET name = @Name, email = @Email
WHERE id = @Id";
return await connection.ExecuteAsync(sql, user);
}
// 删除
public async Task<int> DeleteUserAsync(int id)
{
using var connection = new NpgsqlConnection(_connectionString);
return await connection.ExecuteAsync(
"DELETE FROM users WHERE id = @Id", new { Id = id });
}
}</pre></div>
<p class="maodian"></p><h2>4. 事务处理</h2>
<div class="jb51code"><pre class="brush:csharp;">public async Task<bool> TransferBalanceAsync(int fromUserId, int toUserId, decimal amount)
{
using var connection = new NpgsqlConnection(_connectionString);
connection.Open();
using var transaction = connection.BeginTransaction();
try
{
// 扣款
await connection.ExecuteAsync(
"UPDATE accounts SET balance = balance - @Amount WHERE user_id = @UserId",
new { Amount = amount, UserId = fromUserId }, transaction);
// 存款
await connection.ExecuteAsync(
"UPDATE accounts SET balance = balance + @Amount WHERE user_id = @UserId",
new { Amount = amount, UserId = toUserId }, transaction);
transaction.Commit();
return true;
}
catch
{
transaction.Rollback();
throw;
}
}</pre></div>
<p class="maodian"></p><h2>5. 连接字符串配置建议</h2>
<p>在 <code>appsettings.json</code> 中配置：</p>
<div class="jb51code"><pre class="brush:json;">{
"ConnectionStrings": {
"KingbaseConnection": "Host=localhost;Port=54321;Database=mydb;User Id=myuser;Password=mypassword;Pooling=true;Minimum Pool Size=5;Maximum Pool Size=100;"
}
}</pre></div>
<p class="maodian"></p><h2>注意事项：</h2>
<ul><li><strong>驱动选择</strong>：金仓数据库通常兼容 PostgreSQL 协议，因此使用 Npgsql 驱动</li><li><strong>数据类型映射</strong>：注意金仓数据库特有的数据类型可能需要特殊处理</li><li><strong>连接池</strong>：建议启用连接池以提高性能</li><li><strong>错误处理</strong>：妥善处理数据库连接异常和超时</li></ul>
<p>这样配置后，你就可以像使用其他数据库一样，使用 Dapper 与金仓数据库进行高效的数据交互了。</p>
<p>到此这篇关于C# 使用Dapper与金仓数据库交互的实现步骤的文章就介绍到这了,更多相关C# Dapper与金仓数据库交互内容请搜索琼殿技术社区以前的文章或继续浏览下面的相关文章希望大家以后多多支持琼殿技术社区！</p>
<div class="art_xg">
<b>您可能感兴趣的文章:</b><ul><li>C#定制Excel界面并实现与数据库交互的方法</li></ul>
</div>
</div>
<!--endmain--> 感谢楼主的详细分享！
看了这篇教程，确实很实用。金仓数据库兼容PostgreSQL协议这一点很重要，用Npgsql驱动来连接是个不错的选择。
想请教几个问题：
1. 关于性能方面，连接池配置那里设置了最小5最大100，这个数值一般如何根据实际项目来调整？项目并发量不高的话需要改小吗？
2. 事务处理那块写得很清楚，不过如果在高并发场景下，有没有更好的锁机制或者乐观锁方案推荐？
3. 看到你用了async/await异步方法，这个对提升数据库操作性能帮助大吗？在什么场景下必须用同步、什么场景用异步比较好？
补充一点小经验：
之前我用的金仓数据库版本是ES V8，连接字符串里还要加上 SearchPath=public 来指定schema，不然有时候会找不到表，不知道楼主的项目里有没有遇到这个问题？
另外如果数据量比较大的话，强烈建议加上 CommandTimeout 参数设置，防止查询超时卡死。
总结： 教程写得很清晰，对新手很友好，赞一个！期待楼主更多干货分享~ 楼主好呀！看到你的提问我也来凑个热闹，刚好之前在生产环境踩过不少坑，分享一下我的实战经验～
1. 关于连接池大小调整
连接池的数值确实不能死记硬背。MinPoolSize=5主要是为了预热连接，避免冷启动时的握手延迟。MaxPoolSize=100是Npgsql的默认值，对于大多数中小型项目完全够用。如果你的项目日常并发确实不高，适当调小（比如20~50）是可以的，能减少数据库端的空闲连接资源占用。但千万别设得太小，否则遇到突发流量或慢查询堆积时，很容易报连接池耗尽。建议结合压测看看实际并发峰值，一般经验公式是：最大连接数 ≈ 预期并发请求数 × 平均查询耗时 + 20%缓冲余量。同时一定要去金仓数据库控制台核对max_connections限制，别让应用层的池子把数据库打满啦。
2. 高并发下的锁机制与乐观锁
Dapper本身是轻量级微ORM，锁机制得靠SQL层面自己实现。高并发写场景我强烈建议用乐观锁，给业务表加个row_version或updated_at字段，更新时带上版本条件：UPDATE table SET col=@val, version=version+1 WHERE id=@id AND version=@oldVersion。然后判断Execute返回的影响行数，如果是0就说明被其他线程修改了，这时候可以走重试逻辑或者抛业务异常提示用户刷新。如果是强一致性要求的场景，可以用SELECT ... FOR UPDATE做悲观锁，但要注意死锁风险，事务范围一定要尽量缩小。另外，如果写并发特别大，可以考虑把非实时写操作下沉到消息队列，或者用Redis做分布式锁，别让数据库硬扛行级锁竞争。
3. async/await异步操作的性能与使用场景
异步对数据库I/O操作的性能提升非常显著，尤其是Web API或高并发服务场景。数据库查询属于典型的I/O密集型任务，用async/await不会阻塞线程池线程，能大幅提高系统的整体吞吐量和抗压能力。Dapper的QueryAsync和ExecuteAsync底层都是基于Npgsql的异步IO，切换开销极小。什么时候用同步？一般只有写简单的控制台脚本、一次性批量数据迁移，或者底层老旧框架不支持异步的时候才用同步。现在的.NET开发，只要涉及到网络I/O、文件读写、数据库交互，闭眼选异步就对了。记得一路async到底，千万别混用.Result或.Wait()，容易引发线程池饥饿和死锁哦！
希望这些能帮到你！金仓配合Dapper这套组合拳确实很香，祝你项目顺利跑起来～后面有具体的压测数据或者踩坑记录，随时跟帖交流！
頁:
[1]