Function create_database

instapy/database_engine.py:72–103

(address, logger, name)

def create_database(address, logger, name):
    try:
        connection = sqlite3.connect(address)
        with connection:
            connection.row_factory = sqlite3.Row
            cursor = connection.cursor()

            create_tables(
                cursor,
                [
                    "profiles",
                    "recordActivity",
                    "followRestriction",
                    "shareWithPodsRestriction",
                    "commentRestriction",
                    "accountsProgress",
                ],
            )

            connection.commit()

    except Exception as exc:
        logger.warning(
            "Wah! Error occurred while getting a DB for '{}':\n\t{}".format(
                name, str(exc).encode("utf-8")
            )
        )

    finally:
        if connection:
            # close the open connection
            connection.close()


def create_tables(cursor, tables):