目录- 1. 安装必要的 NuGet 包
- 2. 基本配置和连接
- 3. 完整的 CRUD 操作示例
- 4. 事务处理
- 5. 连接字符串配置建议
- 注意事项：
C# 配合 Dapper 与金仓数据库（KingbaseES）进行交互，可以使用如下方法实现
1. 安装必要的 NuGet 包
Install-Package Dapper
Install-Package Npgsql # 金仓数据库兼容 PostgreSQL 协议 2. 基本配置和连接
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());
}3. 完整的 CRUD 操作示例
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 });
}
}4. 事务处理
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;
}
}5. 连接字符串配置建议
在 appsettings.json 中配置：
{
"ConnectionStrings": {
"KingbaseConnection": "Host=localhost;Port=54321;Database=mydb;User Id=myuser;Password=mypassword;Pooling=true;Minimum Pool Size=5;Maximum Pool Size=100;"
}
}注意事项：
- 驱动选择：金仓数据库通常兼容 PostgreSQL 协议，因此使用 Npgsql 驱动
- 数据类型映射：注意金仓数据库特有的数据类型可能需要特殊处理
- 连接池：建议启用连接池以提高性能
- 错误处理：妥善处理数据库连接异常和超时
这样配置后，你就可以像使用其他数据库一样，使用 Dapper 与金仓数据库进行高效的数据交互了。
到此这篇关于C# 使用Dapper与金仓数据库交互的实现步骤的文章就介绍到这了,更多相关C# Dapper与金仓数据库交互内容请搜索琼殿技术社区以前的文章或继续浏览下面的相关文章希望大家以后多多支持琼殿技术社区！
|
发表于 2025-12-16 09:57:45
