Examples of addWithSizeCheck()


Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

    UserIdentifier userId = new UserIdentifier(UUID.randomUUID());
    QueryFavourites newHistory = new QueryFavourites();

    CqlQuery query = new CqlQuery(CqlQueryType.SELECT, "select * from MyTable");
    QueryEntry favEntry = new QueryEntry(query, 234);
    newHistory.addWithSizeCheck(favEntry);

    storage.store(userId, newHistory);

    Optional<QueryFavourites> readHistory = storage.read(userId, QueryFavourites.class);
    assertNotNull(readHistory);
View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

    UserIdentifier userId = new UserIdentifier(UUID.randomUUID());
    QueryFavourites history = new QueryFavourites();
    {
      for (int i = 0; i < 50; i++) {
        CqlQuery query = new CqlQuery(CqlQueryType.SELECT, "select * from MyTable where id=" + i);
        assertTrue(history.addWithSizeCheck(new QueryEntry(query, 234)));
      }
      assertEquals(50, history.size());
    }

    checkFavLimitContent(history);
View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

    checkFavLimitContent(history);

    {
      for (int i = 0; i < 10; i++) {
        CqlQuery query = new CqlQuery(CqlQueryType.SELECT, "select * from MyTableA where id=" + i);
        assertFalse(history.addWithSizeCheck(new QueryEntry(query, 456)));
      }
      checkFavLimitContent(history);
    }

    {
View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

    }

    {
      for (int i = 0; i < 20; i++) {
        CqlQuery query = new CqlQuery(CqlQueryType.SELECT, "select * from MyTable where id=" + i);
        assertTrue(history.addWithSizeCheck(new QueryEntry(query, 234)));
      }
      checkFavLimitContent(history);
    }

    {
View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

  @Test
  public void testCreateReadAndClear() throws Exception {
    QueryFavourites favourites = favService.read();

    for (int i = 0; i < 20; i++) {
      assertTrue(favourites.addWithSizeCheck(new QueryEntry(new CqlQuery(CqlQueryType.SELECT,
          "select * from HistoryStarTest where id=" + i), 1000 + i)));

      assertTrue(favourites.addWithSizeCheck(new QueryEntry(new CqlQuery(CqlQueryType.SELECT,
          "select * from HistoryStarTest where id=" + i), 2000 + i)));

View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

    for (int i = 0; i < 20; i++) {
      assertTrue(favourites.addWithSizeCheck(new QueryEntry(new CqlQuery(CqlQueryType.SELECT,
          "select * from HistoryStarTest where id=" + i), 1000 + i)));

      assertTrue(favourites.addWithSizeCheck(new QueryEntry(new CqlQuery(CqlQueryType.SELECT,
          "select * from HistoryStarTest where id=" + i), 2000 + i)));

      favService.store(favourites);
      QueryFavourites favQueue = asyncFileStore.getFromWriteQueue(user).get();
      assertNotNull(favQueue);
View Full Code Here

Examples of org.cyclop.model.QueryFavourites.addWithSizeCheck()

            favs.add(readFavs);

            QueryEntry fav = new QueryEntry(new CqlQuery(CqlQueryType.SELECT,
                "select * from MyTable2 where id=" + UUID.randomUUID()), 5000 + i);
            int retry = 0;
            while (!readFavs.addWithSizeCheck(fav)) {
              retry++;
              assertTrue(retry < 100);

              ImmutableSortedSet<QueryEntry> favsSorted = readFavs.copyAsSortedSet();
              UnmodifiableIterator<QueryEntry> iterator = favsSorted.iterator();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.