Ich glaube, ich habe einen Fehler mit der Logik gefunden, wie eine vorbereitete Anweisung in der StatementFactory im csharp-Treiber von Cassandra (Version 2.7.3) zwischengespeichert wird. Hier ist der Anwendungsfall.

Guid key = Guid.NewGuid(); // your key

ISession session_foo = new Session("foo"); //This is pseudo code
ISession session_bar = new Session("bar");

var foo_mapper = new Mapper(session_foo); //table foo_bar
var bar_mapper = new Mapper(session_bar); //table foo_bar

await Task.WhenAll(
   foo_mapper.DeleteAsync<Foo>("WHERE id = ?", key),
   bar_mapper.DeleteAsync<Bar>("WHERE id = ?", key));

Wir haben festgestellt, dass nach dem Ausführen dieses Löschvorgangs nur die erste Anforderung erfolgreich ist. Nach dem Tauchen im Quellcode von StatementFactory

public Task<Statement> GetStatementAsync(ISession session, Cql cql)
    {
        if (cql.QueryOptions.NoPrepare)
        {
            // Use a SimpleStatement if we're not supposed to prepare
            Statement statement = new SimpleStatement(cql.Statement, cql.Arguments);
            SetStatementProperties(statement, cql);
            return TaskHelper.ToTask(statement);
        }
        return _statementCache
            .GetOrAdd(cql.Statement, session.PrepareAsync)
            .Continue(t =>
            {
                if (_statementCache.Count > MaxPreparedStatementsThreshold)
                {
                    Logger.Warning(String.Format("The prepared statement cache contains {0} queries. Use parameter markers for queries. You can configure this warning threshold using MappingConfiguration.SetMaxStatementPreparedThreshold() method.", _statementCache.Count));
                }
                Statement boundStatement = t.Result.Bind(cql.Arguments);
                SetStatementProperties(boundStatement, cql);
                return boundStatement;
            });
    }

Sie können sehen, dass der Cache nur die cql-Anweisung verwendet. In unserem Fall haben wir die gleichen Tabellennamen in verschiedenen Schlüsselbereichen (aka Sitzungen). Unsere cql-Anweisung in beiden Abfragen sieht gleich aus. dhDELETE FROM foo_bar WHERE id =?.

Wenn ich raten müsste, würde ich sagen, dass eine einfache Lösung darin besteht, die cql-Anweisung und den Schlüsselbereich zusammen als Cache-Schlüssel zu kombinieren.

Hat noch jemand auf dieses Problem gestoßen?