org.skife.jdbi.v2.Query.mapTo()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(257)

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

Query.mapTo介绍

[英]Makes use of registered mappers to map the result set to the desired type.
[中]使用已注册的映射器将结果集映射到所需的类型。

代码示例

代码示例来源：origin: HubSpot/Singularity

  1. @Override
  2. public int getTaskIdHistoryCount(Optional<String> requestId, Optional<String> deployId, Optional<String> runId, Optional<String> host,
  3.                  Optional<ExtendedTaskState> lastTaskStatus, Optional<Long> startedBefore, Optional<Long> startedAfter, Optional<Long> updatedBefore,
  4.                  Optional<Long> updatedAfter) {
  5.   final Map<String, Object> binds = new HashMap<>();
  6.   final StringBuilder sqlBuilder = new StringBuilder(GET_TASK_ID_HISTORY_COUNT_QUERY);
  7.   applyTaskIdHistoryBaseQuery(sqlBuilder, binds, requestId, deployId, runId, host, lastTaskStatus, startedBefore, startedAfter, updatedBefore, updatedAfter);
  8.   final String sql = sqlBuilder.toString();
  9.   LOG.trace("Generated sql for task search count: {}, binds: {}", sql, binds);
  10.   final Query<Integer> query = getHandle().createQuery(sql).mapTo(Integer.class);
  11.   for (Map.Entry<String, Object> entry : binds.entrySet()) {
  12.     query.bind(entry.getKey(), entry.getValue());
  13.   }
  14.   return query.first();
  15. }

代码示例来源：origin: HubSpot/Singularity

  1. @Override
  2. public List<SingularityTaskIdHistory> getTaskIdHistory(Optional<String> requestId, Optional<String> deployId, Optional<String> runId, Optional<String> host,
  3.                             Optional<ExtendedTaskState> lastTaskStatus, Optional<Long> startedBefore, Optional<Long> startedAfter, Optional<Long> updatedBefore,
  4.                             Optional<Long> updatedAfter, Optional<OrderDirection> orderDirection, Optional<Integer> limitStart, Integer limitCount) {
  5.   final Map<String, Object> binds = new HashMap<>();
  6.   final StringBuilder sqlBuilder = new StringBuilder(GET_TASK_ID_HISTORY_QUERY);
  7.   applyTaskIdHistoryBaseQuery(sqlBuilder, binds, requestId, deployId, runId, host, lastTaskStatus, startedBefore, startedAfter, updatedBefore, updatedAfter);
  8.   sqlBuilder.append(" ORDER BY startedAt ");
  9.   sqlBuilder.append(orderDirection.or(OrderDirection.DESC).name());
  10.   if (!requestId.isPresent()) {
  11.     sqlBuilder.append(", requestId ");
  12.     sqlBuilder.append(orderDirection.or(OrderDirection.DESC).name());
  13.   }
  14.   // NOTE: PG, MySQL are both compatible with OFFSET LIMIT syntax, while only MySQL understands LIMIT offset, limit.
  15.   if (limitCount != null ){
  16.     sqlBuilder.append(" LIMIT :limitCount");
  17.     binds.put("limitCount", limitCount);
  18.   }
  19.   if (limitStart.isPresent()) {
  20.     sqlBuilder.append(" OFFSET :limitStart ");
  21.     binds.put("limitStart", limitStart.get());
  22.   }
  23.   final String sql = sqlBuilder.toString();
  24.   LOG.trace("Generated sql for task search: {}, binds: {}", sql, binds);
  25.   final Query<SingularityTaskIdHistory> query = getHandle().createQuery(sql).mapTo(SingularityTaskIdHistory.class);
  26.   for (Map.Entry<String, Object> entry : binds.entrySet()) {
  27.     query.bind(entry.getKey(), entry.getValue());
  28.   }
  29.   return query.list();
  30. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Override
  2.   public Integer withHandle(Handle handle) throws Exception
  3.   {
  4.     return handle.createQuery("select 2 + 2").mapTo(Integer.class).first();
  5.   }
  6. });

