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

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

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

Query.map介绍

[英]Provide basic JavaBean mapping capabilities. Will instantiate an instance of resultType for each row and set the JavaBean properties which match fields in the result set.
[中]提供基本的JavaBean映射功能。将为每一行实例化resultType的实例，并设置与结果集中的字段匹配的JavaBean属性。

代码示例

代码示例来源：origin: apache/incubator-druid

@Override
 public List<Pair<String, String>> withHandle(Handle handle)
 {
  return handle
    .createQuery(
      buildLookupQuery(table, filter, keyColumn, valueColumn)
    ).map(
      new ResultSetMapper<Pair<String, String>>()
      {
       @Override
       public Pair<String, String> map(
         final int index,
         final ResultSet r,
         final StatementContext ctx
       ) throws SQLException
       {
        return new Pair<>(r.getString(keyColumn), r.getString(valueColumn));
       }
      }
    ).list();
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Timestamp withHandle(Handle handle)
 {
  final String query = StringUtils.format(
    "SELECT MAX(%s) FROM %s",
    tsColumn, table
  );
  return handle
    .createQuery(query)
    .map(TimestampMapper.FIRST)
    .first();
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
public List<TaskInfo<EntryType, StatusType>> getActiveTaskInfo(@Nullable String dataSource)
{
 return getConnector().retryWithHandle(
   handle -> {
    final Query<Map<String, Object>> query = createActiveTaskInfoQuery(
      handle,
      dataSource
    );
    return query.map(taskInfoMapper).list();
   }
 );
}

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

@Test
public void testMapEnumValues() throws Exception
{
  Handle h = openHandle();
  h.createStatement("insert into something (id, name) values (1, 'eric')").execute();
  h.createStatement("insert into something (id, name) values (2, 'brian')").execute();
  List<SomethingElse> results = h.createQuery("select * from something order by id")
                .map(SomethingElse.class)
                .list();
  assertEquals(SomethingElse.Name.eric, results.get(0).name);
  assertEquals(SomethingElse.Name.brian, results.get(1).name);
}

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

@Test
public void testFluentApi() throws Exception
{
  Map<String, Team> teams = handle.createQuery("select t.name as teamName, " +
                         "       t.mascot as mascot, " +
                         "       p.name as personName, " +
                         "       p.role as role " +
                         "from team t inner join person p on (t.name = p.team)")
                  .map(TeamPersonJoinRow.class)
                  .fold(Maps.<String, Team>newHashMap(), new TeamFolder());
  assertThat(teams, equalTo(expected));
}

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

@Test
public void testMapEnumValues() throws Exception
{
  Handle h = openHandle();
  h.createStatement("insert into something (id, name) values (1, 'eric')").execute();
  h.createStatement("insert into something (id, name) values (2, 'brian')").execute();
  List<SomethingElse> results = h.createQuery("select * from something order by id")
                .map(SomethingElse.class)
                .list();
  assertEquals(SomethingElse.Name.eric, results.get(0).name);
  assertEquals(SomethingElse.Name.brian, results.get(1).name);
}

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

@Test
public void testFluentApi() throws Exception
{
  Map<String, Team> teams = handle.createQuery("select t.name as teamName, " +
                         "       t.mascot as mascot, " +
                         "       p.name as personName, " +
                         "       p.role as role " +
                         "from team t inner join person p on (t.name = p.team)")
                  .map(TeamPersonJoinRow.class)
                  .fold(Maps.<String, Team>newHashMap(), new TeamFolder());
  assertThat(teams, equalTo(expected));
}

代码示例来源：origin: apache/incubator-druid

@Override
public boolean tableExists(final Handle handle, final String tableName)
{
 return !handle.createQuery(
   "SELECT tablename FROM pg_catalog.pg_tables WHERE schemaname = 'public' AND tablename ILIKE :tableName"
 )
        .bind("tableName", tableName)
        .map(StringMapper.FIRST)
        .list()
        .isEmpty();
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Optional<StatusType> withHandle(Handle handle) throws Exception
 {
  byte[] res = handle.createQuery(
    StringUtils.format("SELECT status_payload FROM %s WHERE id = :id", entryTable)
  )
            .bind("id", entryId)
            .map(ByteArrayMapper.FIRST)
            .first();
  return Optional.fromNullable(
    res == null ? null : jsonMapper.readValue(res, statusType)
  );
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
public List<TaskInfo<EntryType, StatusType>> getCompletedTaskInfo(
  DateTime timestamp,
  @Nullable Integer maxNumStatuses,
  @Nullable String dataSource
)
{
 return getConnector().retryWithHandle(
   handle -> {
    final Query<Map<String, Object>> query = createCompletedTaskInfoQuery(
      handle,
      timestamp,
      maxNumStatuses,
      dataSource
    );
    return query.map(taskInfoMapper).list();
   }
 );
}

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

@Test
public void testAPIWorks() throws Exception
{
  Spiffy s = SqlObjectBuilder.onDemand(dbi, Spiffy.class);
  s.insert(7, "Bill");
  String bill = handle.createQuery("select name from something where id = 7").map(StringMapper.FIRST).first();
  assertEquals("Bill", bill);
}

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

@Test
public void testDefines() throws Exception
{
  handle.attach(Kangaroo.class).weirdInsert("something", "id", "name", 5, "Bouncer");
  String name = handle.createQuery("select name from something where id = 5")
            .map(StringMapper.FIRST)
            .first();
  assertThat(name, equalTo("Bouncer"));
}

代码示例来源：origin: apache/incubator-druid

@Override
 public List<String> inTransaction(Handle handle, TransactionStatus status)
 {
  return handle.createQuery(reverseFetchQuery)
         .bind("val", value)
         .map(StringMapper.FIRST)
         .list();
 }
});

代码示例来源：origin: apache/incubator-druid

@Override
 public Optional<EntryType> withHandle(Handle handle) throws Exception
 {
  byte[] res = handle.createQuery(
    StringUtils.format("SELECT payload FROM %s WHERE id = :id", entryTable)
  )
            .bind("id", entryId)
            .map(ByteArrayMapper.FIRST)
            .first();
  return Optional.fromNullable(
    res == null ? null : jsonMapper.readValue(res, entryType)
  );
 }
}

代码示例来源：origin: apache/incubator-druid

boundQuery = boundQuery.bind(var.lhs, var.rhs);
final List<byte[]> existingBytes = boundQuery.map(ByteArrayMapper.FIRST).list();

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

@Test
public void testListWithMaxRows() throws Exception
{
  h.prepareBatch("insert into something (id, name) values (:id, :name)")
   .add(1, "Brian")
   .add(2, "Keith")
   .add(3, "Eric")
   .execute();
  assertEquals(1, h.createQuery("select id, name from something").map(Something.class).list(1).size());
  assertEquals(2, h.createQuery("select id, name from something").map(Something.class).list(2).size());
}

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

@Test
public void testBaz() throws Exception
{
  Wombat wombat = handle.attach(Wombat.class);
  wombat.insert(new Something(7, "Henning"));
  String name = handle.createQuery("select name from something where id = 7")
            .map(StringMapper.FIRST)
            .first();
  assertThat(name, equalTo("Henning"));
}

代码示例来源：origin: apache/incubator-druid

@Override
public boolean tableExists(final Handle handle, final String tableName)
{
 return !handle.createQuery("SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = :tableName")
   .bind("tableName", tableName)
   .map(StringMapper.FIRST)
   .list()
   .isEmpty();
}

代码示例来源：origin: apache/incubator-druid

@Override
@Nullable
public TaskInfo<EntryType, StatusType> getTaskInfo(String entryId)
{
 return connector.retryWithHandle(handle -> {
  final String query = StringUtils.format(
    "SELECT id, status_payload, payload, datasource, created_date FROM %s WHERE id = :id",
    entryTable
  );
  return handle.createQuery(query)
         .bind("id", entryId)
         .map(taskInfoMapper)
         .first();
 });
}

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

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

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com