2

我正在使用该Microsoft.Data.OData库,基本上想构建一个程序,该程序DataTable从 OData 查询中获取一个,从中构建一个数据库,然后插入记录。

由于这需要是动态的,因此服务引用对我不起作用。

在 MSDN 上搜索和筛选文档两个小时后,我还没有找到解决问题的方法。

到目前为止,我的代码如下,我只需要知道是否有人从 anHttpWebRequest到 anODataReader或任何相关类,这将使我无需编写自己的解析器即可读取查询结果,以及他们是如何做到的。

public class ODataPuller
{
    private readonly Uri uri;

    public ODataPuller(Uri uri)
    {
        this.uri = uri;
    }

    private async Task<HttpWebResponse> MakeRequestAsync(string filter)
    {
        filter = "?$filter=" + filter;
        Uri target = new Uri(this.uri, filter);

        HttpWebRequest request = HttpWebRequest.CreateHttp(target);
        request.Headers["Accept"] = "application/xml";

        HttpWebResponse response = await request.GetResponseAsync() as HttpWebResponse;
        return response;
    }

    public async Task<DataTable> GetDataTableAsync(string filter)
    {
        HttpWebResponse response = await this.MakeRequestAsync(filter);

        Stream stream = response.GetResponseStream();

        // Turn this stream into something nice
    }
}
4

1 回答 1

4

使用 ODataLib 时,需要自己实现一个消息接口(其中一个消息代表一个 HTTP 消息:stream & headers)。在读取响应时,您需要实现 IODataResponseMessage,而在编写请求时,您需要实现 IODataRequestMessage。

我们有一些 HttpWebRequest 和 HttpWebResponse 的示例消息实现,您可以在此处使用。(我认为这些可能存在一些编译问题,但它们不应该太难修复)

完成消息实现后,您将把它传递给 ODataMessageReader 或 ODataMessageWriter 构造函数。例如,

using (var messageReader = new ODataMessageReader(responseMessage, readerSettings, model))
{
   var feedReader = messageReader.CreateODataFeedReader(entityType, entitySet);
   while (feedReader.Read())
   {
       switch(feedReader.State)
       {
          case ODataReaderState.EntryEnd:
          {
             ODataEntry entry = (ODataEntry) feedReader.Item;
             // access entry.Properties, etc.
             break;
          }
       }
   }
}

有关使用该库的文档,您可以查看此使用该库的摘要 以及我的 ODataLib 博客:http ://odata.jenspinney.com

于 2013-11-01T01:35:00.930 回答