解决GeoTools中CQL解析中文字段名的问题

    这两天做项目，使用 Geotools 封装了一个空间数据查询服务，能对 Oracle Spatial 的图层表进行查询，但是后来发现如果图层字段是中文名，则不能进行查询，后来在网上参

考了网友 无痕客的博客 ，再稍作修改后解决。  详见网址： http://www.cnblogs.com/wuhenke/archive/2011/12/07/2278681.html
表结构上图：



查询服务界面上图：



附代码：

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.Iterator;
import org.geotools.filter.AndImpl;
import org.geotools.filter.AttributeExpressionImpl;
import org.geotools.filter.IsEqualsToImpl;
import org.geotools.filter.IsNotEqualToImpl;
import org.geotools.filter.LikeFilterImpl;
import org.geotools.filter.LiteralExpressionImpl;
import org.geotools.filter.NotImpl;
import org.geotools.filter.OrImpl;
import org.geotools.filter.text.ecql.ECQL;
import org.opengis.filter.Filter;
import org.opengis.filter.expression.Expression;

public class GeotoolsFilterUtil {

<span style="color:#FF0000;">private static char startMark = 's'; //0x02;
private static char endMark = 'e'; //0x03;</span>

public static Filter whereclauseToFilter(String where) {
Filter filter = null;
try {
StringBuilder sb = new StringBuilder();
for (int i = 0, count = where.length(); i < count; i++) {
char c = where.charAt(i);
if (c < 256) {
sb.append(c);
} else {
String enc = URLEncoder.encode(String.valueOf(c), "UTF-8");
enc = enc.replaceAll("\\%", "");
sb.append(startMark + enc + endMark);
}
}
String encode = sb.toString();
Filter f = ECQL.toFilter(encode);
decodeFilter(f);
filter = f;
} catch (Exception ex) {
ex.printStackTrace();
}

return filter;
}

@SuppressWarnings("unchecked")
private static void decodeFilter(Filter filter) throws UnsupportedEncodingException {
if (filter instanceof OrImpl) {
OrImpl impl = (OrImpl) filter;
for (Iterator<Filter> itr = impl.getFilterIterator(); itr.hasNext();) {
Filter f = itr.next();
decodeFilter(f);
}
} else if (filter instanceof AndImpl) {
AndImpl impl = (AndImpl) filter;
for (Iterator<Filter> itr = impl.getFilterIterator(); itr.hasNext();) {
Filter f = itr.next();
decodeFilter(f);
}
} else if (filter instanceof NotImpl) {
NotImpl impl = (NotImpl) filter;
Filter f = impl.getFilter();
decodeFilter(f);
} else if (filter instanceof LikeFilterImpl) {
LikeFilterImpl impl = (LikeFilterImpl) filter;
String encode = impl.getLiteral();
impl.setLiteral(decodeString(encode));

<span style="color:#FF0000;">decodeExpression(impl.getExpression());</span>
} else if (filter instanceof IsEqualsToImpl) {
IsEqualsToImpl impl = (IsEqualsToImpl) filter;
decodeExpression(impl.getExpression1());
decodeExpression(impl.getExpression2());
} else if (filter instanceof IsNotEqualToImpl) {
IsNotEqualToImpl impl = (IsNotEqualToImpl) filter;
decodeExpression(impl.getExpression1());
decodeExpression(impl.getExpression2());
}
}

private static void decodeExpression(Expression exp) throws UnsupportedEncodingException {
<span style="color:#FF0000;">/**
* 还原属性名为中文
*/
if (exp instanceof AttributeExpressionImpl) {
AttributeExpressionImpl impl = (AttributeExpressionImpl) exp;
String encode = String.valueOf(impl.getPropertyName());
//System.out.println("encode2:"+encode+" decodeString(encode)2:"+decodeString(encode));
impl.setPropertyName(decodeString(encode));
}</span>

/**
* 还原属性值为中文
*/
if (exp instanceof LiteralExpressionImpl) {
LiteralExpressionImpl impl = (LiteralExpressionImpl) exp;
String encode = String.valueOf(impl.getValue());
//System.out.println("encode1:"+encode+" decodeString(encode)1:"+decodeString(encode));
impl.setValue(decodeString(encode));
}

}

private static String decodeString(String encode) throws UnsupportedEncodingException {
StringBuilder sb = new StringBuilder();
int i = 0, count = encode.length();
while (i < count) {
int start = encode.indexOf(startMark, i);
if (start >= 0) {
sb.append(encode.substring(i, start));
} else {
sb.append(encode.substring(i));
return sb.toString();
}

int end = encode.indexOf(endMark, i);
if (end > 0) {
i = end + 1;

String enc = encode.substring(start + 1, end);
StringBuilder sbEnc = new StringBuilder();
for (int j = 0, l = enc.length(); j < l; j += 2) {
sbEnc.append("%" + enc.charAt(j) + enc.charAt(j + 1));
}
String dec = URLDecoder.decode(sbEnc.toString(), "UTF-8");
sb.append(dec);
} else {
sb.append(encode.substring(i + 1));
i = count;
}
}
return sb.toString();
}

public static void main(String args[]){
String filterCondition = "湿地斑块名 like '%河%' and 湿地斑块序 = 38";

Filter filter = GeotoolsFilterUtil.whereclauseToFilter(filterCondition);
System.out.println(filter.toString());
}
}

红色字体代码为修改内容，综合了无痕客的代码及引用的参考代码，解决了原文不能查询,  或者只能查询一个中文字段的问题。