PostgreSQL中使用Npgsql获取LastInsertedId报错，如何正确实现？

嘿，我来帮你搞定这个问题！你遇到的错误核心原因是：Npgsql的NpgsqlCommand类根本没有LastInsertedId这个属性，直接调用它肯定会编译或者运行报错。下面给你两种靠谱的实现方式，首推第一种！

方法一：使用PostgreSQL的RETURNING子句（推荐） #

这是PostgreSQL官方推荐的方式，也是最安全、最灵活的做法——在INSERT语句末尾添加RETURNING子句，直接返回插入行的自增ID，完全不用担心并发场景下的ID混乱问题。

修改后的代码如下：

int playerId = 0;
using (NpgsqlConnection connection = new NpgsqlConnection(connectionString))
{
    try
    {
        connection.Open();
        NpgsqlCommand command = connection.CreateCommand();
        // 关键：添加RETURNING子句，指定返回自增列（这里假设你的自增列名为id）
        command.CommandText = "INSERT INTO users (name) VALUES (@playerName) RETURNING id";
        command.Parameters.AddWithValue("@playerName", playerModel.realName);
        
        // 用ExecuteScalar()获取返回的单个值（也就是插入的ID）
        playerId = (int)command.ExecuteScalar();
        
        // 后续可以正常使用这个playerId
        // command.Parameters.AddWithValue("@playerId", playerId);
    }
    catch (Exception ex)
    {
        // 建议补充异常处理逻辑，比如记录日志或提示错误
        Console.WriteLine($"插入数据失败：{ex.Message}");
    }
}

说明 #

• RETURNING子句不仅能返回自增ID，还能返回插入行的其他字段（比如RETURNING id, name, create_time），非常灵活。
• 确保你的users表确实有一个自增主键列，比如用SERIAL或IDENTITY定义：

  -- 旧版SERIAL方式
  CREATE TABLE users (
      id SERIAL PRIMARY KEY,
      name VARCHAR(50) NOT NULL
  );
  
  -- 新版IDENTITY方式（PostgreSQL 10+推荐）
  CREATE TABLE users (
      id INT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
      name VARCHAR(50) NOT NULL
  );
  

方法二：查询序列当前值（不推荐并发场景） #

如果你的自增列是基于序列创建的（比如SERIAL），可以在插入后查询序列的当前值，但这种方法在多线程/多会话并发插入时，可能会拿到其他会话插入的ID，所以只适合单线程低并发场景。

示例代码：

int playerId = 0;
using (NpgsqlConnection connection = new NpgsqlConnection(connectionString))
{
    try
    {
        connection.Open();
        // 第一步：执行插入
        NpgsqlCommand insertCommand = connection.CreateCommand();
        insertCommand.CommandText = "INSERT INTO users (name) VALUES (@playerName)";
        insertCommand.Parameters.AddWithValue("@playerName", playerModel.realName);
        insertCommand.ExecuteNonQuery();
        
        // 第二步：查询序列当前值（序列名格式一般是[表名]_[列名]_seq）
        NpgsqlCommand idCommand = connection.CreateCommand();
        idCommand.CommandText = "SELECT currval('users_id_seq')";
        playerId = (int)idCommand.ExecuteScalar();
    }
    catch (Exception ex)
    {
        Console.WriteLine($"操作失败：{ex.Message}");
    }
}

注意 #

• 序列名称需要和你的表定义对应，如果你用的是IDENTITY列，序列名称也是类似users_id_seq的格式，但不同版本可能有差异，不如RETURNING直接。
• 并发场景下强烈不建议用这种方法，会有ID获取错误的风险。

内容的提问来源于stack exchange，提问作者ZeroneXYZ