input {
  jdbc {
    jdbc_driver_library => "D:\elastic\logstash\mysql-connector-j-9.0.0.jar"
    jdbc_driver_class => "com.mysql.cj.jdbc.Driver"
    jdbc_connection_string => "jdbc:mysql://esghosts.com:3306/esgsadmin_eturk"
    jdbc_user => "esgsadmin_eturk"
    jdbc_password => "p4kc7bzcnxsz"
    schedule => "* * * * *"
    statement => "select carrier_range_prices.id as carrier_range_prices_id,carrier_range_prices.price as carrier_range_prices_price,carrier_range_prices.created_at as carrier_range_prices_created_at,carrier_range_prices.updated_at as carrier_range_prices_updated_at,carriers.id as carriers_id,carriers.name as carriers_name,carriers.code as carriers_code,carriers.logo as carriers_logo,carriers.transit_time as carriers_transit_time,carriers.free_shipping as carriers_free_shipping,carriers.local_shipping as carriers_local_shipping,carriers.status as carriers_status,carriers.created_at as carriers_created_at,carriers.updated_at as carriers_updated_at,carrier_range_prices.created_at as  '@timestamp',carrier_ranges.id as carrier_ranges_id,carrier_ranges.billing_type as carrier_ranges_billing_type,carrier_ranges.delimiter1 as carrier_ranges_delimiter1,carrier_ranges.delimiter2 as carrier_ranges_delimiter2,carrier_ranges.created_at as carrier_ranges_created_at,carrier_ranges.updated_at as carrier_ranges_updated_at,carrier_range_prices.created_at as  '@timestamp',zones.id as zones_id,zones.name as zones_name,zones.status as zones_status,zones.created_at as zones_created_at,zones.updated_at as zones_updated_at,carrier_range_prices.created_at as  '@timestamp' from carrier_range_prices  left join carriers on carriers.id=carrier_range_prices.carrier_id  left join carrier_ranges on carrier_ranges.id=carrier_range_prices.carrier_range_id  left join zones on zones.id=carrier_range_prices.zone_id"
    use_column_value => true
    tracking_column => "carrier_range_price_id"
    jdbc_paging_enabled => "true"
    jdbc_page_size => 10000
  }
}
 filter {
 

    mutate  {
          
          rename=>  {
          
            }
    }
}

output {
  elasticsearch {
     hosts => "localhost:9200"
     index => "carrier_range_prices"
     user => "elastic"
     password => "123456"
     document_id => "%{carrier_range_prices_id}"
     ssl_enabled => true
     ssl_verification_mode => "none"
  }

}