input {
  jdbc {
     jdbc_driver_library => "C:\logstash-6.1.1\bin\mssql-jdbc-6.2.2.jre8.jar"
     jdbc_driver_class => "com.microsoft.sqlserver.jdbc.SQLServerDriver"
     jdbc_connection_string => "jdbc:sqlserver://localhost:1433;databasename=AppDataBase;user=sa;password=******"
     jdbc_user => "sa"
     jdbc_password => "****"
     jdbc_pool_timeout => 30
     jdbc_validate_connection => true
     statement =>  "select
                    Vendasid CodigoDaVenda,
                    DataVenda DataDaVenda,
                    Produtos Produto,
                    EntregaEm EnderecoDeEntrega,
                    Vendas.VendedoresID CodigoDoVendedor,
                    Nome Vendedor,
                    Nascimento DataDeNascimento
                    from Vendas
                    inner join Vendedores on Vendas.VendedoresID = Vendedores.VendedoresID
    "
     schedule => "* * * * *"
  }
}
output {
    elasticsearch {
        hosts	=>	[	"localhost:9200"	]
        index => "vendas5"
        document_id => "%{codigodavenda}"
    }
    stdout {
        codec => json_lines
    }
}