fj.data.List.arrayList()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(99)

本文整理了Java中fj.data.List.arrayList()方法的一些代码示例,展示了List.arrayList()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。List.arrayList()方法的具体详情如下:
包路径:fj.data.List
类名称:List
方法名:arrayList

List.arrayList介绍

[英]Constructs a list from the given elements.
[中]从给定元素构造一个列表。

代码示例

代码示例来源:origin: org.functionaljava/functionaljava

/**
 * Constructs a list from the given elements.
 *
 * @param as The elements to construct a list with.
 * @return A list with the given elements.
 */
@SafeVarargs public static <A> List<A> list(final A... as) {
 return arrayList(as);
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test
public void submitIsNotTransactional()
{
  DB<Unit> fail = insertKeysOp(arrayList("a", "b", "c")).bind(ignore -> new DB<Unit>()
  {
    @Override public Unit run(Connection c) throws SQLException
    {
      throw new SQLException("failed i have");
    }
  });
  swallow(() -> DB.submit(fail));
  assertThat(DB.submit(SELECT_ALL_IDS_OP), is(arrayList("a", "b", "c")));
  assertThat(DB.transact(SELECT_ALL_IDS_OP), is(arrayList("a", "b", "c")));
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test
  public void testIt()
  {
    SyncDbInterpreter dbi = new SyncDbInterpreter(
        () -> DriverManager.getConnection("jdbc:hsqldb:mem:test", "sa", "")
    );

    //given an iterable of DB's
    List<DB<String>> dbList = arrayList(
        DB.unit("foo"),
        DB.unit("bar"),
        DB.unit("baz")
    );

    //we can treat it as a DB<List>
    DB<List<String>> db = sequence(dbList);

    List<String> result = dbi.submit(db);

    assertThat(result, is(arrayList("foo", "bar", "baz")));

  }
}

代码示例来源:origin: novarto-oss/sane-dbc

throw new RuntimeException();
    },
    arrayList()
)),
is(none())
      throw new RuntimeException();
    },
    arrayList(),
    rs -> {
      throw new RuntimeException();

代码示例来源:origin: novarto-oss/sane-dbc

@Test
public void dbSequence()
{
  DB.transact(insertDataOp(arrayList(p(1, "foo"), p(2, "bar"), p(3, "zzz"))));
  List<DB<Option<String>>> dbs = arrayList(selectByUniqueDescOp("foo"), selectByUniqueDescOp("zzz"),
      selectByUniqueDescOp("no_such"));
  List<Option<String>> result = DB.submit(sequence(dbs, fjListCanBuildFrom()));
  assertThat(result, is(arrayList(some("foo"), some("zzz"), none())));
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test
  public void testIt()
  {

    SyncDbInterpreter dbi = new SyncDbInterpreter(
        () -> DriverManager.getConnection("jdbc:hsqldb:mem:test", "sa", "")

    );

    Tree<Integer> result = dbi.submit(intTree());

    Tree<Integer> expected = node(
        1,
        arrayList(
            leaf(2),
            node(
                3,
                arrayList(leaf(4), leaf(5))
            )
        )
    );

    assertThat(
        result,
        is(expected)
    );

  }
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test
public void iterableBinder()
{
  List<P2<String, String>> data = arrayList(p("x1", "y1"), p("x2", "y2"), p("x3", "y3"));
  String sql = format(
      "INSERT INTO MySqlTest_FOO(X,Y) VALUES ({0})",
      SqlStringUtils.placeholderRows(data.length(), 2)
  );
  UpdateOp insert = new UpdateOp(
      sql,
      Binders.iterableBinder((pos, ps, x) -> {
        int currentPosition = pos;
        ps.setString(currentPosition++, x._1());
        ps.setString(currentPosition++, x._2());
        return currentPosition;
      }, data)
  );
  int updateCount = DB.transact(insert);
  assertThat(updateCount, is(3));
  List<P2<String, String>> readData = DB.submit(new SelectOp.FjList<>("SELECT X,Y FROM MySqlTest_FOO", NO_BINDER,
      rs -> p(rs.getString(1), rs.getString(2))));
  assertThat(readData, is(data));
}

代码示例来源:origin: novarto-oss/sane-dbc

List<String> helloSaneDbc = List.arrayList("hello", "sane", "dbc");

代码示例来源:origin: novarto-oss/sane-dbc

@BeforeClass
public static void setupSuite()
{
  fj.control.db.DB<Unit> createSchema = sequence(
      arrayList(new EffectOp("CREATE TABLE MySqlTest_IDS (ID INTEGER PRIMARY KEY IDENTITY, DUMMY CHAR)"),
          new EffectOp("CREATE TABLE MySqlTest_DATA (ID INTEGER PRIMARY KEY, DESCRIPTION VARCHAR(100))"),
          new EffectOp("CREATE TABLE MySqlTest_EXPIRING_STUFF (ID INTEGER PRIMARY KEY IDENTITY," +
              " DESCRIPTION VARCHAR(100), STAMP BIGINT)"),
          new EffectOp("CREATE TABLE MySqlTest_FOO (X VARCHAR (100), Y VARCHAR(100))")
      )).map(ignore -> Unit.unit());
  DB.transact(createSchema);
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test
public void testIt()
{
  SyncDbInterpreter dbi = new SyncDbInterpreter(
      () -> DriverManager.getConnection("jdbc:hsqldb:mem:bind_example", "sa", "")
  );
  dbi.submit(UserDB.CREATE_USER_TABLE);
  dbi.submit(OrderDb.CREATE_TABLE);
  dbi.submit(UserDB.insertUser("john@doe.com", "abcd"));
  dbi.submit(UserDB.insertUser("foo@bar.com", "abcd"));
  dbi.submit(
      OrderDb.insertOrders(
          arrayList(new CreateOrder("john@doe.com", "Hi there"),
              new CreateOrder("foo@bar.com", "Bye there")
          ))
  );
  Either<String, List<Order>> result = dbi.submit(OrderDb.authenticateAndGetOrders("john@doe.com", "abcd"));
  assertThat(result.isRight(), is(true));
  List<Order> orders = result.right().value();
  assertThat(orders.isSingle(), is(true));
  Order johnOrder = orders.head();
  assertThat(johnOrder.text, is("Hi there"));
  Either<String, List<Order>> shouldFail = dbi.submit(OrderDb.authenticateAndGetOrders("haxx0r", "abcd"));
  assertThat(shouldFail, is(Either.left("auth failure")));
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test public void testIt()
{
  assertThat(awaitSuccess(dbi.submit(insert("x"))), is(1));
  assertThat(awaitSuccess(dbi.submit(selectAll())), is(single("x")));
  SQLException ex = new SQLException("failed i have");
  assertThat(
      awaitFailure(dbi.transact(new DB<Unit>()
      {
        @Override public Unit run(Connection c) throws SQLException
        {
          insert("a").run(c);
          insert("b").run(c);
          throw ex;
        }
      })),
      is(ex)
  );
  assertThat(awaitSuccess(dbi.submit(selectAll())), is(single("x")));
  SQLException noConn = new SQLException("no connection");
  AsyncDbInterpreter noConnection = new AsyncDbInterpreter(() -> {
    throw noConn;
  }, executor);
  assertThat(awaitFailure(noConnection.transact(insert("alabala"))), is(noConn));
  assertThat(awaitSuccess(dbi.submit(selectAll())), is(single("x")));
  assertThat(
      awaitSuccess(dbi.transact(insert("y").bind(ignore -> insert("z")).map(ignore2 -> Unit.unit()))),
      is(Unit.unit())
  );
  assertThat(awaitSuccess(dbi.submit(selectAll())), is(arrayList("x", "y", "z")));
}

代码示例来源:origin: novarto-oss/sane-dbc

@Test public void testIt()
{
  assertThat(DB.submit(insert("x")).f(), is(success(1)));
  assertThat(DB.submit(selectAll()).f(), is(success(single("x"))));
  SQLException ex = new SQLException("failed i have");
  assertThat(
      DB.transact(new DB<Unit>()
      {
        @Override public Unit run(Connection c) throws SQLException
        {
          insert("a").run(c);
          insert("b").run(c);
          throw ex;
        }
      }).f(),
      is(fail(ex))
  );
  assertThat(DB.submit(selectAll()).f(), is(success(single("x"))));
  SQLException noConn = new SQLException("no connection");
  ValidationDbInterpreter noConnection = new ValidationDbInterpreter(() -> {
    throw noConn;
  });
  assertThat(noConnection.transact(insert("alabala")).f(), is(fail(noConn)));
  assertThat(DB.submit(selectAll()).f(), is(success(single("x"))));
  assertThat(
      DB.transact(insert("y").bind(ignore -> insert("z")).map(ignore2 -> Unit.unit())).f(),
      is(success(Unit.unit()))
  );
  assertThat(DB.submit(selectAll()).f(), is(success(arrayList("x", "y", "z"))));
}

相关文章