#!/usr/bin/python

import sys
import MySQLdb
from email.parser import Parser

DB_HOST = 'derp.com'
DB_USER = 'derp_user'
DB_PASS = 'derpish'
DB_NAME = 'some_db_name'

def db_insert(*args):
    try:
        con = MySQLdb.connect(host=DB_HOST, user=DB_USER, passwd=DB_PASS, db=DB_NAME)
        cur = con.cursor()
    except Exception, e:
        print "Error connection to the DB: %s" % e
        sys.exit(1)

    query = "INSERT INTO `table` (from, to, subject, body) VALUES(%s, %s, %s, %s)"
    cur.execute(query % args)

def parse_headers(msg):
    msg = msg.replace('\\r\\n', '\r\n')
    try:
        msg_obj = Parser().parsestr(msg)
        to = msg_obj['To']
        frm = msg_obj['From']
        subject = msg_obj['Subject']
        body = msg_obj.get_payload()
    except Exception, e:
        print "Error parsing email: %s" % e
        sys.exit(1)

    db_insert(to, frm, subject, body)

if __name__ == '__main__':
    f = sys.stdin
    if f:
        parse_headers(f.read())