import logging
import logging.config
import subprocess
import mysql.connector
import psycopg2
from sshtunnel import SSHTunnelForwarder
from mysql.connector import Error
try:
    logging.config.fileConfig('/home/kios/logging.conf')
    log=logging.getLogger('main')
    with SSHTunnelForwarder(
         ('myip', myport),
         #ssh_private_key="</path/to/private/ssh/key>",
         ### in my case, I used a password instead of a private key
         ssh_username='iptv',
         ssh_password='password',
         remote_bind_address=('localhost', 5432)) as server:

         server.start()
         print ("server connected")
         local_port = str(server.local_bind_port)
         params = {
             'database': 'ares-iptv',
             'user': 'mda',
             'password': 'password',
             'host': 'localhost',
             'port':local_port
             }

         connpg = psycopg2.connect(**params)
         curspg = connpg.cursor()
         print ("database connected")
    cursorUpd = conn.cursor()
    log.info('Preparing cursor:')
    curspg.execute("SELECT id, terminalid, weblogin, webpwd, ip_addr,opertype FROM public.mda_syncro where prcsflg=0;")
	log.info('Cursor is ready:')
    rows = curspg.fetchall()