所以下面不工作时运行。我加列[Target_Id] INT
我Create Table
声明。现在抛出的错误:
消息213,级别16,状态1,1376线 列名或提供值的数目不匹配表定义。
这里是整批:
--FactSite
IF OBJECT_ID('tempdb..#factSite', 'U') IS NOT NULL
DROP TABLE #factSite;
CREATE TABLE #factSite
(
[ID] INT,
[Target_Id] INT,
[SYS_CHANGE_OPERATION] NVARCHAR(1),
DimSite_Id INT,
DimSubSite_Id INT,
DimSubParameters_Id INT
);
WITH cteUpivotFactSite AS
(
SELECT [ID], [SYS_CHANGE_OPERATION], [SiteID], [SubSiteID],
[SubParameterVal] AS [SubParameter]
FROM Staging.AppsFlyerBasic
CROSS APPLY (
VALUES ('SubParam1',[SubParam1]),
('SubParam2',[SubParam2]),
('SubParam3',[SubParam3]),
('SubParam4',[SubParam4]),
('SubParam5',[SubParam5])
) x ([DimensionVal],[SubParameterVal])
)
INSERT INTO #factSite
SELECT src.[ID], NULL, src.[SYS_CHANGE_OPERATION],
site.[ID] AS DimSite_Id, subSite.ID AS DimSubSite_Id,
subParameters.[ID] AS DimParameters_Id
FROM cteUpivotFactSite AS src
INNER JOIN AppsFlyer.DimSite AS site
ON (src.[SiteID] = site.[Name] OR (src.[SiteID] IS NULL AND site.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubSite AS subSite
ON (src.[SubSiteID] = subSite.[Name] OR (src.[SubSiteID] IS NULL AND subSite.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubParameters AS subParameters
ON (src.[SubParameter] = subParameters.[Name] OR (src.[SubParameter] IS NULL AND subParameters.[Name] IS NULL))
但是,如果我分裂批次分为两个部分它的工作原理。
第1批:
--FactSite
IF OBJECT_ID('tempdb..#factSite', 'U') IS NOT NULL
DROP TABLE #factSite;
CREATE TABLE #factSite
(
[ID] INT,
[Target_Id] INT,
[SYS_CHANGE_OPERATION] NVARCHAR(1),
DimSite_Id INT,
DimSubSite_Id INT,
DimSubParameters_Id INT
);
第2批:
WITH cteUpivotFactSite AS
(
SELECT [ID], [SYS_CHANGE_OPERATION], [SiteID], [SubSiteID],
[SubParameterVal] AS [SubParameter]
FROM Staging.AppsFlyerBasic
CROSS APPLY (
VALUES ('SubParam1',[SubParam1]),
('SubParam2',[SubParam2]),
('SubParam3',[SubParam3]),
('SubParam4',[SubParam4]),
('SubParam5',[SubParam5])
) x ([DimensionVal],[SubParameterVal])
)
INSERT INTO #factSite
SELECT src.[ID], NULL, src.[SYS_CHANGE_OPERATION],
site.[ID] AS DimSite_Id, subSite.ID AS DimSubSite_Id,
subParameters.[ID] AS DimParameters_Id
FROM cteUpivotFactSite AS src
INNER JOIN AppsFlyer.DimSite AS site
ON (src.[SiteID] = site.[Name] OR (src.[SiteID] IS NULL AND site.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubSite AS subSite
ON (src.[SubSiteID] = subSite.[Name] OR (src.[SubSiteID] IS NULL AND subSite.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubParameters AS subParameters
ON (src.[SubParameter] = subParameters.[Name] OR (src.[SubParameter] IS NULL AND subParameters.[Name] IS NULL))
任何人都知道为什么单批不下降,并创建临时表,而是两个不同批次的作品?
这是因为你添加的列,Target_Id
,还不是表定义的一部分,当临时表DDL是在同一批次,因此,该元数据没有感觉到。当在先前的间歇在创建表时,执行第二批之前检测所添加的列中。要使用还没有,但将列添加到对象在同一批次必须使用动态SQL来访问表后,修改完成后如下。
--FactSite
IF OBJECT_ID('tempdb..#factSite', 'U') IS NOT NULL
DROP TABLE #factSite;
CREATE TABLE #factSite
(
[ID] INT,
[Target_Id] INT,
[SYS_CHANGE_OPERATION] NVARCHAR(1),
DimSite_Id INT,
DimSubSite_Id INT,
DimSubParameters_Id INT
);
declare @query nvarchar(2000)
set @query = N'
WITH cteUpivotFactSite AS
(
SELECT [ID], [SYS_CHANGE_OPERATION], [SiteID], [SubSiteID],
[SubParameterVal] AS [SubParameter]
FROM Staging.AppsFlyerBasic
CROSS APPLY (
VALUES (''SubParam1'',[SubParam1]),
(''SubParam2'',[SubParam2]),
(''SubParam3'',[SubParam3]),
(''SubParam4'',[SubParam4]),
(''SubParam5'',[SubParam5])
) x ([DimensionVal],[SubParameterVal])
)
INSERT INTO #factSite
SELECT src.[ID], NULL, src.[SYS_CHANGE_OPERATION],
site.[ID] AS DimSite_Id, subSite.ID AS DimSubSite_Id,
subParameters.[ID] AS DimParameters_Id
FROM cteUpivotFactSite AS src
INNER JOIN AppsFlyer.DimSite AS site
ON (src.[SiteID] = site.[Name] OR (src.[SiteID] IS NULL AND site.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubSite AS subSite
ON (src.[SubSiteID] = subSite.[Name] OR (src.[SubSiteID] IS NULL AND subSite.[Name] IS NULL))
INNER JOIN AppsFlyer.DimSubParameters AS subParameters
ON (src.[SubParameter] = subParameters.[Name] OR (src.[SubParameter] IS NULL AND subParameters.[Name] IS NULL)) '
exec sp_executesql @query