Я пытаюсь создать пакет SSIS, который вызывает REST API и вставляет ответы в таблицу сервера SQL Azure. Для этого я использую задачу сценария и диспетчер соединений ADO.NET. Ответ API находится в формате JSON, как показано ниже.
[{"id":1,"name":"AX BD","description":"D","shippingFreeze":false,"receivingFreeze":false,"mouseNorovirus":false,"irradiatedFeed":true,"createdAt":"2022-02-24T10:03:50.09","lastUpdated":"2022-02-24T10:03:50.09"},
{"id":2,"name":"AX PD","description":"B","shippingFreeze":false,"receivingFreeze":false,"mouseNorovirus":false,"irradiatedFeed":false,"createdAt":"2022-02-24T10:03:50.09","lastUpdated":"2022-02-24T10:03:50.09"}]
и ниже в задаче сценария я попытался сделать вызов REST API и преобразовал ответ в JSON, но я не уверен, как выполнить итерацию по каждой записи JSON и вставить их, сопоставляя значения из JSON в sqlCmd.Parameters.AddWithValue
public void Main()
{
try
{
string serviceUrl = Dts.Variables["$Project::ServiceUrl"].Value.ToString();
HttpClient client = new HttpClient();
client.BaseAddress = new Uri(serviceUrl);
client.DefaultRequestHeaders.Accept.Add(
new MediaTypeWithQualityHeaderValue("application/json"));
string APIUrl = string.Format(serviceUrl + "/rooms");
var response = client.GetAsync(APIUrl).Result;
if (response.IsSuccessStatusCode)
{
var result = response.Content.ReadAsStringAsync().Result;
dynamic res_JSON = JsonConvert.DeserializeObject(result);
ConnectionManager cm = Dts.Connections["SurplusMouse_ADONET"];
var sqlConn = (System.Data.SqlClient.SqlConnection)cm.AcquireConnection(Dts.Transaction);
using (var sqlCmd = new System.Data.SqlClient.SqlCommand(
"INSERT INTO [dbo].[RM_Room]([ROOMID],[NAME],[DESCRIPTION],[SHIPPING_FREEZE],[RECEIVING_FREEZE],[MOUSE_NOROVIRUS],[IRRADIATED_FEED])" +
"VALUES(@ROOMID,@NAME,@DESCRIPTION,@SHIPPING_FREEZE,@RECEIVING_FREEZE,@MOUSE_NOROVIRUS,@IRRADIATED_FEED,)", sqlConn))
{
sqlCmd.CommandType = CommandType.Text;
sqlCmd.Parameters.AddWithValue("@ROOMID", xxxxx);
..................
int rowsAffected = sqlCmd.ExecuteNonQuery();
}
cm.ReleaseConnection(sqlConn);
}
}
catch (Exception ex)
{
Dts.TaskResult = (int)ScriptResults.Failure;
}
}
Это мой первый проект, использующий сценарии SSIS и вызов API, любая помощь приветствуется.
Вы можете повторить res_JSON
, как показано ниже:
dynamic res_JSON = JsonConvert.DeserializeObject(result);
foreach (var jsonObj in res_JSON)
{
//Clear Parameter of sqlCmd
sqlCmd.CommandType = CommandType.Text;
sqlCmd.Parameters.AddWithValue("@ROOMID", jsonObj.id);
sqlCmd.Parameters.AddWithValue("@NAME", jsonObj.name);
sqlCmd.Parameters.AddWithValue("@DESCRIPTION", jsonObj.description);
//You can access another props of jsonObj also
int rowsAffected = sqlCmd.ExecuteNonQuery();
}
или для удобочитаемости лучше иметь эквивалентный вам класс json
, например:
public class JsonObj
{
public int id { get; set; }
public string name { get; set; }
public string description { get; set; }
public bool shippingFreeze { get; set; }
public bool receivingFreeze { get; set; }
public bool mouseNorovirus { get; set; }
public bool irradiatedFeed { get; set; }
public DateTime createdAt { get; set; }
public DateTime lastUpdated { get; set; }
}
и deserialize
result
как массив JsonObj
, например:
var res_JSON = JsonConvert.DeserializeObject<JsonObj[]>(result);
foreach (var obj in res_JSON)
{
//obj.id
//obj.name
//...
}