import os
from settings import SQLURI
from sqlalchemy import *

sql_db = create_engine(SQLURI, convert_unicode=True)
metadata = BoundMetaData(sql_db)


index_data = Table('xap_index_data', metadata,
                   Column('docid', String(10)),
                   Column('language_iso', String(2)),
                   Column('data', TEXT()))

try:
    index_data.create()
except exceptions.SQLError:
    # already exists
    pass

remove_data = Table('xap_remove_data', metadata,
                   Column('docid', String(10)),)

try:
    remove_data.create()
except exceptions.SQLError:
    # already exists
    pass

statistics = Table('xap_statistics', metadata,
                   Column('query', String(200)),
                   Column('count', Integer))

try:
    statistics.create()
except exceptions.SQLError:
    # already exists
    pass