Hi, Does ignite v2.1 support UPDATE queries with JOINS?
I tried a SELECT query as follows and it worked fine - select count(*) from fulfill_order fo join table(id bigint = ?) t on fo.fulfill_order_status_code = t.id"; SqlFieldsQuery enhanceQuery = new SqlFieldsQuery(cacheQuery); ArrayList<Integer> list = new ArrayList<>(); list.add(7); list.add(1); list.add(9); Integer [] arr = list.toArray(new Integer[list.size()]); Object [] obj = new Object[]{arr}; enhanceQuery.setArgs(obj); IgniteCache<fulfill_order_key, fulfill_order> fulfillOrderCache = Ignition.ignite() .cache(CacheNameConstants.FULFILL_ORDER_CACHE_NAME); QueryCursor<List<?>> cursor = fulfillOrderCache.query(enhanceQuery); However, I tried running UPDATE query as follows but none of the queries worked. 1. String updateQuery = "UPDATE fo SET fo.fulfill_order_status_code =? " + "FROM fulfill_order fo join table(id bigint = ?) t on fo.fulfill_order_status_code = t.id " + "where fo.fulfill_order_id=?"; SqlFieldsQuery enhanceQuery = new SqlFieldsQuery(updateQuery); ArrayList<Integer> list = new ArrayList<>(); list.add(7); list.add(1); list.add(9); Integer [] arr = list.toArray(new Integer[list.size()]); Object [] obj = new Object[]{arr}; enhanceQuery.setArgs(3,obj, 347427284695L); IgniteCache<fulfill_order_key, fulfill_order> fulfillOrderCache = Ignition.ignite() .cache(CacheNameConstants.FULFILL_ORDER_CACHE_NAME); fulfillOrderCache.query(enhanceQuery); 2. update fulfill_order fo join table(id bigint = ?) t on fo.fulfill_order_status_code = t.id set fo.fulfill_order_status_code =?, fo.last_update_userid =?, fo.order_due_ts =?, fo.last_update_ts =? where fo.fulfill_order_id=? Can someone help with the correct way of running UPDATE query with JOIN? Thanks! -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/