'Initializes the database. If the database doesn\'t exist, we create a new one. Otherwise, we check the
version and upgrade to the latest version.'

@blocking_call_on_reactor_thread
def initialize(self):

    self._open_connection()
