java.sql.ResultSet.getBytes()方法的使用及代码示例

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

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

ResultSet.getBytes介绍

[英]Gets the value of a column specified by column index as a byte array.
[中]获取列索引指定为字节数组的列的值。

代码示例

代码示例来源：origin: com.h2database/h2

private byte[] fetch() {
  try {
    prep.setInt(2, seq++);
    ResultSet rs = prep.executeQuery();
    if (rs.next()) {
      return rs.getBytes(1);
    }
    return null;
  } catch (SQLException e) {
    throw DbException.convert(e);
  }
}

代码示例来源：origin: azkaban/azkaban

@Override
 public List<byte[]> handle(final ResultSet rs) throws SQLException {
  if (!rs.next()) {
   return Collections.emptyList();
  }
  final ArrayList<byte[]> data = new ArrayList<>();
  do {
   final byte[] bytes = rs.getBytes(5);
   data.add(bytes);
  } while (rs.next());
  return data;
 }
}

代码示例来源：origin: spring-projects/spring-security-oauth

public OAuth2AccessToken mapRow(ResultSet rs, int rowNum) throws SQLException {
    try {
      return deserializeAccessToken(rs.getBytes(2));
    }
    catch (IllegalArgumentException e) {
      String token = rs.getString(1);
      jdbcTemplate.update(deleteAccessTokenSql, token);
      return null;
    }
  }
}

代码示例来源：origin: stackoverflow.com

