我想我为那些使用流行的免费软件代码类 BulkDataReader 的人找到了答案。我有同样的问题,我试图在不久前发布这个,但是因为我问了另一个问题并且没有提供答案,所以帖子被删除了。没关系,我没有意识到这是违反规则的。
这一次,我得到了答案,所以希望这篇文章能留在这里。我将保留我的问题的设置部分,以便它定义明确,并且没有人对为什么解决方案不适合他们感到困惑。我从一位同事那里获得了 BulkDataReader 类的代码,看来他可能是从另一个著名的答案来源获得的,所以每个人都会知道如何从搜索引擎中找到 BuldDataReader。
这个问题是这样设置的:
我也尝试了 CSV 文件中 GUIDS 的各种格式,包括:N'3192E434-F479-4B32-B516-AC658F4B7B89' {3192E434-F479-4B32-B516-AC658F4B7B89} (3192E434-F479-4B32-B516-AC658F4B7B7B89} ) “{3192E434-F479-4B32-B516-AC658F4B7B89}”</p>
我的 CSV 中的真实示例行是:1,AAPL,452.2012,2013-01-24 13:24:27.000,3192E434-F479-4B32-B516-AC658F4B7B89,3192E434-F479-4B32-B516-AC658F4B7B89
如果我删除 2 Guids 并导入没有这些列的表,它工作正常。使用 Guids to Unique Identifier 列我收到此错误:Message = {“来自数据源的 String 类型的给定值无法转换为指定目标列的类型唯一标识符。”}
我的控制代码非常基本,但 BulkDataReader 非常麻烦,因此如果您尝试调试它,请做好准备。
using (IDataReader reader = new BulkDataReader(new StreamReader("C:\\test.csv"), false))
{
String connectionStr = GetConnString();
SqlConnection connection = new SqlConnection(connectionStr);
connection.Open();
SqlTransaction transaction = connection.BeginTransaction();
try
{
SqlBulkCopy copy = new SqlBulkCopy(connection, SqlBulkCopyOptions.TableLock, transaction);
copy.DestinationTableName = "TestTable6";
copy.WriteToServer(reader); //ERROR OCCURS HERE: The given value of type String from the data source cannot be converted to type uniqueidentifier of the specified target column
transaction.Commit();
}
catch (Exception exe)
{
transaction.Rollback();
}
finally
{
connection.Close();
}
}
所以错误实际上发生在 .NET SqlBulkCopy 类中。但是,它发生在 BulkDataReader 读取 Guid 值之后。该 GetValue 方法是从外部代码调用的,这意味着它隐藏在 BulkDataReader 的 streamReader 和 SqlBulkCopy 类中的 StreamWriting 内容之间的管道中。没有必要使用我最喜欢的反射实用程序深入研究所有内容。我发现当 BulkDataReader 的方法 IDataRecord.GetValue(int i) 返回一个真正是 Guid 的字符串时,SqlBulkCopy 无法将该字符串转换为唯一标识符,无论它采用什么格式。可能有一些晦涩的编码格式,但我可以找不到一个可以工作的。但是,如果我只是将值作为正确的 System.Guid 类型返回,那么 SqlBulkCopy 会将其转换为唯一标识符就好了。因此,一个似乎是噩梦般的序列化问题的简单解决方案。只需复制整个 IDataRecord.GetValue(int i) 方法,它应该可以工作。我尝试了许多从 CLR 到 SQL 的数据类型,但不是全部,所以可能还有另一个你必须玩这个反序列化游戏的地方,但这应该在很大程度上解决了这个问题。
object IDataRecord.GetValue(int i)
{
ValidateDataReader(DataReaderValidations.IsInitialized | DataReaderValidations.IsNotClosed);
if (((IDataRecord)this).IsDBNull(i))
return DBNull.Value;
else
{
//For some reason the SqlBulkCopy.WriteToServer method will call this GetValue method when reading
//the value and it doesn't seem to know how to convert the string value of a Guid to a unique identifier.
//However, it does actually know how to convert a System.Guid to a UniqueIdentifer so we can return that if
//the value parses to Guid
if (IsGuid(this[i]))
return Guid.Parse(this[i]);
else
return this[i];
}
}
bool IsGuid(object value)
{
if (value != null)
{
Guid testGuid = Guid.Empty;
if (Guid.TryParse(value.ToString(), out testGuid))
return true;
}
return false;
}
我希望这对某人有所帮助,很抱歉我第一次违反了博客规则。