本文整理了Java中io.vertx.core.json.JsonArray.getLong()
方法的一些代码示例,展示了JsonArray.getLong()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。JsonArray.getLong()
方法的具体详情如下:
包路径:io.vertx.core.json.JsonArray
类名称:JsonArray
方法名:getLong
[英]Get the Long at position pos in the array,
[中]获取阵列中位置pos处的长数据,
代码示例来源:origin: eclipse-vertx/vert.x
@Test
public void testGetLong() {
jsonArray.add(123l);
assertEquals(Long.valueOf(123l), jsonArray.getLong(0));
try {
jsonArray.getLong(-1);
fail();
} catch (IndexOutOfBoundsException e) {
jsonArray.getLong(1);
fail();
} catch (IndexOutOfBoundsException e) {
assertEquals(Long.valueOf(123l), jsonArray.getLong(1));
jsonArray.add(123f);
assertEquals(Long.valueOf(123l), jsonArray.getLong(2));
jsonArray.add(123d);
assertEquals(Long.valueOf(123l), jsonArray.getLong(3));
jsonArray.add("foo");
try {
jsonArray.getLong(4);
fail();
} catch (ClassCastException e) {
assertNull(jsonArray.getLong(5));
代码示例来源:origin: eclipse-vertx/vert.x
@Test
public void testAddLong() {
assertSame(jsonArray, jsonArray.add(123l));
assertEquals(Long.valueOf(123l), jsonArray.getLong(0));
try {
jsonArray.add((Long)null);
fail();
} catch (NullPointerException e) {
// OK
}
}
代码示例来源:origin: eclipse-vertx/vert.x
@Test
public void testDecode() {
byte[] bytes = TestUtils.randomByteArray(10);
String strBytes = Base64.getEncoder().encodeToString(bytes);
Instant now = Instant.now();
String strInstant = ISO_INSTANT.format(now);
String json = "[\"foo\",123,1234,1.23,2.34,true,\"" + strBytes + "\",\"" + strInstant + "\",null,{\"foo\":\"bar\"},[\"foo\",123]]";
JsonArray arr = new JsonArray(json);
assertEquals("foo", arr.getString(0));
assertEquals(Integer.valueOf(123), arr.getInteger(1));
assertEquals(Long.valueOf(1234l), arr.getLong(2));
assertEquals(Float.valueOf(1.23f), arr.getFloat(3));
assertEquals(Double.valueOf(2.34d), arr.getDouble(4));
assertEquals(true, arr.getBoolean(5));
assertArrayEquals(bytes, arr.getBinary(6));
assertEquals(Base64.getEncoder().encodeToString(bytes), arr.getValue(6));
assertEquals(now, arr.getInstant(7));
assertEquals(now.toString(), arr.getValue(7));
assertTrue(arr.hasNull(8));
JsonObject obj = arr.getJsonObject(9);
assertEquals("bar", obj.getString("foo"));
JsonArray arr2 = arr.getJsonArray(10);
assertEquals("foo", arr2.getString(0));
assertEquals(Integer.valueOf(123), arr2.getInteger(1));
}
代码示例来源:origin: eclipse-vertx/vert.x
assertEquals("bar", jsonArray.getString(0));
assertEquals(Integer.valueOf(123), jsonArray.getInteger(1));
assertEquals(Long.valueOf(123l), jsonArray.getLong(2));
assertEquals(Float.valueOf(1.23f), jsonArray.getFloat(3));
assertEquals(Double.valueOf(1.23d), jsonArray.getDouble(4));
代码示例来源:origin: io.vertx/vertx-core
@Test
public void testGetLong() {
jsonArray.add(123l);
assertEquals(Long.valueOf(123l), jsonArray.getLong(0));
try {
jsonArray.getLong(-1);
fail();
} catch (IndexOutOfBoundsException e) {
jsonArray.getLong(1);
fail();
} catch (IndexOutOfBoundsException e) {
assertEquals(Long.valueOf(123l), jsonArray.getLong(1));
jsonArray.add(123f);
assertEquals(Long.valueOf(123l), jsonArray.getLong(2));
jsonArray.add(123d);
assertEquals(Long.valueOf(123l), jsonArray.getLong(3));
jsonArray.add("foo");
try {
jsonArray.getLong(4);
fail();
} catch (ClassCastException e) {
assertNull(jsonArray.getLong(5));
代码示例来源:origin: io.vertx/vertx-core
@Test
public void testAddLong() {
assertSame(jsonArray, jsonArray.add(123l));
assertEquals(Long.valueOf(123l), jsonArray.getLong(0));
try {
jsonArray.add((Long)null);
fail();
} catch (NullPointerException e) {
// OK
}
}
代码示例来源:origin: io.vertx/vertx-core
@Test
public void testDecode() {
byte[] bytes = TestUtils.randomByteArray(10);
String strBytes = Base64.getEncoder().encodeToString(bytes);
Instant now = Instant.now();
String strInstant = ISO_INSTANT.format(now);
String json = "[\"foo\",123,1234,1.23,2.34,true,\"" + strBytes + "\",\"" + strInstant + "\",null,{\"foo\":\"bar\"},[\"foo\",123]]";
JsonArray arr = new JsonArray(json);
assertEquals("foo", arr.getString(0));
assertEquals(Integer.valueOf(123), arr.getInteger(1));
assertEquals(Long.valueOf(1234l), arr.getLong(2));
assertEquals(Float.valueOf(1.23f), arr.getFloat(3));
assertEquals(Double.valueOf(2.34d), arr.getDouble(4));
assertEquals(true, arr.getBoolean(5));
assertArrayEquals(bytes, arr.getBinary(6));
assertEquals(Base64.getEncoder().encodeToString(bytes), arr.getValue(6));
assertEquals(now, arr.getInstant(7));
assertEquals(now.toString(), arr.getValue(7));
assertTrue(arr.hasNull(8));
JsonObject obj = arr.getJsonObject(9);
assertEquals("bar", obj.getString("foo"));
JsonArray arr2 = arr.getJsonArray(10);
assertEquals("foo", arr2.getString(0));
assertEquals(Integer.valueOf(123), arr2.getInteger(1));
}
代码示例来源:origin: FroMage/redpipe
@Override
protected java.util.function.Function<Object,Integer> keyConverter(){
return lastId -> Integer.valueOf(((io.vertx.core.json.JsonArray)lastId).getLong(0).intValue());
}
}
代码示例来源:origin: apiman/apiman
@Override
public Long getLong(int index) {
indexCheck();
return rows.get(row).getLong(index);
}
代码示例来源:origin: io.vertx/vertx-core
assertEquals("bar", jsonArray.getString(0));
assertEquals(Integer.valueOf(123), jsonArray.getInteger(1));
assertEquals(Long.valueOf(123l), jsonArray.getLong(2));
assertEquals(Float.valueOf(1.23f), jsonArray.getFloat(3));
assertEquals(Double.valueOf(1.23d), jsonArray.getDouble(4));
代码示例来源:origin: com.jporm/jpo-rx-vertx3
@Override
public long getLong(final int columnIndex) {
return orDefault(resultSet.getResults().get(position).getLong(columnIndex), 0l);
}
代码示例来源:origin: tsegismont/vertx-musicstore
private Single<JsonArray> findGenres(SQLConnection sqlConnection) {
return sqlConnection.rxQueryStream(findAllGenres)
.flatMapObservable(SQLRowStream::toObservable)
.map(row -> new JsonObject().put("id", row.getLong(0)).put("name", row.getString(1)))
.collect(JsonArray::new, JsonArray::add);
}
}
代码示例来源:origin: tsegismont/vertx-musicstore
private Single<JsonArray> findAlbums(SQLConnection sqlConnection, Long genreId) {
return sqlConnection.rxQueryStreamWithParams(findAlbumsByGenre, new JsonArray().add(genreId))
.flatMapObservable(SQLRowStream::toObservable)
.map(row -> new JsonObject().put("id", row.getLong(0)).put("title", row.getString(1)))
.collect(JsonArray::new, JsonArray::add);
}
代码示例来源:origin: tsegismont/vertx-musicstore
private Single<JsonArray> findArtists(SQLConnection sqlConnection, Long genreId) {
return sqlConnection.rxQueryStreamWithParams(findArtistsByGenre, new JsonArray().add(genreId))
.flatMapObservable(SQLRowStream::toObservable)
.map(row -> new JsonObject().put("id", row.getLong(0)).put("name", row.getString(1)))
.collect(JsonArray::new, JsonArray::add);
}
}
代码示例来源:origin: EnMasseProject/enmasse
public long getQueueMessageCount(String queueName) throws TimeoutException {
log.info("Checking message count for queue {} on broker {}", queueName, syncRequestClient.getRemoteContainer());
Message response = doAttribute("queue." + queueName, "messageCount");
String payload = (String) ((AmqpValue)response.getBody()).getValue();
JsonArray json = new JsonArray(payload);
return json.getLong(0);
}
代码示例来源:origin: jklingsporn/vertx-jooq-async
@Override
public CompletableFuture<Long> insertReturning(Query query) {
return getConnection().thenCompose(sqlConnection -> {
CompletableFuture<Long> cf = new VertxCompletableFuture<>(vertx);
sqlConnection.update(query.getSQL(ParamType.INLINED), executeAndClose(updateResult->updateResult.getKeys().getLong(0), sqlConnection, cf));
return cf;
});
}
代码示例来源:origin: io.github.jklingsporn/vertx-jooq-async-future
@Override
public CompletableFuture<Long> insertReturning(Query query) {
return getConnection().thenCompose(sqlConnection -> {
CompletableFuture<Long> cf = new VertxCompletableFuture<>(vertx);
sqlConnection.update(query.getSQL(ParamType.INLINED), executeAndClose(updateResult->updateResult.getKeys().getLong(0), sqlConnection, cf));
return cf;
});
}
代码示例来源:origin: io.vertx/vertx-codetrans
@CodeTranslate
public void getLong() throws Exception {
JsonArray arr = JsonTest.array;
arr = JsonConverter.fromJsonArray(arr);
JsonTest.o = arr.getLong(0);
}
代码示例来源:origin: io.github.jklingsporn/vertx-jooq-async-rx
@Override
public Single<Long> insertReturning(Query query) {
return getConnection()
.flatMap(executeAndClose(sqlConnection ->
sqlConnection
.rxUpdateWithParams(query.getSQL(), getBindValues(query))
.map(updateResult -> updateResult.getKeys().getLong(0)))
);
}
代码示例来源:origin: jklingsporn/vertx-jooq-async
@Override
public Single<Long> insertReturning(Query query) {
return getConnection()
.flatMap(executeAndClose(sqlConnection ->
sqlConnection
.rxUpdateWithParams(query.getSQL(), getBindValues(query))
.map(updateResult -> updateResult.getKeys().getLong(0)))
);
}
内容来源于网络,如有侵权,请联系作者删除!