c#

2024-04-10 00:50| 来源: 网络整理| 查看: 265

我想我为那些使用流行的免费软件代码类 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}”

我的 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; }

我希望这对某人有所帮助，很抱歉我第一次违反了博客规则。

【本文地址】

公司简介

联系我们