Pokud je třeba stáhnout obsah webové adresy z prostředí SQL Serveru, nebo se z něj připojit na webovou službu, lze to udělat Startkovou procedurou DownloadURL (případně jednou z jejích variant). Procedura(-y) je řešena jako CLR knihovna, do aplikační databáze ji lze tedy nahrát buď skriptem, nebo přímým importem DLL knihovny.
CREATE OR ALTER PROCEDURE dbo.DownloadURL ( @URL [nvarchar](1000), @RequestMethod [nvarchar](10), @Headers [nvarchar](MAX) OUTPUT, @DATA [nvarchar](MAX), @Response [nvarchar](MAX) OUTPUT, @ResponseStatus [INT] = NULL OUTPUT , @ResponseEncoding [nvarchar](10) = NULL) AS EXTERNAL NAME DownloadURL.CDownloadURL.DownloadURL
<Headers><Jmeno>hodnota</Jmeno></Headers>
Základní ověření (Basic authentication) se předává v hlavičce ve formátu:
<Headers><Authorization>Basic xxx</Authorization></Headers>
kde xxx
je přihlašovací jméno a heslo v Base64 kódování. Získat je lze i z online generátorů např. zde: https://www.debugbear.com/basic-auth-header-generator.
Mějme e-shop, jehož API je dostupné na adrese https://api.my-eshop.cz. Parametry na odkazu určíme oblast a akci, kterou chceme po rozhraní provést (oblast prodeje, akce stažení seznamu prodejních dokladů). V proměnné @credentials si sestavíme přihlašovací údaje a spolu s dalšími HTTP hlavičkami (které nám dodal výrobce rozhraní e-shopu) je připravíme do proměnné @headers. Filtrovací podmínky výrobce e-shopu předepisuje předat v datech HTTP požadavku ve formátu JSON, připravíme si je tedy v požadovaném formátu do proměnné @myData. Vše máme připraveno, zavoláme tedy URL s rozhraním a stáhneme (a vypíšeme) si seznam prodejních dokladů.
DECLARE @credentials [nvarchar](4000) = 'Basic dGVzdDp0ZXN0' --Base64 encoded name/password = test/test DECLARE @headers [nvarchar](4000) = '<Headers><Accept>application/x.app.v1.0+json; UTF-8</Accept><Authorization>' + @credentials + '</Authorization></Headers>' DECLARE @myData [nvarchar](MAX) = '{ "type": 0, "dateFrom": "2021-10-01T23:28:56.782Z" }' DECLARE @Response [nvarchar](MAX) DECLARE @ResponseStatus [INT] EXEC [dbo].[DownloadURL] 'https://api.my-eshop.cz/?module=sale&action=list', 'POST', @headers, @myData, @Response OUT SELECT @ResponseStatus AS HTTPstatus, @Response AS HTTPresponse, @headers AS HTTPheaders
Kromě základního ověřování (Basic Authentication) je nejrozšířenější tzv.JWT autentikace, tedy ověřování pomocí autorizačního tokenu (více např. na https://jwt.io/). Pomocí základního ověření se nejprve získá ověřovací token, který se následně používá v datové komunikaci.
--první volání slouží k získání autentikačního tokenu (JWT), který potom využívám k volání datových funkcí DECLARE @URL NVARCHAR(255) = 'https://api.my-eshop.cz/oauth/token' DECLARE @headers NVARCHAR(4000) = '<Headers><Accept></Accept><Authorization>' + @credentials + '</Authorization></Headers>' DECLARE @DATA NVARCHAR(MAX) = '{"role": "admin", "type": "client_credentials"}' DECLARE @Response NVARCHAR(MAX) EXEC [dbo].[DownloadURL] @URL, 'POST', @Headers, @DATA, @Response OUT SELECT @Response --ukázka formátu výsledku (proměnná @Json) a jeho zpracování -> získání autorizačního tokenu DECLARE @Json NVARCHAR(MAX) DECLARE @AccessToken NVARCHAR(MAX) --max 8kB SET @Json='{ "access_token": "asdASDasdASDasdASDasdASDasdASDasdASD", "token_type": "bearer", "expires_in": 3599, "role": "admin" }' SELECT @AccessToken = access_token FROM OPENJSON(@Json) WITH ( access_token nvarchar(MAX) '$.access_token' , token_type VARCHAR(10) '$.token_type', expires_in INT '$.expires_in', scope VARCHAR(10) '$.scope' ) --ukázka použití získaného JWT tokenu v datovém volání DECLARE @URL NVARCHAR(255) = 'https://api.my-eshop.cz/invoices' DECLARE @Headers NVARCHAR(4000) = '<Headers><Accept>*/*</Accept><Authorization>Bearer ' + @AccessToken + '</Authorization><Content-Type>application/json</Content-Type></Headers>' DECLARE @DATA NVARCHAR(MAX) = '{ "data_get": "all"}' DECLARE @Response NVARCHAR(MAX) EXEC [dbo].[DownloadURL] @URL, 'POST', @Headers, @DATA, @Response OUT SELECT @Response
Pokud je třeba jedním HTTP requestem zároveň poslat data soubory, řeší se to tzv.multipart HTTP requestem. I tento způsob HTTP komunikace lze realizovat z prostředí SQL serveru stejnou CLR knihovnou.
CREATE OR ALTER PROCEDURE dbo.HTTPPOSTMultipartData ( @URL [nvarchar](1000), @Headers [nvarchar](MAX), @multipartFormXMLData[nvarchar](MAX), @fileName [nvarchar](255), @fileBuffer [varbinary](MAX), @fileParamName [nvarchar](50), @fileContentType [nvarchar](255), @Response [nvarchar](MAX) OUTPUT) AS EXTERNAL NAME DownloadURL.CDownloadURL.HTTPPOSTMultipartData GO
<formData><name>value</name><name>value</name></formData>
DECLARE @credentials NVARCHAR(4000) = 'Basic dGVzdDp0ZXN0' --Base64 encoded name/password = test/test DECLARE @headers NVARCHAR(4000) = '<Headers><Accept></Accept><Authorization>' + @credentials + '</Authorization></Headers>' DECLARE @DATA [nvarchar](MAX) = '{"invoice_id": "ASD123","type": 1,"currency": "CZK","value": "1","customer_id": "TEST","customer_name": "TEST"}' DECLARE @multipartFormXMLData [nvarchar](MAX) = '<formData><data>' + @DATA + '</data></formData>' DECLARE @fileContent [varbinary](MAX) SELECT @fileContent = FILEIMAGE FROM [ESO9start_DOC].dbo.Eso9Doc DECLARE @Response [nvarchar](MAX) EXEC [dbo].[HTTPPOSTMultipartData] 'https://api.my-eshop.cz?module=Invoices&action=Insert', @headers, @multipartFormXMLData, 'faktura.pdf', @fileContent, 'invoice', 'application/octet-stream', @Response OUT SELECT @Response
Předchozí text se týkal případů, kdy se HTTP protokolem přenáší textový obsah.
Pokud potřebujeme přenášet obecně binární obsah (např. obrázek zboží z e-shopu, sken účtenky od dodavatele apod.), lze to udělat Startkovou procedurou DownloadBinURL.
CREATE OR ALTER PROCEDURE dbo.DownloadBinURL ( @URL [nvarchar](1000), @RequestMethod [nvarchar](10), @Headers [nvarchar](MAX), @DATA [nvarchar](MAX), @RespHeaders [nvarchar](MAX) OUTPUT, @Response [varbinary](MAX) OUTPUT, @ErrDesc [nvarchar](MAX) OUTPUT) AS EXTERNAL NAME DownloadURL.CDownloadURL.DownloadBinURL
Zkusme si z webu stáhnout obrázek a uložit si jej do DMS ESO9.
Proceduře předáme URL adresu požadovaného obrázku, který po volání dostaneme v proměnné @fileContent. Výstupní parametry si po stažení obrázku pro kontrolu vypíšeme. Obrázek následně pomocí Startkové procedury spDokument_Zalozeni uložíme do DMS v ESO9 a vypíšeme si ID nově založeného dokumentu. Pokud by se jednalo např. o obrázek importovaného zboží, mohu si jej v proceduře rovnou napojit na tabulku ZBOZI pomocí parametrů @TableName a @idTable.
DECLARE @headers NVARCHAR(4000) = '<Headers><CONTENT-TYPE>image/png</CONTENT-TYPE></Headers>' DECLARE @respHeaders NVARCHAR(MAX) DECLARE @idDokument_new INT DECLARE @fileContent [varbinary](MAX) DECLARE @errDesc [nvarchar](MAX) EXEC [dbo].[DownloadBinURL] 'https://scripts.eso9.cz/rtm/img/home_bg.jpg', 'GET', @headers, NULL, @respHeaders OUT, @fileContent OUT, @errDesc OUT SELECT DATALENGTH(@fileContent) AS LENGTH, @errDesc AS chyba, @respHeaders AS headers EXEC dbo.spDokument_Zalozeni @TableName='', @idTable=NULL, @FileName='obrazek.jpg', @FileImage=@fileContent, @idDokument = @idDokument_new OUT SELECT @idDokument_new AS IDDokument
Pokud je HTTP volání ověřováno klientskými certifikáty, lze k tomu použít proceduru DownloadURLcertAuth. Klientský certifikát, použitý pro ověření, může být uložen např. v DMS.
CREATE OR ALTER PROCEDURE dbo.DownloadURLcertAuth ( @URL [nvarchar](1000), @RequestMethod [nvarchar](10), @Headers [nvarchar](MAX), @DATA [nvarchar](MAX), @Cert [varbinary](MAX), @CertPwd [nvarchar](100), @Response [nvarchar](MAX) OUTPUT) AS EXTERNAL NAME DownloadURL.CDownloadURL.DownloadURLcertAuth
--stažení URL ověřovaného klientským certifikátem DECLARE @Response nvarchar(MAX) DECLARE @headers NVARCHAR(4000) = '<Headers><Accept>application/json</Accept></Headers>' DECLARE @CertGUID VARCHAR(40) = 'abcd1234-4567-5678-abcd-ef1234ef1234' DECLARE @Cert [varbinary](MAX) SELECT @Cert = FILEIMAGE FROM ESO9start_DOC.dbo.Eso9Doc WHERE FILEGUID = @CertGUID EXEC [dbo].[DownloadURLcertAuth] 'https://testapi.sukl.cz/hsz/v1/pracoviste', 'GET', @headers, '', @Cert, 'SecretPassword', @Response OUT SELECT @Response
Ověřování protokolem OAuth 2.0 je jen zjednodušením obecnější JWT autentikace z první kapitoly. Ověřování OAuth 2.0 spočívá v získání autentikačního tokenu (tzv.Bearer Tokenu) od poskytovatele ověření a následně použití ověřovacího tokenu pro vlastní datovou komunikaci s (obecně) vlastníkem prostředků. Tato dvě HTTP volání umožňuje procedura DownloadURLbearerAuth sloučit do jediného a tedy odstranit parsování autentikační odpovědi a získávání a udržování tokenu.
CREATE OR ALTER PROCEDURE dbo.DownloadURLbearerAuth ( @URL [nvarchar](1000), @AuthURL [nvarchar](1000), @RequestMethod [nvarchar](10), @Headers [nvarchar](MAX) OUTPUT, @AuthHeaders [nvarchar](1000), @DATA [nvarchar](MAX), @AuthData [nvarchar](MAX), @Response [nvarchar](MAX) OUTPUT) AS EXTERNAL NAME DownloadURL.CDownloadURL.DownloadURLbearerAuth
DECLARE @APIVersion NVARCHAR(255) = '9.2' DECLARE @authURL NVARCHAR(255) = 'https://login.microsoftonline.com/{{tenantId}}/oauth2/v2.0/authorize' -- URL použité pro autentikaci = pro získání Bearer tokenu DECLARE @tokenURL NVARCHAR(255) = 'https://login.microsoftonline.com/{{tenantId}}/oauth2/v2.0/token' -- URL použité pro volání funkcí API rozhraní DECLARE @webAPIURL NVARCHAR(255) = 'https://xxxtest.crm4.dynamics.com/api/data/v{{version}}/' -- identifikace aplikace a uživatele vůči API DECLARE @tenantID NVARCHAR(255) = '9251d13e-a086-49a0-8c07-123456789012' DECLARE @clientID NVARCHAR(255) = '946251d7-04a0-4122-9a46-123456789012' DECLARE @clientSecret NVARCHAR(255) = 'BzcOyNjYr63S3ZTPoyfuIJ0Fs/xxxYYYzzzYYY=' -- HTTP hlavičky použité pro volání funkcí API rozhraní DECLARE @Headers NVARCHAR(4000) -- HTTP hlavičky použité pro autentikaci. Pokud nejsou zadány, použijí se pro autentikaci hlavičky z volání API (@Headers) DECLARE @AuthHeaders NVARCHAR(4000) -- HTTP request body použité pro volání funkcí API rozhraní DECLARE @DATA NVARCHAR(MAX) -- HTTP request body použité pro autentikaci DECLARE @AuthData NVARCHAR(MAX) DECLARE @Response NVARCHAR(MAX) -- pomocná porměnná pro sestavení finálního URL DECLARE @APIURL NVARCHAR(255) BEGIN TRY -- URL pro získání autentikačního Bearer tokenu SET @tokenURL = REPLACE(@tokenURL, '{{tenantId}}', @tenantID) -- hlavičky HTTP requestu pro komunikace SET @Headers = '<Headers><Accept>*/*</Accept><Content-Type>application/json</Content-Type></Headers>' -- hlavičky HTTP requestu pro autentikaci jsou jiné, než pro volání API funkcí SET @AuthHeaders = '<Headers><Content-Type>application/x-www-form-urlencoded</Content-Type></Headers>' -- datový obsah Body s autentikačními údaji pro získání Bearer tokenu SET @AuthData = 'grant_type=client_credentials&client_id=' + @clientID + '&client_secret=' + @clientSecret + '&scope=https%3A%2F%2Ftest.crm4.dynamics.com%2F.default' -- URL pro volání fce erpnotifications z API SET @APIURL = REPLACE(@webAPIURL, '{{version}}', @APIVersion) + 'erpnotifications' -- HTTP request Body pro volání fce erpnotifications z API SET @DATA = '{ "name": "testovací notifikace", "tablename": "PROJEKT", "idrecord": "123456", "operationtype": 1, "textdata": "notifikace změny projektu s ID=123456" }' EXEC [dbo].[DownloadURLbearerAuth] @APIURL, @tokenURL, 'POST', @Headers, @AuthHeaders, @DATA, @AuthData, @Response OUT SELECT @Response, @headers
Pro potřeby volání ESO9 API je možno využít proceduru DownloadURLEso9Api, která na základě x-api-key zaslaného v parametru @Headers s ostatními hlavičkami. A na základě zaslané hodnoty apiHash v parametru @apiHash vypočítá x-eso9-signature používané k ověřování při volání ESO9 API.
CREATE OR ALTER PROCEDURE dbo.DownloadURLEso9Api ( @URL [nvarchar](1000), @RequestMethod [nvarchar](10), @Headers [nvarchar](MAX) OUTPUT, @DATA [nvarchar](MAX), @ApiHash [nvarchar](600), @Response [nvarchar](MAX) OUTPUT, @ResponseStatus [INT] = NULL OUTPUT , @ResponseEncoding [nvarchar](10) = NULL) AS EXTERNAL NAME DownloadURL.CDownloadURL.DownloadURLEso9Api GO
* @Headers - HTTP hlavičky, musí obsahovat přidělenou hodnotu x-api-key
<Headers><x-api-key>a62160ba-f04d-47b8-8c3a-718ab6bf00b2</x-api-key></Headers>
* @ApiHash - přidělená hodnota apiHash
DECLARE @Response nvarchar(MAX), @ResponseStatus INT EXEC DownloadURLEso9Api @URL ='http://ws003/webapieso9/getdata', @RequestMethod ='POST', @Headers ='<Headers><Accept>*/*</Accept><Content-Type>application/json</Content-Type><x-api-key>a62160ba-f04d-47b8-8c3a-718ab6bf00b2</x-api-key></Headers>', @DATA= '{"vltyp": 1001,"params": [{"ico": "27624609"}]}', @apiHash = 'Ana7Ez7MqFnenlUIQdX94zVml6wz0y7IgjJbmZRaiwQ=', @Response = @Response OUT, @ResponseStatus = @ResponseStatus OUT , @ResponseEncoding = NULL SELECT @Response, @ResponseStatus