代码示例来源：origin: org.jdbi/jdbi

  1. @Override
  2.   public void call(IDBI dbi)
  3.   {
  4.     final Handle h = DBIUtil.getHandle(dbi);
  5.     int count = h.createQuery("select count(*) from something").mapTo(Integer.class).first();
  6.     assertEquals(0, count);
  7.   }
  8. });

代码示例来源：origin: org.kill-bill.commons/killbill-jdbi

  1. @Override
  2.   public Object withHandle(final Handle h) throws Exception {
  3.     h.execute("create");
  4.     h.execute("insert", 1, "Brian");
  5.     String brian = h.createQuery("findNameById").bind("0", 1).mapTo(String.class).first();
  6.     assertThat(brian).isEqualTo("Brian");
  7.     return null;
  8.   }
  9. });

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testZipping() throws Exception
  3. {
  4.   UsesBatching b = handle.attach(UsesBatching.class);
  5.   List<Integer> ids = Arrays.asList(1, 2, 3, 4, 5);
  6.   List<String> names = Arrays.asList("David", "Tim", "Mike");
  7.   b.zipArgumentsTogether(ids, names);
  8.   assertThat(b.size(), equalTo(3));
  9.   List<String> ins_names = handle.createQuery("select distinct name from something order by name")
  10.                   .mapTo(String.class)
  11.                   .list();
  12.   assertThat(ins_names, equalTo(Arrays.asList("David", "Mike", "Tim")));
  13. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Override
  2.   public String withHandle(Handle handle) throws Exception {
  3.     handle.execute("insert into something (id, name) values (8, 'Mike')");
  4.     return handle.createQuery("select name from something where id = 8").mapTo(String.class).first();
  5.   }
  6. });

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testBindConstantValue() throws Exception
  3. {
  4.   UsesBatching b = handle.attach(UsesBatching.class);
  5.   List<Integer> ids = Arrays.asList(1, 2, 3, 4, 5);
  6.   b.withConstantValue(ids, "Johan");
  7.   assertThat(b.size(), equalTo(5));
  8.   List<String> names = handle.createQuery("select distinct name from something")
  9.                 .mapTo(String.class)
  10.                 .list();
  11.   assertThat(names, equalTo(Arrays.asList("Johan")));
  12. }

代码示例来源：origin: org.kill-bill.commons/killbill-jdbi

  1. @Override
  2.   public Something withHandle(Handle handle) throws Exception
  3.   {
  4.     handle.insert("insert into something (id, name) values (18, 'Sam')");
  5.     return handle.createQuery("select id, name from something where id = :id")
  6.       .bind("id", 18)
  7.       .mapTo(Something.class)
  8.       .first();
  9.   }
  10. });

