本文整理了Java中fj.data.List.arrayList()
方法的一些代码示例,展示了List.arrayList()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。List.arrayList()
方法的具体详情如下:
包路径:fj.data.List
类名称: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"))));
}
内容来源于网络,如有侵权,请联系作者删除!