我正在使用这个库:
将来自 xml 解析的一些 linq 查询结果放入带有 sqlbulkcopy 的数据库中,该数据库使用数据读取器直接放置数据,而不使用数据表或此类数据结构。
我无法实现它。
这是我到目前为止写的没有任何成功的代码:
XDocument xdoc = XDocument.Parse(str_XmlToParse);
//ORDINI
IEnumerable<XDocument> xdod;
var orders = from c in xdoc.Descendants("ordersdata").AsEnumerable().Descendants("order").AsEnumerable()
select new
{
Client_ID = (string)c.Element("Client").Element("ID"),
Doc_ID = (string)c.Element("ord_ID"),
Doc_data = (DateTime)c.Element("ord_datetime"),
};
IDataReader dr = orders.AsDataReader();
using (SqlConnection con = new SqlConnection(connectionString))
{
con.Open();
using (SqlTransaction tran = con.BeginTransaction())
{
var newOrders =
from i in Enumerable.Range(0, totalToSend)
select new Order
{
customer_name = "Customer " + i % 100,
quantity = i % 9,
order_id = i,
order_entry_date = DateTime.Now
};
SqlBulkCopy bc = new SqlBulkCopy(con,
SqlBulkCopyOptions.CheckConstraints |
SqlBulkCopyOptions.FireTriggers |
SqlBulkCopyOptions.KeepNulls, tran);
bc.BatchSize = 1000;
bc.DestinationTableName = "order_queue";
bc.WriteToServer(newOrders.AsDataReader());
tran.Commit();
}
con.Close();
这主要是该库示例中内容的副本。
我什至无法正确理解他们所有奇怪的铸件发生了什么,但我需要它来工作。(相信我,我试图理解)
我不断收到此错误:
错误 1“System.Collections.Generic.IEnumerable AnonymousType#1>”不包含“AsDataReader”的定义,并且没有扩展方法“AsDataReader”接受“System.Collections.Generic.IEnumerable AnonymousType#1>”类型的第一个参数可以找到(您是否缺少 using 指令或程序集引用?)
它是什么?我如何解决它?
谢谢