代码示例来源：origin: org.jdbi/jdbi

  1. @Override
  2.   public Something withHandle(Handle handle) throws Exception
  3.   {
  4.     handle.insert("insert into something (id, name) values (18, 'Sam')");
  5.     return handle.createQuery("select id, name from something where id = :id")
  6.       .bind("id", 18)
  7.       .mapTo(Something.class)
  8.       .first();
  9.   }
  10. });

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testOnList() throws Exception
  3. {
  4.   h.registerContainerFactory(new ImmutableListContainerFactory());
  5.   h.execute("insert into something (id, name) values (1, 'Coda')");
  6.   h.execute("insert into something (id, name) values (2, 'Brian')");
  7.   ImmutableList<String> rs = h.createQuery("select name from something order by id")
  8.                 .mapTo(String.class)
  9.                 .list(ImmutableList.class);
  10.   assertThat(rs, equalTo(ImmutableList.of("Coda", "Brian")));
  11. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testDefines() throws Exception
  3. {
  4.   handle.attach(Kangaroo.class).weirdInsert("something", "id", "name", 5, "Bouncer");
  5.   String name = handle.createQuery("select name from something where id = 5")
  6.             .mapTo(String.class)
  7.             .first();
  8.   assertThat(name, equalTo("Bouncer"));
  9. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testBaz() throws Exception
  3. {
  4.   Wombat wombat = handle.attach(Wombat.class);
  5.   wombat.insert(new Something(7, "Henning"));
  6.   String name = handle.createQuery("select name from something where id = 7")
  7.             .mapTo(String.class)
  8.             .first();
  9.   assertThat(name, equalTo("Henning"));
  10. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testMapToEnum() throws Exception
  3. {
  4.   Handle h = openHandle();
  5.   h.createStatement("insert into something (id, name) values (1, 'eric')").execute();
  6.   h.createStatement("insert into something (id, name) values (2, 'brian')").execute();
  7.   List<SomethingElse.Name> results = h.createQuery("select name from something order by id")
  8.                 .mapTo(SomethingElse.Name.class)
  9.                 .list();
  10.   assertEquals(SomethingElse.Name.eric, results.get(0));
  11.   assertEquals(SomethingElse.Name.brian, results.get(1));
  12. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testDefines() throws Exception
  3. {
  4.   handle.attach(Wombat.class).weirdInsert("something", "id", "name", 5, "Bouncer");
  5.   handle.attach(Wombat.class).weirdInsert("something", "id", "name", 6, "Bean");
  6.   String name = handle.createQuery("select name from something where id = 5")
  7.             .mapTo(String.class)
  8.             .first();
  9.   assertThat(name, equalTo("Bouncer"));
  10. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testDoesNotExist() throws Exception
  3. {
  4.   h.execute("insert into something (id, name) values (1, 'Coda')");
  5.   h.registerContainerFactory(new MaybeContainerFactory());
  6.   Maybe<String> rs = h.createQuery("select name from something where id = :id")
  7.             .bind("id", 2)
  8.             .mapTo(String.class)
  9.             .first(Maybe.class);
  10.   assertThat(rs.isKnown(), equalTo(false));
  11. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testExists() throws Exception
  3. {
  4.   h.execute("insert into something (id, name) values (1, 'Coda')");
  5.   h.registerContainerFactory(new MaybeContainerFactory());
  6.   Maybe<String> rs = h.createQuery("select name from something where id = :id")
  7.             .bind("id", 1)
  8.             .mapTo(String.class)
  9.             .first(Maybe.class);
  10.   assertThat(rs.isKnown(), equalTo(true));
  11.   assertThat(rs.getValue(), equalTo("Coda"));
  12. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testAPIWorks() throws Exception
  3. {
  4.   Spiffy s = SqlObjectBuilder.onDemand(dbi, Spiffy.class);
  5.   s.insert(7, "Bill");
  6.   String bill = handle.createQuery("select name from something where id = 7").mapTo(String.class).first();
  7.   assertEquals("Bill", bill);
  8. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testInsertWithVoidReturn() throws Exception
  3. {
  4.   Inserter i = SqlObjectBuilder.open(dbi, Inserter.class);
  5.   // this is what is under test here
  6.   i.insertWithVoidReturn(2, "Diego");
  7.   String name = handle.createQuery("select name from something where id = 2").mapTo(String.class).first();
  8.   assertEquals("Diego", name);
  9.   i.close();
  10. }

代码示例来源：origin: org.jdbi/jdbi

  1. @Test
  2. public void testInsert() throws Exception
  3. {
  4.   Spiffy s = handle.attach(Spiffy.class);
  5.   s.insert(new Something(2, "Bean"));
  6.   String name = handle.createQuery("select name from something where id = 2").mapTo(String.class).first();
  7.   assertEquals("Bean", name);
  8. }

内容来源于网络，如有侵权，请联系作者删除！

query

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com