from models import *

from utils import *

from optparse import OptionParser

from sqlalchemy.orm import sessionmaker

import logging

import sqlite3

import sys

#    'entities': "tweet_entity",     

#    'user': "tweet_user"

def get_option():

    parser = OptionParser()

    return parser.parse_args()

if __name__ == "__main__":

    (options, args) = get_option()

    with sqlite3.connect(args[0]) as conn_in:

        Session = sessionmaker(bind=engine)

        session = Session()

        try:

            curs_in = conn_in.cursor()

            fields_mapping = {}

            for i,res in enumerate(curs_in.execute("select json from tweet_tweet;")):

                logging.debug("main loop %d : %s" % (i, res[0]))

                session.commit()

            logging.debug("main : %d tweet processed" % (i+1))

        except Exception, e:

            session.rollback()

            raise e

        finally:

            session.close()