Problema de cache de instrução preparado no driver Cassandra Csharp
Acredito que encontrei um bug com a lógica de como uma instrução preparada é armazenada em cache no StatementFactory no driver Cassandra csharp (versão 2.7.3). Aqui está o caso de uso.
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));
Descobrimos que, após executar essas exclusões, apenas a primeira solicitação é bem-sucedida. Depois de mergulhar no código fonte deStatementFactory
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;
});
}
Você pode ver que o cache usa apenas a instrução cql. No nosso caso, temos os mesmos nomes de tabela em diferentes espaços de teclas (também conhecidos como sessões). Nossa instrução cql em ambas as consultas tem a mesma aparência. ieEXCLUIR DE foo_bar WHERE id =?.
Se eu tivesse que adivinhar, diria que uma correção simples seria combinar a instrução cql e o espaço de chaves como a chave do cache.
Alguém já encontrou esse problema antes?