def METHOD_NAME(self, logdir):
    self.journal_path = os.path.join(logdir, JOURNAL_FILENAME)
    self.journal = sqlite3.connect(self.journal_path)
    self.journal_cursor = self.journal.cursor()
    for table in SCHEMA:  # pylint: disable=C0206
        res = self.journal_cursor.execute(f"PRAGMA table_info('{table}')")
        if res.fetchone() is None:
            self.journal_cursor.execute(SCHEMA[table])
    self.journal.commit()