Skip to content

Retrieve non flushed event count in sqlite db at start #85

@cbeaujoin-stellar

Description

@cbeaujoin-stellar
  def _setup_database(self):
        if self._database_path:
           ...
            self._non_flushed_event_count = self._database.get_non_flushed_event_count()
    def get_non_flushed_event_count(self):
        query_fetch = '''SELECT count(*) FROM `event` WHERE `pending_delete` = 0;'''
        with self._connect() as connection:
            cursor = connection.cursor()
            cursor.execute(query_fetch)
            count = cursor.fetchone()[0]
        return count

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions