#!/usr/bin/env python3
# -*- coding: UTF-8 -*-

from sqlalchemy import create_engine

isin_bdd = True
# Parametres bdd CEN38 OUT
user = 'postgres'
pwd  = 'tutu'
adr  = '192.168.60.10'
base = 'bd_cen'
con = create_engine('postgresql+psycopg2://{0}:{1}@{2}/{3}'.format(user,pwd,adr,base), echo=False)

# Parametres bdd SICEN OUT
sicen_user = 'cen_admin'
sicen_pwd  = '#CEN38@venir'
sicen_adr  = '91.134.194.221'
sicen_base = 'sicen2'
sicen_con = create_engine('postgresql+psycopg2://{0}:{1}@{2}/{3}'.format(sicen_user,sicen_pwd,sicen_adr,sicen_base), echo=False)


DIC_REF_HAB = {
  'ssbv': {
    'gid':'id',
    'CD_SSBV': 'cdssbv',
    'LIB_SSBV': 'nom',
    'CD_COMGEO': 'cd_comgeo',
    'CD_CTB': 'cd_ctb',
    'CD_': 'cd_',
    'CD_SUBUNIT': 'cd_subunit',
    'geometry': 'geom', },
  'plan_eau':{
    'gid':'id',
    'geometry':'geom',
    'CdOH':'cdoh',
    'TopoOH':'nom',
    'NaturePE':'nature_pe',},
  'masse_eau':{
    'gid':'id',
    'geometry':'geom',
    'CdMasseDEa':'cd_mass_eau',
    'CdEuMasseD':'cdeu_mass_eau',
    'NomMasseDE':'nom',
    'SurfaceTot':'surfacetot',
    'CdEuSsBass':'cdeu_ssbass',
    'TypeGeneal':'type_geneal',},
  'cours_eau':{
    'gid':'id',
    'geometry':'geom',
    'CdOH':'cdoh',
    'TopoOH':'nom',},
  'troncon_hydro':{
    'gid':'id',
    'geometry':'geom',
    'CdOH':'cdoh',
    'TopoOH':'nom',
    'NatureTH':'nature_th',
    'TronconFic':'troncon_fic',
    'PositionPa':'position_pa',
    'Persistanc':'persistance',
    'OrigineTH':'origine_th',
    'SensEcoule':'sens_ecoule',
    'ReseauPrin':'reseau_prin',
    'Delimitati':'delimit',
    'ClasseLarg':'classe_larg',
    'BrasTH':'bras_th',
    'CdCoursEau':'cd_cours_eau',
    'CdSurfaceE':'cd_surf_eau',},
}

DIC_UNIQUE_KEY = {
  'ssbv': 'cdssbv',
  'plan_eau': 'cdoh',
  'masse_eau': 'cd_mass_eau',
  'cours_eau': 'cdoh',
  'troncon_hydro': 'nom',
}



dic_zh_medwet = {
    'SITE_COD':'id',
    'DEPT':'dept',
    'ORG':'org',
    'NUM':'num',
    'SITE_NAME':'nom',
}

class sites:
  def tab_sites():
    tab = {}
    tab['name'] = 'sites'
    tab['schema'] = 'sites'
    tab['desc_columns'] = con.dialect.get_columns(con,schema=tab['schema'],table_name=tab['name'])
    tab['columns'] = [col['name'] for col in tab['desc_columns']]
    tab['contraintes'] = con.dialect.get_foreign_keys(con,schema=tab['schema'],table_name=tab['name'])
    tab['pkey'] = con.dialect.get_pk_constraint(con,schema=tab['schema'],table_name=tab['name'])
    return tab

  def tab_geomsites():
    tab = {}
    tab['name'] = 'r_sites_geom'
    tab['schema'] = 'sites'
    tab['desc_columns'] = con.dialect.get_columns(con,schema=tab['schema'],table_name=tab['name'])
    tab['columns'] = [col['name'] for col in tab['desc_columns']]
    tab['contraintes'] = con.dialect.get_foreign_keys(con,schema=tab['schema'],table_name=tab['name'])
    tab['pkey'] = con.dialect.get_pk_constraint(con,schema=tab['schema'],table_name=tab['name'])
    return tab