Обновление Cassandra со счетчиками в C #

Я хочу увеличить использование таблицы с помощью счетчиков. Итак, я получил следующую таблицу:

create table counterInt (MeterID int, DayStamp timestamp, NumberOf public void insertBasic ( List < CSVMeter > meterList ) { try { Connect (); инструкция var = session . Подготовить ( "Update counterInt SET NumberOfValues ??= NumberOfValues ??+?, Value1 = Value1 +? , Value2 = Value2 +?, QualityScore = QualityScore +?, ID, DayStamp,) VALUES (?,?,?,?,?,?) " ); var tasks = new List < Task > (); foreach ( CSVMeter метр в meterList ) { var bind = statement . Bind ( метр . NumberOfValues , метр . Значение , метр . Значение2 , метр . QualityScore , метр . MeterID , метр . PeriodStart ); var resultSetFuture = сеанс . ExecuteAsync ( bind ); задач . Добавить ( resultSetFuture ); } Задача . WaitAll ( задачи . ToArray ()); CloseConnection (); } catch ( Exception ex ) { throw ex ; } } счетчик, счетчик Value1, счетчик Value2, счетчик качестваScore, PRIMARY KEY ((MeterID), DayStamp))

Также у меня есть список объектов, и я заполняю список объектов и прокручиваю его

    public CSVMeter(int meterID, DateTime periodStart, double value, double value2, int numberOfValues, double qualityScore)
    {//getters setters that kind of stuff nothing weird}

это мой объект в C #

UPDATE

Почему я могу получить следующую ошибку и как ее решить? Кроме того, могу ли я использовать подготовленные заявления, подобные этому в этом примере?

Необработанное исключение типа Cassandra.SyntaxError произошло в counterTest.exe. Дополнительная информация: строка 1: 136 нет жизнеспособной альтернативы на входе ',' (... = QualityScore +?, ID [,] ...)

Также побочный вопрос: возможно ли увеличение с удвоением вместо целого?

c#,cassandra,

0

Ответов: 1


1 принят

Поскольку сообщение об ошибке сообщает вам: у вас есть синтаксическая ошибка в вашей команде cql.

Для WHEREкоманды вы должны использовать VALUEпредложение, и вы не должны использовать VALUEпредложение.

Внимательно следите за своим запросом, похоже, вы объединили команду INSERTи UPDATEкоманду.

C #, Cassandra,