2

我已经创建并使用了很多次连接值的 SQL CLR 聚合 - 它还按指定的数字对值进行排序，并使用用户输入分隔符来连接它们。

我在大量数据上使用了相同的聚合，并注意到没有使用分隔符 - 值是连接的，但没有分隔符。

经过大量测试，我发现在Terminate方法中，分隔符丢失/未读取。我使用硬编码分隔符仔细检查了这一点 - 一切正常。

我猜我的ReadandWrite方法有问题（在处理大量数据时使用）但无法理解是什么。

这是功能代码：

[Serializable]
[
    Microsoft.SqlServer.Server.SqlUserDefinedAggregate
    (
        Microsoft.SqlServer.Server.Format.UserDefined,
        IsInvariantToNulls = true,
        IsInvariantToDuplicates = false,
        IsInvariantToOrder = false,
        IsNullIfEmpty = false,
        MaxByteSize = -1
    )
]
/// <summary>
/// Concatenates <int, string, string> values defining order using the specified number and using the given delimiter
/// </summary>
public class ConcatenateWithOrderAndDelimiter : Microsoft.SqlServer.Server.IBinarySerialize
{
    private List<Tuple<int, string>> intermediateResult;
    private string delimiter;
    private bool isDelimiterNotDefined;

    public void Init()
    {
        this.delimiter = ",";
        this.isDelimiterNotDefined = true;
        this.intermediateResult = new List<Tuple<int, string>>();
    }

    public void Accumulate(SqlInt32 position, SqlString text, SqlString delimiter)
    {
        if (this.isDelimiterNotDefined)
        {
            this.delimiter = delimiter.IsNull ? "," : delimiter.Value;
            this.isDelimiterNotDefined = false;
        }

        if (!(position.IsNull || text.IsNull))
        {
            this.intermediateResult.Add(new Tuple<int, string>(position.Value, text.Value));
        }
    }

    public void Merge(ConcatenateWithOrderAndDelimiter other)
    {
        this.intermediateResult.AddRange(other.intermediateResult);
    }

    public SqlString Terminate()
    {
        this.intermediateResult.Sort();
        return new SqlString(String.Join(this.delimiter, this.intermediateResult.Select(tuple => tuple.Item2)));
    }

    public void Read(BinaryReader r)
    {
        if (r == null) throw new ArgumentNullException("r");

        int count = r.ReadInt32();
        this.intermediateResult = new List<Tuple<int, string>>(count);

        for (int i = 0; i < count; i++)
        {
            this.intermediateResult.Add(new Tuple<int, string>(r.ReadInt32(), r.ReadString()));
        }

        this.delimiter = r.ReadString();
    }

    public void Write(BinaryWriter w)
    {
        if (w == null) throw new ArgumentNullException("w");

        w.Write(this.intermediateResult.Count);

        foreach (Tuple<int, string> record in this.intermediateResult)
        {
            w.Write(record.Item1);
            w.Write(record.Item2);
        }

        w.Write(this.delimiter);
    }
}
4

2 回答 2

1

我发现了这个问题。它在Merge方法中。它是：

public void Merge(ConcatenateWithOrderAndDelimiter other)
{
    this.intermediateResult.AddRange(other.intermediateResult);
}

我将其更改为：

public void Merge(ConcatenateWithOrderAndDelimiter other)
{
    this.intermediateResult.AddRange(other.intermediateResult);
    this.delimiter = other.delimiter;
}

似乎当 data 为 时merge，分隔符未初始化。我想在上面的上下文中，所有this属性都是空的。

无论如何，我不会接受这个作为答案，因为如果有人能够解释内部发生的事情将会很有帮助。

于 2018-08-22T10:05:27.067 回答
1

Merge()仅当使用并行性并且特定组分布在超过 1 个线程上时才调用该方法。在这种情况下，Init()已经调用了 0 个或多个Accumulate().

因此，在并行的情况下，如果Init()已调用但尚未调用 no Accumulate()，则 in 的值delimiter将是Init()方法中设置的值。问题中的代码显示它被设置为,，但我怀疑这是后来在试图解决这个问题时添加的。当然，这假定将逗号作为分隔符传入Accumulate(). 或者，也许逗号总是被设置为默认值Init()，但是另一个字符通过传入，Accumulate()并且没有通过最终输出（问题中没有显示对 UDA 的特定调用，也没有显示不正确的输出，所以这里有一些歧义）。

虽然另一个答案中显示的修复似乎有效，但它不是一个通用修复，因为可能存在当前对象Accumulate()至少调用过一次的情况，但被合并到这个对象中的“其他”对象仍然是空的（可能没有匹配的行，或者在调用时值未在本地存储的其他原因Accumulate()）。在这种情况下，当前对象将具有所需的分隔符，但“其他”对象仍将具有默认值。理想的解决方案是将 的值也存储在方法中，isDelimiterNotDefined在Write()方法中再次将其取回Read()，并将本地值与other.isDelimiterNotDefined方法中的值进行比较，Merge()以便您可以确定是否应该保留本地值或其他值delimiter（取决于在其上设置/定义）。

于 2018-09-19T19:48:30.617 回答