String imageName = request.getPathInfo().substring(1); // Returns "foo.png".
try (Connection connection = dataSource.getConnection(); PreparedStatement statement = connection.prepareStatement(SQL_FIND)) {
  statement.setString(1, imageName);
  try (ResultSet resultSet = statement.executeQuery()) {
    if (resultSet.next()) {
      byte[] content = resultSet.getBytes("content");
      response.setContentType(getServletContext().getMimeType(imageName));
      response.setContentLength(content.length);

代码示例来源：origin: azkaban/azkaban

@Override
 public List<ProjectFileHandler> handle(final ResultSet rs) throws SQLException {
  if (!rs.next()) {
   return null;
  }
  final List<ProjectFileHandler> handlers = new ArrayList<>();
  do {
   final int projectId = rs.getInt(1);
   final int version = rs.getInt(2);
   final long uploadTime = rs.getLong(3);
   final String uploader = rs.getString(4);
   final String fileType = rs.getString(5);
   final String fileName = rs.getString(6);
   final byte[] md5 = rs.getBytes(7);
   final int numChunks = rs.getInt(8);
   final String resourceId = rs.getString(9);
   final ProjectFileHandler handler =
     new ProjectFileHandler(projectId, version, uploadTime, uploader, fileType, fileName,
       numChunks, md5,
       resourceId);
   handlers.add(handler);
  } while (rs.next());
  return handlers;
 }
}

代码示例来源：origin: apache/phoenix

@Test
public void test() throws Exception {
  Connection conn = DriverManager.getConnection(getUrl());
  PreparedStatement stmt = conn.prepareStatement(
    "UPSERT INTO " + TABLE_NAME + " VALUES (?, ?, ?)");
  stmt.setString(1, KEY);
        "SELECT SET_BYTE(vb, 1, 1), SET_BYTE(b, 1, 1) FROM " + TABLE_NAME);
  assertTrue(rs.next());
  assertArrayEquals(new byte[] { 1, 1, 3, 4 }, rs.getBytes(1));
  assertArrayEquals(new byte[] { 1, 1, 3, 4 }, rs.getBytes(2));
  assertTrue(!rs.next());
  rs =
        "SELECT SET_BIT(vb, 8, 1), SET_BIT(b, 8, 1) FROM " + TABLE_NAME);
  assertTrue(rs.next());
  assertArrayEquals(new byte[] { 1, 3, 3, 4 }, rs.getBytes(1));
  assertArrayEquals(new byte[] { 1, 3, 3, 4 }, rs.getBytes(2));
  assertTrue(!rs.next());

代码示例来源：origin: marytts/marytts

+ "' AND outputtype = 'AUDIO' AND locale = '" + locale + "' AND voice = '" + voice + "' AND outputparams = '"
    + outputparams + "' AND style = '" + style + "' AND effects = '" + effects + "' AND inputtext = ?";
PreparedStatement st = connection.prepareStatement(query);
st.setString(1, inputtext);
ResultSet results = st.executeQuery();
if (results.next()) {
  audio = results.getBytes(1);

代码示例来源：origin: debezium/debezium

public Set<ChangeTable> listOfChangeTables() throws SQLException {
  final String query = GET_LIST_OF_CDC_ENABLED_TABLES;
  return queryAndMap(query, rs -> {
    final Set<ChangeTable> changeTables = new HashSet<>();
    while (rs.next()) {
      changeTables.add(
          new ChangeTable(
              new TableId(realDatabaseName, rs.getString(1), rs.getString(2)),
              rs.getString(3),
              rs.getInt(4),
              Lsn.valueOf(rs.getBytes(6)),
              Lsn.valueOf(rs.getBytes(7))
          )
      );
    }
    return changeTables;
  });
}

代码示例来源：origin: AxonFramework/AxonFramework

@Override
public SerializedObject<byte[]> readSerializedSaga(ResultSet resultSet) throws SQLException {
  return new SimpleSerializedObject<>(resultSet.getBytes(1), byte[].class,
                    resultSet.getString(2),
                    resultSet.getString(3));
}

代码示例来源：origin: azkaban/azkaban

@Override
 public List<byte[]> handle(final ResultSet rs) throws SQLException {
  if (!rs.next()) {
   return Collections.emptyList();
  }
  final List<byte[]> data = new ArrayList<>();
  do {
   final byte[] bytes = rs.getBytes(1);
   data.add(bytes);
  } while (rs.next());
  return data;
 }
}

代码示例来源：origin: wildfly/wildfly

PreparedStatement ps=prepareStatement(c, select, ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_UPDATABLE)) {
ps.setString(1, cluster);
try(ResultSet resultSet=ps.executeQuery()) {
  int index=1;
  while(resultSet.next()) {
    byte[] bytes=resultSet.getBytes(1);
    try {
      PingData data=deserialize(bytes);

代码示例来源：origin: marytts/marytts

+ "' AND outputtype = 'AUDIO' AND locale = '" + locale + "' AND voice = '" + voice + "' AND outputparams = '"
    + outputparams + "' AND style = '" + style + "' AND effects = '" + effects + "' AND inputtext = ?";
PreparedStatement st = connection.prepareStatement(query);
st.setString(1, inputtext);
ResultSet results = st.executeQuery();
if (results.next()) {
  audio = results.getBytes(1);

代码示例来源：origin: debezium/debezium

public Set<ChangeTable> listOfNewChangeTables(Lsn fromLsn, Lsn toLsn) throws SQLException {
  final String query = GET_LIST_OF_NEW_CDC_ENABLED_TABLES;
  return prepareQueryAndMap(query,
      ps -> {
        ps.setBytes(1, fromLsn.getBinary());
        ps.setBytes(2, toLsn.getBinary());
      },
      rs -> {
        final Set<ChangeTable> changeTables = new HashSet<>();
        while (rs.next()) {
          changeTables.add(new ChangeTable(
                    rs.getString(4),
                    rs.getInt(1),
                    Lsn.valueOf(rs.getBytes(5)),
                    Lsn.valueOf(rs.getBytes(6))
                  ));
        }
        return changeTables;
      }
  );
}

代码示例来源：origin: cloudfoundry/uaa

@Override
  public TokenCode mapRow(ResultSet rs, int rowNum) throws SQLException {
    int pos = 1;
    String code = rs.getString(pos++);
    String userid = rs.getString(pos++);
    String client_id = rs.getString(pos++);
    long expiresat = rs.getLong(pos++);
    Timestamp created = rs.getTimestamp(pos++);
    byte[] authentication = rs.getBytes(pos++);
    return createTokenCode(code, userid, client_id, expiresat, created, authentication);
  }
}

代码示例来源：origin: azkaban/azkaban

@Override
 public String handle(final ResultSet rs) throws SQLException {
  String attachmentsJson = null;
  if (rs.next()) {
   try {
    final byte[] attachments = rs.getBytes(1);
    if (attachments != null) {
     attachmentsJson = GZIPUtils.unGzipString(attachments, "UTF-8");
    }
   } catch (final IOException e) {
    throw new SQLException("Error decoding job attachments", e);
   }
  }
  return attachmentsJson;
 }
}

代码示例来源：origin: com.h2database/h2

PreparedStatement prep = prepare(sql);
prep.setLong(1, block);
ResultSet rs = prep.executeQuery();
if (rs.next()) {
  boolean compressed = rs.getInt(1) != 0;
  byte[] compare = rs.getBytes(2);
  if (compressed == (compressAlgorithm != null) && Arrays.equals(b, compare)) {
    blockExists = true;

代码示例来源：origin: apache/storm

try {
  connection = connectionProvider.getConnection();
  try (PreparedStatement preparedStatement = connection.prepareStatement(sqlQuery)) {
    if (queryTimeoutSecs > 0) {
      preparedStatement.setQueryTimeout(queryTimeoutSecs);
    try (ResultSet resultSet = preparedStatement.executeQuery()) {
      List<List<Column>> rows = Lists.newArrayList();
      while (resultSet.next()) {
        ResultSetMetaData metaData = resultSet.getMetaData();
        int columnCount = metaData.getColumnCount();
          Class columnJavaType = Util.getJavaType(columnType);
          if (columnJavaType.equals(String.class)) {
            row.add(new Column<String>(columnLabel, resultSet.getString(columnLabel), columnType));
          } else if (columnJavaType.equals(Integer.class)) {
            row.add(new Column<Integer>(columnLabel, resultSet.getInt(columnLabel), columnType));
            row.add(new Column<Boolean>(columnLabel, resultSet.getBoolean(columnLabel), columnType));
          } else if (columnJavaType.equals(byte[].class)) {
            row.add(new Column<byte[]>(columnLabel, resultSet.getBytes(columnLabel), columnType));
          } else if (columnJavaType.equals(Long.class)) {
            row.add(new Column<Long>(columnLabel, resultSet.getLong(columnLabel), columnType));

代码示例来源：origin: azkaban/azkaban

@Override
 public List<Pair<String, Props>> handle(final ResultSet rs) throws SQLException {
  if (!rs.next()) {
   return Collections.emptyList();
  }
  final List<Pair<String, Props>> properties = new ArrayList<>();
  do {
   final String name = rs.getString(3);
   final int eventType = rs.getInt(5);
   final byte[] dataBytes = rs.getBytes(6);
   final EncodingType encType = EncodingType.fromInteger(eventType);
   String propertyString = null;
   try {
    if (encType == EncodingType.GZIP) {
     // Decompress the sucker.
     propertyString = GZIPUtils.unGzipString(dataBytes, "UTF-8");
    } else {
     propertyString = new String(dataBytes, "UTF-8");
    }
    final Props props = PropsUtils.fromJSONString(propertyString);
    props.setSource(name);
    properties.add(new Pair<>(name, props));
   } catch (final IOException e) {
    throw new SQLException(e);
   }
  } while (rs.next());
  return properties;
 }
}

代码示例来源：origin: wildfly/wildfly

private static String getStringColumn(ResultSetMetaData metaData, ResultSet resultSet, int column) throws SQLException {
  if (column == -1) return null;
  final int columnType = metaData.getColumnType(column);
  switch (columnType) {
    case Types.BINARY:
    case Types.VARBINARY:
    case Types.LONGVARBINARY: {
      return new String(resultSet.getBytes(column), StandardCharsets.UTF_8);
    }
    case Types.CHAR:
    case Types.LONGVARCHAR:
    case Types.LONGNVARCHAR:
    case Types.VARCHAR:
    case Types.NVARCHAR: {
      return resultSet.getString(column);
    }
    default: {
      final Object object = resultSet.getObject(column);
      if (object instanceof byte[]) {
        return new String((byte[]) object, StandardCharsets.UTF_8);
      } else if (object instanceof String) {
        return (String) object;
      } else {
        return null;
      }
    }
  }
}

代码示例来源：origin: debezium/debezium

public boolean next() throws SQLException {
  completed = !resultSet.next();
  currentChangePosition = completed ? TxLogPosition.NULL : TxLogPosition.valueOf(Lsn.valueOf(resultSet.getBytes(COL_COMMIT_LSN)), Lsn.valueOf(resultSet.getBytes(COL_ROW_LSN)));
  if (completed) {
    LOGGER.trace("Closing result set of change tables for table {}", changeTable);
    resultSet.close();
  }
  return !completed;
}

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

resultset

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    ResultSet类方法

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