flagged_lib.py

 # -*- coding: utf-8  -*-

import time
import datetime 
import create_flagged_data
from general_lib import database_name as myDB

def create_lagging_user(db):
    """This functions creates a table with users sorted by unflagged changes.
    
    It will populate replag_users
    """
    cursor = db.cursor()
    now = datetime.datetime.now()
    timestamp = time.mktime(now.timetuple())
    #
    cursor.execute('drop table if exists %s.replag_users ' % myDB)
    query = """
    create table %s.replag_users as 
    select count(*), fp_page_id, fp_stable, rev_id, rev_user,
    rev_user_text, rev_timestamp, %s as updated_at
    from dewiki_p.flaggedpages fp 
    inner join dewiki_p.revision r on fp.fp_page_id = r.rev_page 
    #inner join dewiki_p.page p on p.page_id = fp.fp_page_id
    where fp_reviewed=0 and r.rev_id > fp.fp_stable group by fp_page_id, rev_user_text
    %s
    """ %  (myDB, int(timestamp) , create_flagged_data.slow_ok_text[True])
    #
    #f = open('tmp_mysql.query', 'w'); f.write( query ); f.close()
    cursor.execute( query )
    cursor.execute( 'commit;' )


def create_never_reviewed(db):
    cursor = db.cursor()
    now = datetime.datetime.now()
    timestamp = time.mktime(now.timetuple())
    #
    cursor.execute('drop table if exists %s.never_review ' % myDB )
    query = """
    create table %s.never_review as 
    select page_title, page_id, rev_user, rev_timestamp,
    %s as updated_at 
    from dewiki_p.page  p
    inner join dewiki_p.revision r on r.rev_page = p.page_id
    #not flagged
    where page_id not in (select distinct fp_page_id from dewiki_p.flaggedpages)
    #not a redirect
    and page_is_redirect = 0
    #and page_id not in (select distinct rd_from from dewiki_p.redirect)
    #and in article namespace
    and page_namespace = 0
    group by page_id
    order by page_id, rev_timestamp DESC
    %s
    """ %  (myDB, int(timestamp) , create_flagged_data.slow_ok_text[True])
    #
    #f = open('tmp_mysql.query', 'w'); f.write( query ); f.close()
    cursor.execute( query )
    cursor.execute( 'commit;' )