SQL Server存储过程合并2个OpenQuery的输出结果

Question

这是我的第一篇文章。希望得到我的代码一些帮助。

我正在尝试编写一个存储过程来合并来自每个指向不同链接服务器的2个打开查询的结果。

存储过程接受一个参数。

第一OPENQUERY回报Col1, Col2, Col3, Col4

多行我想的Col1结果传递给第二OPENQUERY返回Col1,Col5,Col6，然后将结果组合成一个表变量以从读出。

我不能在这里粘贴确切的查询，但会粘贴结构。希望有助于理解我目前的做法。感谢我能否得到一些建议。

这适用于1输入但显然失败时，我通过多个输入。我如何处理第一个查询的结果并传递给第二个查询。

ALTER PROCEDURE [dbo].[MyStoredProc] 
    @Input AS NVARCHAR(MAX) 
AS 
    BEGIN TRY 
     SET NOCOUNT ON; 

     DECLARE @TSQL1 NVARCHAR(MAX) 
     DECLARE @TSQL2 NVARCHAR(MAX) 
     DECLARE @Col1Results NVARCHAR(MAX) 

     /*** OpenQuery 1***/ 
     SELECT @TSQL1 = 'SELECT Col1, Col2, Col3, Col4 FROM Table1 
          WHERE Input IN ('''+ @Input +''') ' 

     DECLARE @tblTempTable1 AS TABLE 
            (
             Col1 NVARCHAR(100), 
             Col2 NVARCHAR(100), 
             Col3 NVARCHAR(50), 
             Col4 NVARCHAR(50) 
           ) 

     INSERT INTO @tblTempTable1 
      EXEC (@TSQL1) AT [LinkedServer1] 

     SELECT @Col1Results = Col1 
     FROM @tblTempTable1 

     /*** Open Query 2***/ 
     SELECT @TSQL2 = 'SELECT Col1, Col5, Col6 FROM Table2 
          WHERE Input IN ('''+ @Col1Results +''') ' 

     DECLARE @tblTempTable2 AS TABLE 
            (
             Col1 NVARCHAR(100), 
             Col5 NVARCHAR(100), 
             Col6 NVARCHAR(50) 
           ) 

     INSERT INTO @tblTempTable2 
      EXEC (@TSQL2) AT [LinkedServer2] 

     SELECT 
      t1.Col1, t1.Col2, t1.Col3, t2.Col2, t2.Col3 
     FROM 
      @tblTempTable1 t1 
     INNER JOIN 
      @tblTempTable2 t2 ON t1.Col1 = t2.Col1 
    END TRY 
    BEGIN CATCH 
    END CATCH 

---------------------------Update---------------------------------
我能够使用游标来实现期望的结果。但注意到在很大程度上使用光标命中性能。下面的代码可以进一步优化以提高性能。谢谢。

ALTER PROCEDURE [dbo].[MyStoredProc] 
    @Input AS NVARCHAR(MAX) AS 
    BEGIN TRY 
    SET NOCOUNT ON; 


Declare @tblTempTable1 Table 
      (
       Col1 Nvarchar(100), 
       Col2 Nvarchar(100), 
       Col3 nvarchar(50), 
       Col4 nvarchar(50) 
      ) 

SELECT @TSQL1 = 'Select Col1,Col2,Col3,Col4 From Table1 
       where Input in ('''+@Input+''')' 

Insert @tblTempTable1 EXEC (@TSQL1) at [LinkedServer1] 

Declare @tblTempTable2 Table 
      (
       Col1 Nvarchar(100), 
      Col2 Nvarchar(100), 
       Col3 nvarchar(50) 
     ) 

Declare db_cursor CURSOR for 
Select Col1 from @tblTempVTErrors 

Open db_cursor 
fetch NEXT FROM db_cursor into @Column1 

While @@FETCH_STATUS=0 
Begin 


SELECT @TSQL2 = 'Select Col1,Col5,Col6 From Table2 
       where Col1 in ('''+@Column1+''')' 

Insert @tblTempTable2 EXEC (@TSQL2) at [LinkedServer2] 

FETCH NEXT FROM db_cursor INTO @Column1 


End 

Close db_Cursor 
Deallocate db_Cursor 


    Select t1.Col1,t1.Col2,t1.Col3,t2.Col2,t2.Col3 
    from @tblTempTable1 t1 
    inner join @tblTempTable2 t2 on t1.Col1=t2.Col1 

END TRY 
BEGIN CATCH 
END CATCH 

Answer 1

如果我理解正确的话，当输入一个值，说“测试”，那么它的工作原理，因为只选择了一个纪录 - 输入是某种形式的唯一标识符。但只要您通过“测试”，“测试2”，“测试3”，它就会失败，因为它将多个记录放入@ tblTempTable1中，然后SELECT @ Col1Results将失败，因为选择了多个记录？

如果是这样，那么你需要做这样的事情：

创建一个功能，让您拆分这种输入参数。我使用：

create FUNCTION [dbo].[fnSplit](
    @sInputList VARCHAR(max) -- List of delimited items 
    , @sDelimiter VARCHAR(5) -- delimiter that separates items 
) RETURNS @List TABLE (item VARCHAR(max)) 

BEGIN 
DECLARE @sItem VARCHAR(max) 
WHILE CHARINDEX(@sDelimiter,@sInputList,0) <> 0 
BEGIN 
SELECT 
    @sItem=RTRIM(LTRIM(SUBSTRING(@sInputList,1,CHARINDEX(@sDelimiter,@sInputList,0)-1))), 
    @sInputList=RTRIM(LTRIM(SUBSTRING(@sInputList,CHARINDEX(@sDelimiter,@sInputList,0)+LEN(@sDelimiter),LEN(@sInputList)))) 

IF LEN(@sItem) > 0 
    INSERT INTO @List SELECT @sItem 
END 

IF LEN(@sInputList) > 0 
INSERT INTO @List SELECT @sInputList -- Put the last item in 
RETURN 
END 

现在你可以摆脱所有的动态SQL和改变的过程简称为：

ALTER PROCEDURE MyStoredProc @Input as NVARCHAR(Max) 
AS 
    BEGIN TRY 
    SET NOCOUNT ON; 


    Declare @tblTempTable1 Table 
    (
    Col1 Nvarchar(100), 
    Col2 Nvarchar(100), 
    Col3 nvarchar(50), 
    Col4 nvarchar(50) 

    ) 

    insert INTO @tblTempTable1 
    Select Col1,Col2,Col3,Col4 From Table1 
    where Input in (SELECT Item FROM dbo.fnSplit(@Input, ',')) 

    Declare @tblTempTable2 Table 
    (
    Col1 Nvarchar(100), 
    Col2 Nvarchar(100), 
    Col3 nvarchar(50) 
    ) 

    insert INTO @tblTempTable2 
    Select Col1,Col5,Col6 From Table2 
    where Input in (SELECT Col1 FROM @tblTempTable1) 

    Select t1.Col1,t1.Col2,t1.Col3,t2.Col2,t2.Col3 
    from @tblTempTable1 t1 
    inner join @tblTempTable2 t2 on t1.Col1=t2.Col1 
END TRY 
BEGIN CATCH 
END CATCH