input {
    jdbc {
        jdbc_connection_string => "jdbc:oracle:thin:@apogee.univ.fr:1521:APOGEE"
        jdbc_user => "user"
        jdbc_password => "xxxxx"
        jdbc_validate_connection => true
        jdbc_driver_library => "../lib/ojdbc14-10.2.0.4.0.jar"
        jdbc_driver_class => "Java::oracle.jdbc.driver.OracleDriver"
        statement => "SELECT 'CMP' || cod_cmp || '0' id, 'CMP' type, cod_cmp COD_OBJ, 0 COD_VRS_OBJ, '[' || cod_cmp || '] ' || lib_cmp LIB_DESC_OBJ, lib_cmp LIB_OBJ FROM composante UNION SELECT DISTINCT 'VDI' || vdi.cod_dip || vdi.cod_vrs_vdi id, 'VDI' type, vdi.cod_dip COD_OBJ, vdi.cod_vrs_vdi COD_VRS_OBJ, '[' || vdi.cod_dip || '/' || vdi.cod_vrs_vdi || '] ' || vdi.lib_web_vdi LIB_DESC_OBJ, vdi.lib_web_vdi LIB_OBJ FROM version_diplome vdi, diplome d, VDI_FRACTIONNER_VET vfv WHERE vdi.cod_dip = d.cod_dip and vfv.COD_DIP=d.cod_dip and vfv.COD_VRS_VDI=vdi.COD_VRS_VDI and vfv.DAA_FIN_RCT_VET > (select cod_anu - 2 from annee_uni where eta_anu_iae = 'O') UNION SELECT DISTINCT 'VET' || vet.cod_etp || vet.cod_vrs_vet id, 'VET' type, vet.cod_etp COD_OBJ, vet.cod_vrs_vet COD_VRS_OBJ, '[' || vet.cod_etp || '/' || vet.cod_vrs_vet || '] ' || vet.lib_web_vet LIB_DESC_OBJ, vet.lib_web_vet LIB_OBJ FROM version_etape vet, etape e, VDI_FRACTIONNER_VET vfv WHERE vet.cod_etp = e.cod_etp and vfv.COD_ETP=e.cod_etp and vfv.COD_VRS_VET=vet.COD_VRS_VET and vfv.DAA_FIN_RCT_VET > (select cod_anu - 2 from annee_uni where eta_anu_iae = 'O') UNION SELECT 'ELP' || cod_elp || '0' id,'ELP' type, cod_elp COD_OBJ, 0 COD_VRS_OBJ,'[' || cod_elp || '] ' || lib_elp LIB_DESC_OBJ, lib_elp LIB_OBJ FROM element_pedagogi e UNION select 'ETU' || IND.COD_ETU || '' id, 'ETU' type,CAST(IND.COD_ETU as VARCHAR2(40)) COD_OBJ, 0 COD_VRS_OBJ,  '[' || IND.COD_ETU || '] ' || IND.LIB_PR1_IND || ' ' || decode(IND.LIB_NOM_USU_IND,null,IND.lib_nom_pat_ind,decode(IND.LIB_NOM_USU_IND, IND.lib_nom_pat_ind,IND.lib_nom_pat_ind,IND.lib_nom_pat_ind || ' (' ||  IND.LIB_NOM_USU_IND || ')')) LIB_DESC_OBJ, IND.LIB_PR1_IND || ' ' || decode(IND.LIB_NOM_USU_IND,null,IND.lib_nom_pat_ind,decode(IND.LIB_NOM_USU_IND, IND.lib_nom_pat_ind,IND.lib_nom_pat_ind,IND.lib_nom_pat_ind || ' (' ||  IND.LIB_NOM_USU_IND || ')')) LIB_OBJ from individu ind, INS_ADM_ANU iaa  where IAA.COD_IND=ind.COD_IND and IND.COD_ETU is not null and IAA.COD_ANU > (select cod_anu - 2 from annee_uni where eta_anu_iae = 'O')"
    }
}
output {
    elasticsearch {
        index => "apogee"
        document_type => "%{type}"
        document_id => "%{id}"
        hosts => "http://localhost:9200"
    }
}