# WHERE condition in logstash

**URL:** <https://discuss.elastic.co/t/where-condition-in-logstash/364516>\
**Category:** Logstash\
**Created:** [August 7, 2024, 7:29am UTC](https://discuss.elastic.co/t/where-condition-in-logstash/364516 "2024-08-07T07:29:28Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![Danyal\_Danish](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/danyal_danish/32/131444_2.png) [@Danyal\_Danish](https://discuss.elastic.co/u/Danyal_Danish)\
**Post date:** [August 7, 2024, 7:29am UTC](https://discuss.elastic.co/t/where-condition-in-logstash/364516/1 "2024-08-07T07:29:28Z")

</div>

Hi, I'm trying to run this query in the logstash jdbc but I'm facing this syntax error everytime. I tried multiple variations of single and double quotations but each time I'm getting the same error.

Query:

```auto
  jdbc_streaming {
    id => "jdbc_mainSKU"
    jdbc_driver_library => "D:/projects/connectors/postgresql-42.7.1.jar"
    jdbc_driver_class => "org.postgresql.Driver"
    jdbc_connection_string => "jdbc:postgresql://192.168.1.213:5432/catalog_management"
    jdbc_user => ""
    jdbc_password => ""
    jdbc_validation_timeout => "30"
    jdbc_validate_connection => true
    use_cache => false

    statement => 'SELECT
    id,
    active,
    barcode,
    is_default AS "isDefault",
    part_number AS "partNumber",
    discount_price AS "discountPrice",
    price,
    quantity,

    variant_id AS "variantId"
    FROM 
      main_skus
    WHERE
      active = "ACTIVE" AND product_id = :product_id'
    parameters => { "product_id" => "id" }
    target => "mainSKU" 
  }

```

Error log:

> [2024-08-07T12:05:52,653][WARN][logstash.pluginmixins.jdbcstreaming.normalstatementhandler][product\_pipeline][jdbc\_mainSKU] Exception when executing JDBC query {:statement=\>"SELECT\r\n id,\r\n active,\r\n barcode,\r\n is\_default AS "isDefault",\r\n part\_number AS "partNumber",\r\n discount\_price AS "discountPrice",\r\n price,\r\n quantity,\r\n\r\n variant\_id AS "variantId"\r\n FROM \r\n main\_skus\r\n WHERE\r\n active = "ACTIVE" AND product\_id = :product\_id", :parameters=\>{:product\_id=\>691}, :exception=\>#\<Sequel::DatabaseError: Java::OrgPostgresqlUtil::PSQLException: ERROR: column "ACTIVE" does not exist

---

<div class="post-metadata">

**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\
**Post date:** [August 7, 2024, 7:41am UTC](https://discuss.elastic.co/t/where-condition-in-logstash/364516/2 "2024-08-07T07:41:39Z")

</div>

From #Kibana to #Logstash

---

<div class="post-metadata">

**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\
**Post date:** [August 7, 2024, 7:41am UTC](https://discuss.elastic.co/t/where-condition-in-logstash/364516/3 "2024-08-07T07:41:39Z")

</div>

Removed #canvas