点燃查询异常

即时得到以下错误：点燃查询异常

Caused by: org.h2.jdbc.JdbcSQLException: Syntax error in SQL statement "SELECT 
""standard_item_cache"".""STANDARDITEM""._KEY, 
""standard_item_cache"".""STANDARDITEM""._VAL FROM 
""standard_item_cache"".""STANDARDITEM"" WHERE ITEMID[*] == ? "; SQL statement: 
SELECT "standard_item_cache"."STANDARDITEM"._KEY, 
"standard_item_cache"."STANDARDITEM"._VAL FROM 
"standard_item_cache"."STANDARDITEM" WHERE itemId == ? [42000-196]

当我试图执行一个简单的查询：

String itemId = params.get(Params.PARAM_ITEM_ID); 

SqlQuery<String, StandardItem> sql = new SqlQuery<>(StandardItem.class, "itemid == ?"); 

try (QueryCursor<Cache.Entry<String, StandardItem>> cursor = standardItemIgniteCache.query(sql.setArgs(itemId))) { 
    logger.info("publish standard items from cache"); 

    for (Cache.Entry<String, StandardItem> entry : cursor) { 
     logger.info("publish standard item: " + entry.getValue().toString()); 
    } 

    logger.info("publishing standard items from cache done"); 

    cursor.close(); 
}

哪里错了吗？ Im doint完全像它在apache ignite中描述的例子：https://apacheignite.readme.io/v1.0/docs/cache-queries

来源

2017-11-25 Mulgard

错误在于这个小字符串：itemid == ?。使用==代替=。 SQL相等运算符是一个单独的=。

来源

2017-11-25 12:53:29 Denis

点燃查询异常

回答

相关问题