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

大佬教程收集整理的这篇文章主要介绍了通过数据库连接器创建SQL查询的动态Mule创建条件，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决通过数据库连接器创建SQL查询的动态Mule创建条件？

开发过程中遇到通过数据库连接器创建SQL查询的动态Mule创建条件的问题如何解决？下面主要结合日常开发的经验，给出你关于通过数据库连接器创建SQL查询的动态Mule创建条件的解决方法建议，希望对你解决通过数据库连接器创建SQL查询的动态Mule创建条件有所启发或帮助；

我想到使用自定义变压器。所以我为此使用了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;
}}

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

在数据库连接器中，将查询类型选择为 。在 条件之后，添加 。

干杯

解决方法

@H_262_30@