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 uploads.id as uploads_id,uploads.file_original_name as uploads_file_original_name,uploads.file_name as uploads_file_name,uploads.file_size as uploads_file_size,uploads.extension as uploads_extension,uploads.type as uploads_type,uploads.external_link as uploads_external_link,uploads.created_at as uploads_created_at,uploads.updated_at as uploads_updated_at,uploads.deleted_at as uploads_deleted_at,users.id as users_id,users.referred_by as users_referred_by,users.provider as users_provider,users.refresh_token as users_refresh_token,users.access_token as users_access_token,users.user_type as users_user_type,users.name as users_name,users.email as users_email,users.email_verified_at as users_email_verified_at,users.verification_code as users_verification_code,users.new_email_verificiation_code as users_new_email_verificiation_code,users.password as users_password,users.remember_token as users_remember_token,users.device_token as users_device_token,users.avatar as users_avatar,users.avatar_original as users_avatar_original,users.address as users_address,users.country as users_country,users.state as users_state,users.city as users_city,users.postal_code as users_postal_code,users.is_influence as users_is_influence,users.phone as users_phone,users.balance as users_balance,users.banned as users_banned,users.referral_code as users_referral_code,users.remaining_uploads as users_remaining_uploads,users.created_at as users_created_at,users.updated_at as users_updated_at,users.can_use_google_translate as users_can_use_google_translate,users.info_update_pending as users_info_update_pending,uploads.created_at as  '@timestamp',products.id as products_id,products.uuid as products_uuid,products.name as products_name,products.added_by as products_added_by,products.photos as products_photos,products.can_sync_dropshipping_photos as products_can_sync_dropshipping_photos,products.can_sync_dropshipping_weight as products_can_sync_dropshipping_weight,products.can_sync_dropshipping_brand as products_can_sync_dropshipping_brand,products.can_sync_dropshipping_category as products_can_sync_dropshipping_category,products.thumbnail_img as products_thumbnail_img,products.video_provider as products_video_provider,products.video_link as products_video_link,products.tags as products_tags,products.description as products_description,products.locally_price as products_locally_price,products.locally_selling_price as products_locally_selling_price,products.global_price as products_global_price,products.global_selling_price as products_global_selling_price,products.locally_wholesale_price as products_locally_wholesale_price,products.global_wholesale_price as products_global_wholesale_price,products.purchase_price as products_purchase_price,products.variant_product as products_variant_product,products.attributes as products_attributes,products.choice_options as products_choice_options,products.colors as products_colors,products.variations as products_variations,products.todays_deal as products_todays_deal,products.published as products_published,products.best_sale as products_best_sale,products.new_product as products_new_product,products.approved as products_approved,products.stock_visibility_state as products_stock_visibility_state,products.cash_on_delivery as products_cash_on_delivery,products.featured as products_featured,products.seller_featured as products_seller_featured,products.current_stock as products_current_stock,products.unit as products_unit,products.weight as products_weight,products.min_qty as products_min_qty,products.min_qty_wholesale as products_min_qty_wholesale,products.low_stock_quantity as products_low_stock_quantity,products.discount as products_discount,products.discount_type as products_discount_type,products.discount_start_date as products_discount_start_date,products.discount_end_date as products_discount_end_date,products.tax as products_tax,products.tax_type as products_tax_type,products.shipping_type as products_shipping_type,products.shipping_cost as products_shipping_cost,products.is_quantity_multiplied as products_is_quantity_multiplied,products.est_shipping_days as products_est_shipping_days,products.num_of_sale as products_num_of_sale,products.meta_title as products_meta_title,products.meta_description as products_meta_description,products.meta_img as products_meta_img,products.pdf as products_pdf,products.slug as products_slug,products.rating as products_rating,products.barcode as products_barcode,products.digital as products_digital,products.auction_product as products_auction_product,products.file_name as products_file_name,products.file_path as products_file_path,products.external_link as products_external_link,products.external_link_btn as products_external_link_btn,products.wholesale_product as products_wholesale_product,products.sale_type as products_sale_type,products.created_at as products_created_at,products.updated_at as products_updated_at,products.deleted_at as products_deleted_at,products.starting_bid as products_starting_bid,products.auction_start_date as products_auction_start_date,products.auction_end_date as products_auction_end_date,products.refundable as products_refundable,products.earn_point as products_earn_point,products.import_using_excel as products_import_using_excel,products.drop_shipping_by as products_drop_shipping_by,products.drop_shipping_code as products_drop_shipping_code,products.drop_shipping_default_lang as products_drop_shipping_default_lang,products.info_update_pending as products_info_update_pending,products.product_stocks_image_pending as products_product_stocks_image_pending,products.reason_refuse as products_reason_refuse,uploads.created_at as  '@timestamp' from uploads  left join users on users.id=uploads.user_id  left join products on products.id=uploads.product_id"
    use_column_value => true
    tracking_column => "upload_id"
    jdbc_paging_enabled => "true"
    jdbc_page_size => 10000
  }
}
 filter {
 

    mutate  {
          
          rename=>  {
          
            }
    }
}

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

}