通过数据库连接器创建SQL查询的动态Mule创建条件

Question

我需要创建一个动态查询，其中条件将根据传入的请求更改，其中请求将始终通过查询参数获取。例子如下： http：// localhost：8084 /
basePath？name = balwant＆age =
26

，或 http：//
localhost：8084 / basePath？name = balwant＆age = 26＆gender =
M

同样，它是动态的。现在，我需要一种创建查询的方法，该查询将基于请求中的查询参数添加WHERE条件。

Answer 1

我想到使用自定义变压器。所以我为此使用了Java转换器。

逻辑看起来像这样：

public class QueryBuilder extends AbstractMessageTransformer {

@Override
public Object transformMessage(MuleMessage message, String outputEncoding)
        throws TransformerException {

    System.out.println("Query Params : "
            + message.getInboundProperty("http.query.params").getClass()
                    .getName());

    Map<?, ?> map = message.getInboundProperty("http.query.params");

    System.out.println("Map keys : " + map.keySet());
    String where = "";
    for (Map.Entry<?, ?> entry : map.entrySet()) {
        System.out.println(entry.getKey() + "/" + entry.getValue());
        where = where+" "+entry.getKey()+"="+"'"+entry.getValue()+"'"+" and";
    }
    String whereCondition = where.substring(0, where.lastIndexOf(" "));
    System.out.println("Where condition is : "+ where.substring(0, where.lastIndexOf(" ")));
    return whereCondition;
}}

现在，这将返回字符串类型的有效负载。

在数据库连接器中，将查询类型选择为 动态 。在 WHERE 条件之后，添加 ＃[payload] 。

干杯