从SQL Server迁移到Snowflake时，如何迁移存储过程

Question

我在雪花上做POC，探索这个产品。

我有一个问题：在SQL Server中，我们有400-500个存储过程，这些存储过程是从SSRS报告调用的。这些存储过程本质上很简单，如下所示：

CREATE PROCEDURE [dbo].[SQL_Stored_Procedure]
    (@StartDate DATETIME, 
     @EndDate   DATETIME)
AS
BEGIN
    SELECT *
    FROM MYTable
    WHERE Cloumn_Date BETWEEN @StartDate AND @EndDate;
END

EXEC [dbo].[SQL_Stored_Procedure] @StartDate = Getdate()-1, @EndDate=Getdate()

Answer 1

对于某些用例，UDTFs可能是更好的选择，但是您可以使用javascript存储过程来运行SQL语句。这并不是非常漂亮，我希望他们能尽快将SQL作为一种语言选项添加到存储过程中。下面是上面通用查询的一个示例。

CREATE OR REPLACE PROCEDURE STORED_PROCEDURE_NAME(STARTDATE VARCHAR, ENDDATE VARCHAR)
RETURNS VARIANT
LANGUAGE JAVASCRIPT
EXECUTE AS OWNER
AS 
$$
    query = `SELECT column1, column2
            FROM MYTable
            WHERE Cloumn_Date BETWEEN '` + STARTDATE + `' AND '` + ENDDATE + `';`

    resultset = snowflake.createStatement({sqlText: query}).execute() 

    //extract the results of the query into a javascript object
    output = []
    while (resultset .next())  {
        output.push(output.getColumnValue(1), output.getColumnValue(2));
    }

    //put the output of the query into a JSON object which Snowflake can translate
    // into a "variant" and can be used downstream
    json = { "result" : output };

    return json;
$$;

//I've found it easiest to work with strings because the data type conversions
//between snowflake and javascript and back again can be tricky
CALL STORED_PROCEDURE_NAME(CURRENT_DATE::STRING, DATEADD( DAY, 1, CURRENT_DATE)::STRING);
SELECT * FROM TABLE(RESULT_SCAN(LAST_QUERY_ID()));

我发现这对于执行转换和加载的过程非常有用，但到目前为止，我只手动迁移了一小部分查询，并且需要对其中一些查询进行一些javascript调整和定制。

这将是一个有点棘手的设置，以自动迁移数百个查询，但上面的javascript可以得到更多的改进和推广（我不是javascript专家）。例如，要动态处理任何列列表而无需手动编辑:https://docs.snowflake.net/manuals/sql-reference/stored-procedures-usage.html#return-a-result-set

下面是用于在下游使用结果的额外RESULT_SCAN步骤的文档:https://docs.snowflake.net/manuals/sql-reference/stored-procedures-usage.html#using-result-scan-to-retrieve-the-result-from-a-stored-procedure