分页 Web 返回的大量数据 API
Paging the huge data that is returned by the Web API
我们创建了用于查询 Oracle 数据库的 WebAPI。查询 returns 结果很大,因此有时会抛出 OutOfMemoryException
.
建议使用 Paging 概念。我不明白客户端应用程序如何知道必须调用 API 多少次才能获得整组结果。我还需要为分页创建一个单独的 class 还是可以在我的 API 控制器中操作它。
任何人都可以帮助我,因为这是我的第一个 Web API。我们不能为此创建存储过程,因为我们只有对数据库的读取权限
public HttpResponseMessage Getdetails([FromUri] string[] id)
{
string connStr = ConfigurationManager.ConnectionStrings["ProDataConnection"].ConnectionString;
using (OracleConnection dbconn = new OracleConnection(connStr))
{
var inconditions = id.Distinct().ToArray();
var srtcon = string.Join(",", inconditions);
DataSet userDataset = new DataSet();
var strQuery = @"SELECT * from STCD_PRIO_CATEGORY where STPR_STUDY.STD_REF IN(" + srtcon + ")";
using (OracleCommand selectCommand = new OracleCommand(strQuery, dbconn))
{
using (OracleDataAdapter adapter = new OracleDataAdapter(selectCommand))
{
DataTable selectResults = new DataTable();
adapter.Fill(selectResults);
var returnObject = new { data = selectResults };
var response = Request.CreateResponse(HttpStatusCode.OK, returnObject, MediaTypeHeaderValue.Parse("application/json"));
ContentDispositionHeaderValue contentDisposition = null;
if (ContentDispositionHeaderValue.TryParse("inline; filename=ProvantisStudyData.json", out contentDisposition))
{
response.Content.Headers.ContentDisposition = contentDisposition;
}
return response;
}
}
}
}
通过 API 分页的总体思路是,客户端将传递他们想要的 "page" 数据和他们想要的 "amount" 记录。
从那里您可以构建您的查询,使其达到
的效果
Select all records, but skip ((Page - 1) * amount) of records and take (amount) of records.
如果您使用 LINQ to SQL,有 Take() 和 Skip() 方法可以帮助您更轻松地在代码端编写代码。如果您不使用 LINQ to SQL,则需要查找特定于 Oracle 的内容。
最后请注意,由于一个好的 API 被设计为 "stateless",因此客户端需要在处理 previous/next 页面查询时维护他们所在的页面。通常,页面和数量变量保存在 Javascript 中,甚至像隐藏变量一样简单,可用于计算可用页面的数量等
这是一个 WebAPI 调用的基本示例,我使用它进行分页。如果 LINQ to SQL / EF 不支持它,您可能需要稍微修改它以支持获取所有记录和可能的任何 Oracle 特定内容:
public IActionResult GetProducts(int? page, int? count)
{
var takePage = page ?? 1;
var takeCount = count ?? DefaultPageRecordCount;
var calls = context.Products
.Skip((takePage - 1) * takeCount)
.Take(takeCount)
.ToList();
return Json(calls);
}
IQueryable<ShowMedicineViewModel> query;
List<ShowMedicineViewModel> medic = new List<ShowMedicineViewModel>();
var medicineInfo = _dbContext.medicine_details.Where(m => (m.Medicine_name.StartsWith(medicinename)) && (m.Medicine_type == medicinetype)).ToList();
List<string> TotalMedicine = new List<string>();
var results = (medicineInfo.OrderBy(x => x.id)
.Skip((pages - 1) * 2)
.Take(2));
Parallel.ForEach(results, item =>
{
var temp = Mapper.DynamicMap<medicine_details, ShowMedicineViewModel>(item);
medic.Add(temp);
});
Dictionary<string, int> dictionary2 = new Dictionary<string, int>();
dictionary2.Add("CurrentPage", pages);
dictionary2.Add("TotalPages", medicineInfo.Count() / 2 < 1 ? 1 : medicineInfo.Count());
Dictionary<string, object> dictionary = new Dictionary<string, object>();
dictionary.Add("Data", medic);
dictionary.Add("Page", dictionary2);
return dictionary;
我们创建了用于查询 Oracle 数据库的 WebAPI。查询 returns 结果很大,因此有时会抛出 OutOfMemoryException
.
建议使用 Paging 概念。我不明白客户端应用程序如何知道必须调用 API 多少次才能获得整组结果。我还需要为分页创建一个单独的 class 还是可以在我的 API 控制器中操作它。
任何人都可以帮助我,因为这是我的第一个 Web API。我们不能为此创建存储过程,因为我们只有对数据库的读取权限
public HttpResponseMessage Getdetails([FromUri] string[] id)
{
string connStr = ConfigurationManager.ConnectionStrings["ProDataConnection"].ConnectionString;
using (OracleConnection dbconn = new OracleConnection(connStr))
{
var inconditions = id.Distinct().ToArray();
var srtcon = string.Join(",", inconditions);
DataSet userDataset = new DataSet();
var strQuery = @"SELECT * from STCD_PRIO_CATEGORY where STPR_STUDY.STD_REF IN(" + srtcon + ")";
using (OracleCommand selectCommand = new OracleCommand(strQuery, dbconn))
{
using (OracleDataAdapter adapter = new OracleDataAdapter(selectCommand))
{
DataTable selectResults = new DataTable();
adapter.Fill(selectResults);
var returnObject = new { data = selectResults };
var response = Request.CreateResponse(HttpStatusCode.OK, returnObject, MediaTypeHeaderValue.Parse("application/json"));
ContentDispositionHeaderValue contentDisposition = null;
if (ContentDispositionHeaderValue.TryParse("inline; filename=ProvantisStudyData.json", out contentDisposition))
{
response.Content.Headers.ContentDisposition = contentDisposition;
}
return response;
}
}
}
}
通过 API 分页的总体思路是,客户端将传递他们想要的 "page" 数据和他们想要的 "amount" 记录。
从那里您可以构建您的查询,使其达到
的效果Select all records, but skip ((Page - 1) * amount) of records and take (amount) of records.
如果您使用 LINQ to SQL,有 Take() 和 Skip() 方法可以帮助您更轻松地在代码端编写代码。如果您不使用 LINQ to SQL,则需要查找特定于 Oracle 的内容。
最后请注意,由于一个好的 API 被设计为 "stateless",因此客户端需要在处理 previous/next 页面查询时维护他们所在的页面。通常,页面和数量变量保存在 Javascript 中,甚至像隐藏变量一样简单,可用于计算可用页面的数量等
这是一个 WebAPI 调用的基本示例,我使用它进行分页。如果 LINQ to SQL / EF 不支持它,您可能需要稍微修改它以支持获取所有记录和可能的任何 Oracle 特定内容:
public IActionResult GetProducts(int? page, int? count)
{
var takePage = page ?? 1;
var takeCount = count ?? DefaultPageRecordCount;
var calls = context.Products
.Skip((takePage - 1) * takeCount)
.Take(takeCount)
.ToList();
return Json(calls);
}
IQueryable<ShowMedicineViewModel> query;
List<ShowMedicineViewModel> medic = new List<ShowMedicineViewModel>();
var medicineInfo = _dbContext.medicine_details.Where(m => (m.Medicine_name.StartsWith(medicinename)) && (m.Medicine_type == medicinetype)).ToList();
List<string> TotalMedicine = new List<string>();
var results = (medicineInfo.OrderBy(x => x.id)
.Skip((pages - 1) * 2)
.Take(2));
Parallel.ForEach(results, item =>
{
var temp = Mapper.DynamicMap<medicine_details, ShowMedicineViewModel>(item);
medic.Add(temp);
});
Dictionary<string, int> dictionary2 = new Dictionary<string, int>();
dictionary2.Add("CurrentPage", pages);
dictionary2.Add("TotalPages", medicineInfo.Count() / 2 < 1 ? 1 : medicineInfo.Count());
Dictionary<string, object> dictionary = new Dictionary<string, object>();
dictionary.Add("Data", medic);
dictionary.Add("Page", dictionary2);
return dictionary;