import sqlite3

db = sqlite3.connect('db.sqlite')


def create_db():
    db.execute('''
        CREATE TABLE TOPICS(
                ID INT PRIMARY KEY NOT NULL,
                URL VARCHAR NOT NULL,
                AUTHOR VARCHAR NOT NULL,
                MESSAGE VARCHAR NOT NULL
            );
        ''')


def insert_db(_id, url, author, message):
    db.execute("INSERT INTO TOPICS (ID, URL, AUTHOR, MESSAGE) VALUES ({}, {}, {}, {})".format(_id, url, author, message))
    db.commit()


def get_db(_id):
    cursor = db.execute("SELECT ID, URL, AUTHOR, MESSAGE FROM TOPICS WHERE ID = {}".format(_id))
    return cursor.fetchone()


if __name__ == '__main__':
    create_db()
    insert_db(12, 'abc.com', 'a', 'b')
    get_db(12)
    db.close()