SSMS:OPENJSON 有效,但不适用于直接 REST 调用

SSMS: OPENJSON works but not with direct REST call

this article 之后,我正在尝试实现一个可以从 REST 调用中检索数据并使用 OPENJSON.

解析 JSON 的查询

我给Postman打电话this URL检查数据是否正常:

数据在那里。

我复制粘贴 JSON 并在 SSMS 上测试我的调用:

DECLARE @json nvarchar(max) = N'{
    "version": 0.6,
    "generator": "Overpass API 0.7.55.4 3079d8ea",
    "osm3s": {
        "timestamp_osm_base": "2018-10-04T10:07:02Z",
        "timestamp_areas_base": "2018-10-04T09:02:02Z",
        "copyright": "The data included in this document is from www.openstreetmap.org. The data is made available under ODbL."
    },
    "elements": [
        {
            "type": "node",
            "id": 501591237,
            "lat": 49.4943882,
            "lon": -117.2910343,
            "tags": {
                "amenity": "cinema",
                "name": "Civic Theatre",
                "website": "http://civictheatre.ca"
            }
        },
        {
            "type": "node",
            "id": 2293276829,
            "lat": -41.2709865,
            "lon": 173.2842196,
            "tags": {
                "amenity": "cinema",
                "name": "Cinema 6"
            }
        }
    ]
}';



SELECT * FROM OPENJSON(@json, N'$.elements')
WITH (   
      [type] nvarchar(max) N'$.type'   ,
      [id]   nvarchar(max) N'$.id',
      [lat]   nvarchar(max) N'$.lat',
      [lon]   nvarchar(max) N'$.lon',
      [amenity]   nvarchar(max) N'$.tags.amenity',
      [name]   nvarchar(max) N'$.tags.name'

)

很好,正在运行:我的查询可以解析 JSON。

我现在关注 this guide,它向我展示了如何在 SSMS 中进行 REST 调用 ,我尝试检索相同的 URL 和在 SSMS 中即时查看它们:

Declare @Object as Int;
Declare @json as nvarchar(max);


Exec sp_OACreate 'MSXML2.XMLHTTP', @Object OUT;
Exec sp_OAMethod @Object, 'open', NULL, 'get',
                 'http://overpass-api.de/api/interpreter?data=[out:json];area[name=%22Nelson%22]-%3E.a;(node(area.a)[amenity=cinema];way(area.a)[amenity=cinema];rel(area.a)[amenity=cinema];);out;', --Your Web Service Url (invoked)
                 'false'
Exec sp_OAMethod @Object, 'send'
Exec sp_OAMethod @Object, 'responseText', @json OUTPUT

select @json

SELECT * FROM OPENJSON(@json, N'$.elements')
WITH (   
      [type] nvarchar(max) N'$.type'   ,
      [id]   nvarchar(max) N'$.id',
      [lat]   nvarchar(max) N'$.lat',
      [lon]   nvarchar(max) N'$.lon',
      [amenity]   nvarchar(max) N'$.tags.amenity',
      [name]   nvarchar(max) N'$.tags.name'

)

Exec sp_OADestroy @Object

哎呀!不工作!

为什么数据是空的? Declare @json as nvarchar(max); 正在处理上一个查询。为什么不再工作了?

如果我输入 Declare @json as varchar(8000); 它之所以有效,只是因为我检索的字符少于 8000 个,但我不能这样工作。

如果我没记错的话 OPENJSON 正是为了避免此类问题而开发的,并加载到 2GB 的数据。

我想使用 nvarchar(max) 并加载大量数据。这就是使用 OPENJSON.

的全部要点

完成。

非常感谢@PanagiotisKanavos status 的建议,以便捕获错误。

解决方案是使用 Declare @json as table(Json_Table nvarchar(max)) 并将 JSON 存储到 table 而不是变量中。 现在可以存储2GB!!!

Declare @Object as Int;
DECLARE @hr  int
Declare @json as table(Json_Table nvarchar(max))

Exec @hr=sp_OACreate 'MSXML2.ServerXMLHTTP.6.0', @Object OUT;
IF @hr <> 0 EXEC sp_OAGetErrorInfo @Object
Exec @hr=sp_OAMethod @Object, 'open', NULL, 'get',
                 'http://overpass-api.de/api/interpreter?data=[out:json];area[name="Auckland"]->.a;(node(area.a)[amenity=cinema];way(area.a)[amenity=cinema];rel(area.a)[amenity=cinema];);out;', --Your Web Service Url (invoked)
                 'false'
IF @hr <> 0 EXEC sp_OAGetErrorInfo @Object
Exec @hr=sp_OAMethod @Object, 'send'
IF @hr <> 0 EXEC sp_OAGetErrorInfo @Object
Exec @hr=sp_OAMethod @Object, 'responseText', @json OUTPUT
IF @hr <> 0 EXEC sp_OAGetErrorInfo @Object

INSERT into @json (Json_Table) exec sp_OAGetProperty @Object, 'responseText'

SELECT * FROM OPENJSON((select * from @json), N'$.elements')
WITH (   
      [type] nvarchar(max) N'$.type'   ,
      [id]   nvarchar(max) N'$.id',
      [lat]   nvarchar(max) N'$.lat',
      [lon]   nvarchar(max) N'$.lon',
      [amenity]   nvarchar(max) N'$.tags.amenity',
      [name]   nvarchar(max) N'$.tags.name'     
)
EXEC sp_OADestroy @Object

这是完成任务的正确方法吗?

见鬼不!我不应该使用 sp_OAMethod,而应该使用 SQLCLR,或者用 PythonPowerShellVB、[=18= 编写的任何其他外部进程],等等...

但是,你知道的,我也应该少喝啤酒,少买培根,但是...YOLO,不管有什么用...就去做吧。

多亏了这个,我现在可以创建一个存储过程来进行 REST 调用并自动将数据保存到 SQL 服务器中。我寻找解决方案好几天了,终于找到了答案 here.

我希望这会有所帮助,我看到有几百人在那里搜索这个回复。