依赖SEQUENCE生成ID的两条INSERT语句，第二条执行报错求助

原语句与问题 #

用户的两条INSERT语句如下：

-- Create a new database entry for the astronomicalObject in the GradObservers database
-- based on values of the given id
INSERT INTO astro.bodies (id, title, coordinates) 
    SELECT NEXT VALUE FOR bodies.nextid, title, 9291
    FROM astro.astro 
    WHERE id = 002811

-- Insert new id from table above into astro.sources
-- Insert other fields from existing bodyId 002811
INSERT INTO astro.sources(bodyId, baseValue, Url)
    (SELECT CONVERT(BIGINT, current_value) FROM sys.sequences WHERE schema_id = 71)
    SELECT baseValue, Url 
    FROM astro.sources 
    WHERE bodyId = 002811

第一条语句通过SEQUENCE生成新ID并插入astro.bodies，第二条需要复用这个ID插入astro.sources，但执行第二条时报错：

INSERT语句的选择列表项数少于插入列表项数。SELECT值的数量必须与INSERT列数匹配。

解决方法 #

方法1：用变量捕获SEQUENCE生成的ID #

先获取并保存SEQUENCE的下一个值到变量，再在两条INSERT中统一使用这个变量，确保前后ID一致：

DECLARE @newBodyId BIGINT = NEXT VALUE FOR bodies.nextid;

-- 插入astro.bodies
INSERT INTO astro.bodies (id, title, coordinates) 
SELECT @newBodyId, title, 9291
FROM astro.astro 
WHERE id = 002811;

-- 插入astro.sources
INSERT INTO astro.sources(bodyId, baseValue, Url)
SELECT @newBodyId, baseValue, Url 
FROM astro.sources 
WHERE bodyId = 002811;

这种方式逻辑直接，避免依赖sys.sequences的current_value（该值可能在多线程场景下被其他操作修改）。

方法2：用OUTPUT子句捕获插入的ID #

如果第一条INSERT可能插入多行，或者需要从插入结果中精准获取ID，可以用OUTPUT子句把生成的ID存入表变量，再用于第二条INSERT：

DECLARE @InsertedIds TABLE (Id BIGINT);

-- 插入并捕获ID
INSERT INTO astro.bodies (id, title, coordinates) 
OUTPUT inserted.id INTO @InsertedIds
SELECT NEXT VALUE FOR bodies.nextid, title, 9291
FROM astro.astro 
WHERE id = 002811;

-- 使用捕获的ID插入sources
INSERT INTO astro.sources(bodyId, baseValue, Url)
SELECT i.Id, s.baseValue, s.Url 
FROM astro.sources s
CROSS JOIN @InsertedIds i
WHERE s.bodyId = 002811;

这种方式适合第一条INSERT插入多条数据的场景，能确保获取所有生成的ID。

方法3：修正原第二条语句的语法（不推荐高并发场景） #

原第二条语句的语法错误在于把两个SELECT语句分开写，导致列数不匹配。如果一定要用sys.sequences的current_value，需要把ID和其他字段合并到同一个SELECT中：

-- 注意：高并发环境下，其他操作可能修改SEQUENCE的current_value，导致ID不匹配
INSERT INTO astro.sources(bodyId, baseValue, Url)
SELECT (SELECT CONVERT(BIGINT, current_value) FROM sys.sequences WHERE schema_id = 71), baseValue, Url 
FROM astro.sources 
WHERE bodyId = 002811;

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