public class Main {



    public static float roznicaWartosci(float licz1,float licz2){
        return licz1-licz2;
    }
    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
        // TODO Auto-generated method stub
        Configuration config = new Configuration();
        config.addImport("*");

        EPServiceProvider epServiceProvider = EPServiceProviderManager.getDefaultProvider();
        EPAdministrator epAdministrator = epServiceProvider.getEPAdministrator();
        /*EPStatement epStatement = epAdministrator.createEPL(
                "select istream max(obrot) as maksimum " +
                        "from KursAkcji().win:ext_timed_batch(data.getTime(), 7 days) "

                        );
            */
        ProstyListener prostyListener = new ProstyListener();
        EPStatement epVariableSize2 =epAdministrator.createEPL("create variable long rozmiar=50") ;
        EPStatement epSchema = epAdministrator.createEPL("create schema KursyLicznik (kursZamkniecia int, liczba Integer, blad Integer)");
        EPStatement epWindow = epAdministrator.createEPL("create window Top50.ext:sort(rozmiar, liczba DESC,blad ASC).std:unique(kursZamkniecia) retain-intersection as KursyLicznik");
        EPStatement epVariableError = epAdministrator.createEPL("create variable integer moja_zmienna = 0");
        EPStatement epVariableSize = epAdministrator.createEPL("create variable long rozmiar_zmienna = 0");
        EPStatement epVariableYear = epAdministrator.createEPL("create variable long aktualny_rok = 0");


                EPStatement epEvent = epAdministrator.createEPL("on KursAkcji as ka " +
                "merge Top50 as t " +
                "where t.kursZamkniecia = cast(ka.kursZamkniecia,int) " +
                "when matched then " +
                "update set t.liczba = t.liczba + 1 " +
                "when not matched and rozmiar_zmienna < rozmiar then " +
                "insert into Top50 " +
                        "(kursZamkniecia, liczba, blad) " +
                        "select cast(ka.kursZamkniecia,int), 1  , 0 " +
                                "when not matched and rozmiar_zmienna >= rozmiar then " +
                                "insert into Top50 " +
                                "(kursZamkniecia, liczba, blad) " +
                                "select cast(ka.kursZamkniecia,int), moja_zmienna+1  , moja_zmienna "

                );

        EPStatement epEvent4 = epAdministrator.createEPL("on Top50 as t " +
                "set rozmiar_zmienna = (select count(*) from Top50 as t)");

        EPStatement epEvent3= epAdministrator.createEPL("on Top50 as t " +
                "select t.kursZamkniecia,t.liczba,t.blad from Top50 as t order by t.liczba DESC");

        EPStatement epEvent2 = epAdministrator.createEPL("on Top50 as ka " +
                "set moja_zmienna = (select min(t.liczba) from Top50 as t )");

        EPStatement epEvent5 = epAdministrator.createEPL("on KursAkcji(KursAkcji.getDayOfYear(ka.data)<aktualny_rok) as ka " +
                "select t.kursZamkniecia as co,t.liczba as ile,t.blad as e from Top50 as t order by t.liczba DESC limit 1");


        epAdministrator.createEPL("on KursAkcji as k " +
                "set aktualny_rok = KursAkcji.getDayOfYear(k.data) " );//.addListener(prostyListener);

        //epEvent2.addListener(prostyListener);
        //epEvent3.addListener(prostyListener);
        epEvent5.addListener(prostyListener);

        InputStream inputStream = new InputStream();
        inputStream.generuj(epServiceProvider);

    }

}