Блог

Я пишу приложение, которое опрашивает postgresql DB для проверки новых строк, вставленных другим приложением. Большую часть времени все работает, но время от времени что-то «зависает». Даже если в базе данных существует более новая запись, приложение считывает вторую последнюю строку.

Опрос осуществляется следующим кодом

 private async Task<ResultRow> RetreiveLastRow() {
    ResultRow row = null;

    var connectionString = "server=<ip>;user id=<user>;password=<pass>;database=<db name>";
    using (var connection = new NpgsqlConnection(connectionString))
    using (var command = connection.CreateCommand()) {
        await connection.OpenAsync();
        command.CommandText = "SELECT <fields> FROM <table> ORDER BY <field> DESC LIMIT 1";
        using (var reader = await command.ExecuteReaderAsync()) {
            if (await reader.ReadAsync()) {
                row = <read row>;
            }
        }

        connection.Close();
    }

    return row;
}
  

Метод, описанный выше, вызывается в цикле каждые ~ 100 мс.

 while (!cancellationToken.IsCancellationRequested) {
    try {
        var lastRow = await RetreiveLastRow();

        Logger.Trace($"Last row id = {lastRow.Id}");
        // rest of code...
    } catch (Exception e) {
        Logger.Error(e, "Error");
    }

    await Task.Delay(TimeSpan.FromMilliseconds(100));
}
  

Я точно знаю, что в базе данных есть более новая запись. Я вижу это с помощью pgAdmin, но мое приложение не видит того, что я вижу.

Все возвращается в нормальное русло, когда в таблицу добавляется еще одна строка — приложение видит самые новые данные (за некоторое время). Через некоторое время, когда в таблицу добавляются новые записи, проблема появляется снова.

Я подозреваю, что результат запроса кэшируется драйвером и не обновляется из базы данных. Поэтому я попытался отключить опрос соединения, добавив «polling = false» в строку подключения (что должно отключить кэширование, если оно есть). Кажется, это решает проблему, но я не совсем уверен.

Действительно ли это проблема с кэшированием? Если это так, можно ли это решить, не отключая опрос соединения?