using System;

using System.Data;

using System.Data.SqlClient;

using System.Data.SqlTypes;

using Microsoft.SqlServer.Server;

using System.Net;

using System.IO;

using Rest;

using System.Text;

public partial class UserDefinedFunctions

{

[Microsoft.SqlServer.Server.SqlFunction(DataAccess = DataAccessKind.Read, Name = "fn_rest_get")]

public static SqlString GET(SqlString uri, SqlString headers)

{

SqlString document;

WebRequest req = WebRequest.Create(Convert.ToString(uri));

req.Headers = Headers.SetHeader(headers.ToString());

req.ContentType = "application/json";

WebResponse resp = req.GetResponse();

Stream dataStream = resp.GetResponseStream();

StreamReader rdr = new StreamReader(dataStream);

document = (SqlString)rdr.ReadToEnd();

rdr.Close();

dataStream.Close();

resp.Close();

return (document);

}

[Microsoft.SqlServer.Server.SqlFunction(DataAccess = DataAccessKind.Read, Name = "fn_rest_post")]

public static SqlString POST(SqlString uri, SqlString postData, SqlString headers)

{

SqlString document;

byte[] postByteArray = Encoding.UTF8.GetBytes(Convert.ToString(postData));

WebRequest req = WebRequest.Create(Convert.ToString(uri));

req.Headers = Headers.SetHeader(headers.ToString());

req.ContentType = "application/json";

req.Method = "POST";

Stream dataStream = req.GetRequestStream();

dataStream.Write(postByteArray, 0, postByteArray.Length);

dataStream.Close();

WebResponse resp = req.GetResponse();

dataStream = resp.GetResponseStream();

StreamReader rdr = new StreamReader(dataStream);

document = (SqlString)rdr.ReadToEnd();

rdr.Close();

dataStream.Close();

resp.Close();

return (document);

}

}