EM2MySQL.py

import urllib
import requests
from bs4 import BeautifulSoup
import re
import urllib2
import MySQLdb as mdb
import simplejson as json
import getpass
import time

red = "\033[0;31m{0}\033[00m"
grn = "\033[0;32m{0}\033[00m"

def logo():
	print "\n####################################"
	print "#  [2014] EM2MySQL - by: DanyTamy  #"
        print "####################################\n"
        
def emailmanager():
	logo()
	ook = grn.format('[+]')	
	print "\n============[ Dados Email Manager - API ]============="	
	print ">> Informe o metodo, dominio, usuario e senha do Email Manager."
	time.sleep(1)
	print ">> Ex. de metodos: contacts, campaigns, reportBlacklist, e outros. Veja mais em: http://api.emailmanager.com/1.0.html.\n"
	time.sleep(1)
	metodo = raw_input('[!] Metodo: ')       
	domain = raw_input('[!] Dominio: ')
	username = raw_input('[!] Usuario: ')
	password = getpass.getpass()	
	conectar = urllib.urlencode({'method': 'authentLogin', 'domain': domain, 'username': username , 'password': password})    	
        furl = "http://api.emailmanager.com/1.0/?"+conectar        
        r = requests.get(furl)
        soup = BeautifulSoup(r.text)
        for k in soup.findAll('apikey'):	    
	    regex = re.compile(r'<[^<]*?>')
	    k = regex.sub('', str(k))
	    key = k
	    print ook+" key: ",key+"\n\n"	    
    
        val = urllib.urlencode({'apikey': key, 'method': metodo, 'output': 'json'})
        furl = "http://api.emailmanager.com/1.0/?"+val
        o = urllib2.urlopen(furl)
        j = o.read()	       
	json.dumps(j, sort_keys=False)	
	dic = json.loads(j)		
	vv = []    
        	
	for values in dic:
	    valores = values.values()	    	    
	    valores = tuple('-' if x == '' else x for x in valores)	     
	    nvalores = tuple('-' if x == None else x for x in valores)	
	    vv.append(nvalores)
        
	tags = tuple('-' if x == '' else x for x in values)		
	a = []

	print "============[ Banco de Dados - MySQL ]============"	
        print ">> Informe o nome do banco de dados, tabela [a serem criados] e senha do usuario root do MySQL.\n"	
	db_name = raw_input("[!] Banco de Dados: ")
	table_name = raw_input("[!] Tabela: ")
	db_password = getpass.getpass()

	query1 = "CREATE TABLE "+db_name+"( "
	query2 = ")"
	sql = ''
	sqli = ''
	for t in tags:
	    sql = sql +t+" VARCHAR(300),"
	    sqli = sqli+t+", "
	    query=query1+sql+query2
	    q=query.replace(",)", ");")	
	
	sqli = sqli[0:len(sqli)-2]
		
	db = mdb.connect(host="localhost",user="root",passwd=db_password)
	db1 = db.cursor()
	sql_create = "CREATE DATABASE "+db_name
	sql_use = "USE "+db_name
	sql_ct = q	
	db1.execute(sql_create)
	db1.execute(sql_use)
	db1.execute(sql_ct)	
	print "\n",ook,"Banco de dados: "+db_name+" criado com sucesso.\n"        
	print ook,"Tabela: "+table_name+" criado com sucesso.\n"
	db1.close()
	
	
	for v in vv:
	    sqli2 = "INSERT INTO "+table_name+" ("+sqli+") VALUES"+str(v)
	    a.append(sqli2)
	
	con = mdb.connect('localhost', 'root', db_password, db_name)   	
	with con:
	    cur = con.cursor()           	    		    	    
	    sqli3 = a
	    print ">> inserindo dados na tabela "+table_name+"...\n"
	    for s in sqli3:		
	        cur.execute(s)
	        con.commit()
	print ook+" dados inseridos com sucesso. ;)\n"
	cur.fetchall()	
	con.close()  	   
	   
emailmanager()