0
我正在通过C＃进行批量上传。C＃中的SQL Server批量上传没有错误，但没有插入数据
这不是一段复杂的代码，但尽管代码能够成功运行，但我苦苦挣扎当我对目标表运行查询时，数据库一端没有看到任何东西。
表是 [awsbillingdetailed_w_res_tags]
public static string BulkUpload(DataTable dt, string tableName, string connectionString)
{
string code = "";
//just resizing datatable so that it makes it smaller for testing. Only 5 rows.
dt = ReduceDataTableSize(dt, 5);
dt.TableName = tableName;
string constr = connectionString;
try
{
using (SqlConnection connection = new SqlConnection(constr))
{
connection.Open();
//CreatingTranscationsothatitcanrollbackifgotanyerrorwhileuploading
SqlTransaction trans = connection.BeginTransaction();
//Start bulkCopy
using (SqlBulkCopy bulkCopy = new SqlBulkCopy(connection,
SqlBulkCopyOptions.TableLock |
SqlBulkCopyOptions.FireTriggers,
trans))
{
//Fix up default values
if(dt.Rows.Count > 0)
{
for (int i = 0; i < dt.Rows.Count; i++)
{
dt.Rows[i]["InvoiceId"] = dt.Rows[i]["InvoiceId"].ToString().Replace("\"", "");
dt.Rows[i]["PayerAccountId"] = dt.Rows[i]["PayerAccountId"].ToString().Replace("\"", "");
dt.Rows[i]["LinkedAccountId"] = dt.Rows[i]["LinkedAccountId"].ToString().Replace("\"", "");
dt.Rows[i]["RecordType"] = dt.Rows[i]["RecordType"].ToString().Replace("\"", "");
dt.Rows[i]["ProductName"] = dt.Rows[i]["ProductName"].ToString().Replace("\"", "");
dt.Rows[i]["RateId"] = dt.Rows[i]["RateId"].ToString().Replace("\"", "");
dt.Rows[i]["SubscriptionId"] = dt.Rows[i]["SubscriptionId"].ToString().Replace("\"", "");
dt.Rows[i]["PricingplanId"] = dt.Rows[i]["PricingplanId"].ToString().Replace("\"", "");
dt.Rows[i]["UsageType"] = dt.Rows[i]["UsageType"].ToString().Replace("\"", "");
dt.Rows[i]["PricingplanId"] = dt.Rows[i]["PricingplanId"].ToString().Replace("\"", "");
dt.Rows[i]["Operation"] = dt.Rows[i]["Operation"].ToString().Replace("\"", "");
dt.Rows[i]["AvailabilityZone"] = dt.Rows[i]["AvailabilityZone"].ToString().Replace("\"", "");
dt.Rows[i]["ReservedInstance"] = dt.Rows[i]["ReservedInstance"].ToString().Replace("\"", "");
dt.Rows[i]["ItemDescription"] = dt.Rows[i]["ItemDescription"].ToString().Replace("\"", "");
dt.Rows[i]["ResourceId"] = dt.Rows[i]["ResourceId"].ToString().Replace("\"", "");
dt.Rows[i]["RecordId"] = dt.Rows[i]["RecordId"].ToString().Replace("\"", "");
dt.Rows[i]["UsageQuantity"] = dt.Rows[i]["UsageQuantity"].ToString().Replace("\"", "");
dt.Rows[i]["usagestartdate"] = dt.Rows[i]["usagestartdate"].ToString() == "" ? DateTime.Now.AddYears(-2014) : Convert.ToDateTime((dt.Rows[i]["usagestartdate"].ToString().Replace("\"", "")));
dt.Rows[i]["usageenddate"] = dt.Rows[i]["usageenddate"].ToString() == "" ? DateTime.Now.AddYears(-2014) : Convert.ToDateTime((dt.Rows[i]["usageenddate"].ToString().Replace("\"", "")));
dt.Rows[i]["UsageQuantity"] = dt.Rows[i]["UsageQuantity"].ToString().Replace("\"", "");
dt.Rows[i]["BlendedRate"] = dt.Rows[i]["BlendedRate"].ToString().Replace("\"", "");
dt.Rows[i]["BlendedCost"] = dt.Rows[i]["BlendedCost"].ToString().Replace("\"", "");
dt.Rows[i]["UnBlendedRate"] = dt.Rows[i]["UnBlendedRate"].ToString().Replace("\"", "");
dt.Rows[i]["UnBlendedCost"] = dt.Rows[i]["UnBlendedCost"].ToString().Replace("\"", "");
}
}
bulkCopy.DestinationTableName = tableName;
bulkCopy.ColumnMappings.Add("InvoiceId", "invoiceid");
bulkCopy.ColumnMappings.Add("PayerAccountId", "payeraccountid");
bulkCopy.ColumnMappings.Add("LinkedAccountId", "linkedaccountid");
bulkCopy.ColumnMappings.Add("RecordType", "recordtype");
bulkCopy.ColumnMappings.Add("ProductName", "productname");
bulkCopy.ColumnMappings.Add("RateId", "rateid");
bulkCopy.ColumnMappings.Add("SubscriptionId", "subscriptionid");
bulkCopy.ColumnMappings.Add("PricingplanId", "pricingplanid");
bulkCopy.ColumnMappings.Add("UsageType", "usagetype");
bulkCopy.ColumnMappings.Add("Operation", "operation");
bulkCopy.ColumnMappings.Add("AvailabilityZone", "availabilityzone");
bulkCopy.ColumnMappings.Add("ReservedInstance", "reservedinstance");
bulkCopy.ColumnMappings.Add("ItemDescription", "itemdescription");
bulkCopy.ColumnMappings.Add("UsageStartDate", "usagestartdate");
bulkCopy.ColumnMappings.Add("UsageEndDate", "usageenddate");
bulkCopy.ColumnMappings.Add("UsageQuantity", "usagequantity");
bulkCopy.ColumnMappings.Add("BlendedRate", "blendedrate");
bulkCopy.ColumnMappings.Add("BlendedCost", "blendedcost");
bulkCopy.ColumnMappings.Add("UnBlendedRate", "unblendedrate");
bulkCopy.ColumnMappings.Add("UnBlendedCost", "unblendedcost");
bulkCopy.ColumnMappings.Add("resourceid", "resourceid");
//write the data in the "dataTable"
bulkCopy.WriteToServer(dt);
code = "Data Processed Successfully";
}
}
return code;
}
catch (Exception ex)
{
code = "Error while processing file";
System.Diagnostics.Debug.Write("EXCEPTION BulkUpload: " + ex.ToString());
}
return code;
}
我也双重检查，以确保没有双引号或任何空白字段现在。
我没有得到任何错误，但没有任何实际进入数据库。任何想法为什么？尝试调试了几个小时，但看不到任何问题。阅读大量的论坛，但没有带领我去哪里。非常感谢您的帮助。
在此先感谢。
你没有提交你的交易。请查看“使用现有的tranactions”部分@ http://msdn.microsoft.com/en-us/library/tchktcdk%28v=vs.110%29.aspx – dugas