Ignite自定义函数注意事项

1. Customer SQL Function
   首先，需要写自定义SQL函数的java类。

注意：1. 定义函数的方法必须是静态的static修饰。

      2. 自定义函数的方法不能重载。
      3. 每个方法必须要用@QuerySqlFunction注释。
      4.当有多个自定义方法时，不能同时在@QuerySqlFunction(alias=’XXX’)中定义别名。
      5. 使用setSqlfunction(‘xxx.class’)注册函数的时候，不能同时注册两个class,如果需要自定义多个函数可以在一个类中定义多个方法。

示例如下：
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;

import org.apache.ignite.cache.query.annotations.QuerySqlFunction;

public class addition2{

public static final String DATE_TIME_PATTERN = "yyyy-MM-dd HH:mm:ss";
public static final String MINUTE_PATTERN = "yyyy-MM-dd HH:mm";
public static final String HOUR_PATTERN = "yyyy-MM-dd HH:mm:ss";
public static final String DATE_PATTERN = "yyyy-MM-dd";
public static final String HOUR_FORMAT = "HH:mm:ss";
public static final String MONTH_PATTERN = "yyyy-MM";
public static final String YEAR_PATTERN = "yyyy";
public static final String MINUTE_ONLY_PATTERN = "mm";
public static final String HOUR_ONLY_PATTERN = "HH";

// @QuerySqlFunction
// public static double add1(int x,double y){
// return (double)x+y;
// }

@QuerySqlFunction
public static int add(int x,int y){
    return x+y;
}
@QuerySqlFunction
public static int chengfa(int x,int y){
    return x*y;
}
@QuerySqlFunction
public static int jianfa(int x,int y){
    return x-y;
}
@QuerySqlFunction
public static double chufa(double x,double y){
    if (y==0)
        System.out.println("被除数不能为零，重新输入：");
    return x/y;
}
@QuerySqlFunction
public static Date todate(String dateTimeString,String pattern) throws ParseException{
    if(pattern==null||pattern==""){
        pattern =DATE_PATTERN;
    }
    SimpleDateFormat sdf = new SimpleDateFormat(pattern);
    return sdf.parse(dateTimeString);
}

}

1. 注册自定义函数
   注意：1.客户端和服务器端需要同时拥有自定义函数的类文件，不然会找不到文件

   1. 采用client方式启动的ignite获取的cacheconfigeration对象和服务器段启动的ignite获取的cacheconfigeration对象是不一样的，客户端必须定义不一样的cache名，且服务器端必须配置sqlchema，不然会报错找不到sqlschema。
   2. 程序中使用setName(‘XXXX’)指定cachename的时候需要与已经存在的cacheName不同。

示例如下：
import java.util.Arrays;
import java.util.List;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.Ignition;
import org.apache.ignite.cache.CacheAtomicityMode;
import org.apache.ignite.cache.CacheMode;
import org.apache.ignite.cache.query.QueryCursor;
import org.apache.ignite.cache.query.SqlFieldsQuery;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder;
import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;

public class SqlFunction {

public static void main(String[] args) {
    // TODO Auto-generated method stub
    //local ignite connect
            IgniteConfiguration cfg1 = new IgniteConfiguration();
            cfg1.setIgniteInstanceName("productinfo_withtime");
            TcpDiscoverySpi spi = new TcpDiscoverySpi();
            TcpDiscoveryMulticastIpFinder ipFinder = new TcpDiscoveryMulticastIpFinder();
            ipFinder.setAddresses(Arrays.asList("127.0.0.1:47500..47510"));
            spi.setIpFinder(ipFinder);
            cfg1.setDiscoverySpi(spi);
            cfg1.setClientMode(true);
            Ignite ignite = Ignition.start(cfg1);        
            CacheConfiguration ccfg = new CacheConfiguration();
            ccfg.setName("productinfo1");
            ccfg.setSqlSchema("productinfo_withtime");
            ccfg.setSqlFunctionClasses(addition2.class);        
            IgniteCache cache = ignite.getOrCreateCache(ccfg);
            SqlFieldsQuery query = new SqlFieldsQuery("SELECT add(number,20) add,chengfa(number,3) chengfa,jianfa(number,3) jianfa,chufa(unitPrice,3) chufa,number,floor(unitPrice) floor,unitPrice,todate(time,'yyyy-MM-dd'),time FROM SALE");
            QueryCursor<List<?>> cursor=cache.query(query);
            int i=1;
            for(List<?> row: cursor){
            System.out.println("调用add函数后的number数据第"+i+"行为："+row.get(0)+"\t调用chengfa函数后number的数据为："+row.get(1)+"\t调用jianfa函数后的number的数据为："+row.get(2)+"\t调用chufa函数后的unitPrice的数据为："+row.get(3)+"，\tnumber原始数据为："+row.get(4)+"，\t调用内置floor函数后的unitprice的值："+row.get(5)+"，\tunitPrice原始数据为："+row.get(6)+"，\t调用to_date函数后saleDate数据为："+row.get(7)+"，\tsaleDate原始数据为："+row.get(8));
                i++;
            }
        }
}