动态游标SQL Server

问题描述 投票:1回答:1

我有这样的全局游标,由这样的字符串创建,但是当执行时,我收到此错误消息:

名称为“crsDTO”的游标不存在。

码:

DECLARE @Cursor NVARCHAR(MAX); 

SET @Cursor = 'DECLARE crsDTO CURSOR FOR SELECT p.ID, p.Price, p.Count FROM Business.Products'; 

exec sp_executesql @Cursor; 

OPEN crsDTO; -- fails here <<<<<<<<

BEGIN TRY
    FETCH NEXT FROM crsDTO INTO @ID, @Price, @Count;

    WHILE 0 = @@fetch_status
    BEGIN
        PRINT(@ID)

        FETCH NEXT FROM crsDTO INTO @ID, @Price, @Count;
    END;

    CLOSE crsDTO;
    DEALLOCATE crsDTO;
END TRY
BEGIN CATCH
    CLOSE crsDTO;
    DEALLOCATE crsDTO;
END CATCH   

我环顾四周看起来很好......我找不到为什么它不起作用。

UPDATE

此SP将批量更新价格或库存或两者。我可能错了,可能有另外一种比这更好的方法我对所有的修正都持开放态度。但是,此光标将根据用户意见进行过滤。它可以根据过滤器更改库存/价格(百分比金额或基本金额)。因此,例如,用户希望仅批量更改特定brandId或BrandId / CategoryId和SupplierId的组合的价格,或者不改变任何一种(这意味着每个产品)。

CREATE procedure [Business].[Product_BulkUpdate]
(   
    @PO_Error             int OUTPUT,
    @PO_ErrorMessage      Nvarchar(Max) OUTPUT,
    @PO_Step              int OUTPUT,
    @CallerUserId         uniqueidentifier,
    @CategoryId           uniqueidentifier = null,
    @BrandId              uniqueidentifier = null,
    @SupplierId           uniqueidentifier = null,
    @ProductName          nvarchar(max) = null,
    @Amount               float = null,
    @AmountPercentage     float = null,
    @IsInStock            bit = null
)
as


DECLARE @ID Uniqueidentifier;
DECLARE @Price int;
DECLARE @Count int;
DECLARE @KW nvarchar(max);
DECLARE @Cursor nvarchar(max);
DECLARE @WhereClause nvarchar(max);

    set @WhereClause = ' 1=1 ';
    if (@ProductName is not null)
        set @WhereClause =@WhereClause + ' And p.Name like N'''+'%'+cast(@ProductName as nvarchar(4000))+'%'+''' ';
    if (@CategoryId is not null)
        set @WhereClause =@WhereClause + ' And c.ID in (SELECT cf.id FROM Business.GetCategoryChilds('''+CAST(@CategoryId as nvarchar(50)) +''') cf) ';
    if(@SupplierId is not null)
        set @WhereClause = @WhereClause + ' AND p.SupplierId in (' + CAST(@SupplierId as nvarchar(50)) + ') ';
    IF(@BrandId is not null)
        set @WhereClause = @WhereClause + ' AND bb.ID in (' + CAST(@BrandId as nvarchar(50)) + ')'; 

    SET @Cursor = ' DECLARE crsDTO cursor for
        SELECT p.ID, p.Price, p.Count FROM Business.Products p
        INNER JOIN Kernel.BaseEntity b on b.ID = p.ID AND b.IsDelete = 0
        LEFT JOIN Business.Brand bb on bb.ID = p.BrandId
        LEFT JOIN Business.Category c on c.ID = p.CategoryId
        LEFT JOIN MarketPlace.Supplier s on s.SupplierId = p.SupplierId

        WHERE '+@WhereClause+' AND c.CategoryTypeId = 10700';   

begin 
    --- Auto generated procedure
    SET NOCOUNT ON;
    SET @PO_Error = 0;
    SET @PO_Step = 0;
    SET @PO_ErrorMessage = '';
    BEGIN TRY  
            exec sp_executesql @Cursor;
            SET @PO_Step = 1;
            OPEN crsDTO;
            BEGIN TRY
                FETCH NEXT FROM crsDTO INTO @ID, @Price, @Count;
                while 0 = @@fetch_status
                BEGIN
                    IF(@IsInStock = 0) BEGIN
                        IF(@Amount is not null and @AmountPercentage is null) BEGIN
                            IF EXISTS (SELECT ID FROM Business.Products WHERE ID = @ID) BEGIN
                                UPDATE Business.Products SET                            
                                    Price = @Price + @Amount
                                WHERE ID = @ID                  
                            END
                        END else IF(@AmountPercentage is not null and @Amount is null) BEGIN
                            IF EXISTS (SELECT ID FROM Business.Products WHERE ID = @ID) BEGIN
                                UPDATE Business.Products SET                            
                                    Price = (@Price * (@AmountPercentage / 100))
                                WHERE ID = @ID              
                            END
                        END
                    END ELSE IF(@IsInStock = 1) BEGIN
                        IF(@Amount is not null and @AmountPercentage is null) BEGIN
                            IF EXISTS (SELECT ID FROM Business.Products WHERE ID = @ID) BEGIN
                                UPDATE Business.Products SET                            
                                    Price = @Price + @Amount,
                                    Count = 0
                                WHERE ID = @ID                  
                            END
                        END else IF(@AmountPercentage is not null and @Amount is null) BEGIN
                            IF EXISTS (SELECT ID FROM Business.Products WHERE ID = @ID) BEGIN
                                UPDATE Business.Products SET                            
                                    Price = (@Price * (@AmountPercentage / 100)),
                                    Count = 0
                                WHERE ID = @ID              
                            END
                        END ELSE IF(@Amount is null and @AmountPercentage is null) BEGIN
                            IF EXISTS (SELECT ID FROM Business.Products WHERE ID = @ID) BEGIN
                                UPDATE Business.Products SET
                                    Count = 0
                                WHERE ID = @ID
                            END
                        END
                    END
                    SET @PO_Step = 2;
                FETCH NEXT FROM crsDTO INTO @ID, @Price, @Count;
                END;
                CLOSE crsDTO;
                DEALLOCATE crsDTO;
            END TRY
            BEGIN CATCH
                CLOSE crsDTO;
                DEALLOCATE crsDTO;
                SET @PO_Error = ERROR_NUMBER();
                SET @PO_ErrorMessage = ERROR_MESSAGE();
            END CATCH   
        END TRY
    BEGIN CATCH
        SET @PO_Error = ERROR_NUMBER();
        SET @PO_ErrorMessage = ERROR_MESSAGE();
    END CATCH
END;
sql-server tsql sql-server-2017
1个回答
1
投票

我会添加检查游标是否存在:

-- ....
BEGIN CATCH
    IF CURSOR_STATUS('global','crsDTO')>=-1
    BEGIN
        CLOSE crsDTO;
        DEALLOCATE crsDTO;
    END   
END CATCH  

db<>fiddle demo

使用全局游标/逐行方法似乎不是最佳解决方案。

© www.soinside.com 2019 - 2024. All rights reserved.