# -*- coding: utf8 -*-
from sqlalchemy import text
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import (
    scoped_session,
    sessionmaker,
)
from zope.sqlalchemy import (
    ZopeTransactionExtension, 
    mark_changed
)

from datetime import *
import dateutil.relativedelta
import transaction

def execute_query(request, query, params):
    """Execute query and mark session as changed"""
    request.dbsession.execute(query, params)
    mark_changed(request.dbsession)
    transaction.commit()

def get_log_nuit(request, ):
    # lire le log de nuit
    query = """SELECT * FROM t_log_nuit;"""
    results = request.dbsession.execute(query, )
    return results.fetchall()

def get_last_emailing(request):
    """Lire les 200 derniers envois d'emails"""
    query = "SELECT * FROM email_rappels ORDER BY no_id DESC LIMIT 400;"
    results = request.dbsession.execute(query, {})
    return results.fetchall()