如何從asp.net Web API中使用webApi將結果存儲到數據庫中？

Question

我想知道如何從另一個ASP.Net Web API中使用WEBAPI來將響應存儲在數據庫中。 我知道如何從像JavaScript，控制檯應用程序等客戶消耗的WebAPI

但要求是，這樣使用我的WebAPI我的客戶，結果被我的WebAPI &店拉數據庫中的第三方API的數據要求我提供數據。

是否可以使用Asp.Net Web API執行此操作？

Answer 1

在本教程中解釋瞭如何消耗網頁API用C＃，在這個例子中一個控制檯應用程序被使用，但您也可以使用另一個網頁API消耗，當然。

http://www.asp.net/web-api/overview/web-api-clients/calling-a-web-api-from-a-net-client

你應該看看HttpClient

HttpClient client = new HttpClient(); 
client.BaseAddress = new Uri("http://localhost/yourwebapi"); 

確保您的要求使用接受這樣的標題爲JSON響應問：

client.DefaultRequestHeaders.Accept.Add(
new MediaTypeWithQualityHeaderValue("application/json")); 

現在來與教程不同的部分，請確保您具有與其他WEB API相同的對象，如果沒有，則您有將對象映射到您自己的對象。 ASP.NET會將您收到的JSON轉換爲您想要的對象。

HttpResponseMessage response = client.GetAsync("api/yourcustomobjects").Result; 
if (response.IsSuccessStatusCode) 
{ 
    var yourcustomobjects = response.Content.ReadAsAsync<IEnumerable<YourCustomObject>>().Result; 
    foreach (var x in yourcustomobjects) 
    { 
     //Call your store method and pass in your own object 
     SaveCustomObjectToDB(x); 
    } 
} 
else 
{ 
    //Something has gone wrong, handle it here 
} 

請注意，我使用.Result作爲例子的情況。您應該考慮在這裏使用asyncawait模式。

Answer 2

對於一些無法解釋原因，這種解決方案並不爲我工作（的類型也許有些不兼容），所以我想出了自己的解決方案：

HttpResponseMessage response = await client.GetAsync("api/yourcustomobjects"); 
if (response.IsSuccessStatusCode) 
{ 
    var data = await response.Content.ReadAsStringAsync(); 
    var product = JsonConvert.DeserializeObject<Product>(data); 
} 

這樣，我的內容被解析成JSON字符串，然後將其轉換爲我的對象。

Answer 3

public class EmployeeApiController : ApiController 
{ 
    private readonly IEmployee _employeeRepositary; 

    public EmployeeApiController() 
    { 
     _employeeRepositary = new EmployeeRepositary(); 
    } 

    public async Task<HttpResponseMessage> Create(EmployeeModel Employee) 
    { 
     var returnStatus = await _employeeRepositary.Create(Employee); 
     return Request.CreateResponse(HttpStatusCode.OK, returnStatus); 
    } 
} 

持久性

public async Task<ResponseStatusViewModel> Create(EmployeeModel Employee) 
{  
    var responseStatusViewModel = new ResponseStatusViewModel(); 
    var connection = new SqlConnection(EmployeeConfig.EmployeeConnectionString); 
       var command = new SqlCommand("usp_CreateEmployee", connection); 
       command.CommandType = CommandType.StoredProcedure; 
       var pEmployeeName = new SqlParameter("@EmployeeName", SqlDbType.VarChar, 50); 
       pEmployeeName.Value = Employee.EmployeeName; 
       command.Parameters.Add(pEmployeeName); 


       try 
       { 
        await connection.OpenAsync(); 
        await command.ExecuteNonQueryAsync(); 

        command.Dispose(); 
        connection.Dispose(); 

       } 
       catch (Exception ex) 
       { 

        throw ex; 
       } 
       return responseStatusViewModel; 
      } 

庫

Task<ResponseStatusViewModel> Create(EmployeeModel Employee); 

public class EmployeeConfig 
{ 
    public static string EmployeeConnectionString; 
    private const string EmployeeConnectionStringKey = "EmployeeConnectionString"; 
    public static void InitializeConfig() 
    { 
     EmployeeConnectionString = GetConnectionStringValue(EmployeeConnectionStringKey); 
    } 

    private static string GetConnectionStringValue(string connectionStringName) 
    { 
     return Convert.ToString(ConfigurationManager.ConnectionStrings[connectionStringName]); 
    } 
}