package tst;

import com.gigaspaces.client.ReadModifiers;
import com.j_spaces.core.client.SQLQuery;
import org.openspaces.core.GigaSpace;
import org.openspaces.core.GigaSpaceConfigurer;
import org.openspaces.core.space.SpaceProxyConfigurer;

import java.util.Date;

public class ReaderWriter2 {

    GigaSpace space;

    public ReaderWriter2() {
        this.space = new GigaSpaceConfigurer(new SpaceProxyConfigurer("mySpace")).gigaSpace();
    }

    public static void main(String[] args) {

        ReaderWriter2 r = new ReaderWriter2();
       // r.write();
        r.read();
    }

    public void write(){
        for (int m = 0; m < 500000; m++) {
            MassiveObject mo = new MassiveObject(m, "moooohaaaahaaaa!", new Date(m * 10000));
            space.write(mo);
        }
    }

    public void read(){
        SQLQuery<MassiveObject> query = new SQLQuery<MassiveObject>(MassiveObject.class, "(id != -1 OR message != 'moooohaaaahaaaa!') AND (event >= ? AND event <= ?)");
        //int readModifiers = (fifo ? ReadModifiers.FIFO : ReadModifiers.REPEATABLE_READ);
        Integer value = new Integer( new Double(Math.random() * 400000).intValue());
        query.setParameter(1, new Date(value * 10000));
        query.setParameter(2, new Date((value + 10000) * 10000));
      //  System.out.println("FIFO: " + (ReadModifiers.isFifo(readModifiers) ? "true" : "false"));
        for (int k =0; k< 20; k++) {
            long beg = System.currentTimeMillis();
            Object[] objects = space.readMultiple(query, Integer.MAX_VALUE, ReadModifiers.REPEATABLE_READ);
//		long count = space.count(query);
            System.out.println("not equals query found " + objects.length + " pojos " + (System.currentTimeMillis() - beg) + "ms");
        }

    }

}