#!/usr/bin/env python
#coding: utf8

emergencyContact = 'mpeterson@e-gate.com.ar'

dbInfoSrc = {
#  "host" : "200.69.211.26",
  "host" : "10.30.1.80",
  "user" : "repl_destec",
  "passwd" : "rdd2005",
  "db" : "repl_destec"
}

dbInfoDest = {
  "host" : "127.0.0.1",
  "user" : "icv",
  "passwd" : "icv1234",
  "db" : "ICV"
}

try:
  import MySQLdb as DataBase
except ImportError, e:
  errorMsg = """Make sure MySQL-Python is properly installed. Get it at: http://sourceforge.net/projects/mysql-python"""
  print >>sys.stderr, errorMsg
  sys.exit(1)

import sys
import _mysql_exceptions

if __name__ == "__main__":
  dbSrc = DataBase.connect(host=dbInfoSrc["host"], user=dbInfoSrc["user"], passwd=dbInfoSrc["passwd"], db=dbInfoSrc["db"], port=3307)
  dbSrc.autocommit(True)
  dbDest = DataBase.connect(host=dbInfoDest["host"], user=dbInfoDest["user"], passwd=dbInfoDest["passwd"], db=dbInfoDest["db"])
  dbDest.autocommit(True)
  print >>sys.stderr,"conectado a las DB"

  cursorSrc = dbSrc.cursor()
  cursorDest = dbDest.cursor()

  print >>sys.stderr,"ejecutando query en TENFOLD"
  cursorSrc.execute("SELECT numero_cliente, cliente, na.numero, estado_subscripcion, product_offering FROM subscripciones_site ss JOIN numeros_asignacion na ON ss.codigo_subscripcion = na.codigo_subscripcion WHERE tipo_numero='TELEPHONY'")
  print >>sys.stderr,"query completa, comenzando inserciones"

  while(1):
    row = cursorSrc.fetchone()

    if not row: break

    cursorDest.execute("CALL fu_add_data_tenfold(%s,%s,%s,%s,%s)",
        (row[0], row[1], row[2], row[3], row[4])
    )