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

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

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

ResultSet.getBlob介绍

[英]Gets the value of a column specified by column index as a java.sql.Blob object.
[中]获取列索引指定为java的列的值。sql。水滴状物体。

代码示例

代码示例来源:origin: alibaba/druid

public InputStream getBlobAsBinaryStream(ResultSet rs, int columnIndex) throws SQLException {
  Blob blob = rs.getBlob(columnIndex);
  if (blob == null) {
    return null;
  }
  return blob.getBinaryStream();
}

代码示例来源:origin: oblac/jodd

/**
 * {@inheritDoc}
 */
@Override
public Blob get(final ResultSet rs, final int index, final int dbSqlType) throws SQLException {
  return rs.getBlob(index);
}

代码示例来源:origin: requery/requery

@Override
public Blob fromResult(ResultSet results, int column) throws SQLException {
  return results.getBlob(column);
}

代码示例来源:origin: spring-projects/spring-framework

@Override
@Nullable
public InputStream getBlobAsBinaryStream(ResultSet rs, int columnIndex) throws SQLException {
  logger.debug("Returning BLOB as binary stream");
  if (this.wrapAsLob) {
    Blob blob = rs.getBlob(columnIndex);
    return blob.getBinaryStream();
  }
  else {
    return rs.getBinaryStream(columnIndex);
  }
}

代码示例来源:origin: alibaba/druid

public byte[] getBlobAsBytes(ResultSet rs, int columnIndex) throws SQLException {
  Blob blob = rs.getBlob(columnIndex);
  if (blob == null) {
    return null;
  }
  return blob.getBytes(1, (int) blob.length());
}

代码示例来源:origin: querydsl/querydsl

@Override
public Blob getBlob(int columnIndex) throws SQLException {
  return rs.getBlob(columnIndex);
}

代码示例来源:origin: spring-projects/spring-framework

@Override
@Nullable
public byte[] getBlobAsBytes(ResultSet rs, int columnIndex) throws SQLException {
  logger.debug("Returning BLOB as bytes");
  if (this.wrapAsLob) {
    Blob blob = rs.getBlob(columnIndex);
    return blob.getBytes(1, (int) blob.length());
  }
  else {
    return rs.getBytes(columnIndex);
  }
}

代码示例来源:origin: alibaba/druid

@Override
public Blob getBlob(int columnIndex) throws SQLException {
  try {
    return rs.getBlob(columnIndex);
  } catch (Throwable t) {
    throw checkException(t);
  }
}

代码示例来源:origin: alibaba/druid

@Override
public Blob getBlob(String columnLabel) throws SQLException {
  try {
    return rs.getBlob(columnLabel);
  } catch (Throwable t) {
    throw checkException(t);
  }
}

代码示例来源:origin: hibernate/hibernate-orm

@Override
protected X doExtract(ResultSet rs, String name, WrapperOptions options) throws SQLException {
  return javaTypeDescriptor.wrap( rs.getBlob( name ), options );
}

代码示例来源:origin: apache/kylin

private InputStream getInputStream(String resPath, ResultSet rs) throws SQLException, IOException {
  if (rs == null) {
    return null;
  }
  Blob blob = rs.getBlob(META_TABLE_CONTENT);
  if (blob == null || blob.length() == 0) {
    return openPushdown(resPath); // empty bytes is pushdown indicator
  } else {
    return blob.getBinaryStream();
  }
}

代码示例来源:origin: apache/ignite

@Override public void run() throws Exception {
    rs.getBlob(1);
  }
});

代码示例来源:origin: apache/ignite

@Override public void run() throws Exception {
    rs.getBlob("id");
  }
});

代码示例来源:origin: org.apache.ant/ant

private void printValue(ResultSet rs, int col, PrintStream out)
    throws SQLException {
  if (rawBlobs && rs.getMetaData().getColumnType(col) == Types.BLOB) {
    Blob blob = rs.getBlob(col);
    if (blob != null) {
      new StreamPumper(rs.getBlob(col).getBinaryStream(), out).run();
    }
  } else {
    out.print(maybeQuote(rs.getString(col)));
  }
}

代码示例来源:origin: alibaba/druid

@Override
public Blob resultSet_getBlob(ResultSetProxy resultSet, int columnIndex) throws SQLException {
  if (this.pos < filterSize) {
    return nextFilter().resultSet_getBlob(this, resultSet, columnIndex);
  }
  return resultSet.getResultSetRaw().getBlob(columnIndex);
}

代码示例来源:origin: alibaba/druid

@Override
public Blob resultSet_getBlob(ResultSetProxy resultSet, String columnLabel) throws SQLException {
  if (this.pos < filterSize) {
    return nextFilter().resultSet_getBlob(this, resultSet, columnLabel);
  }
  return resultSet.getResultSetRaw().getBlob(columnLabel);
}

代码示例来源:origin: hibernate/hibernate-orm

@Override
protected X doExtract(ResultSet rs, String name, WrapperOptions options) throws SQLException {
  Blob rsBlob = rs.getBlob( name );
  if ( rsBlob == null || rsBlob.length() < HANAStreamBlobTypeDescriptor.this.maxLobPrefetchSize ) {
    return javaTypeDescriptor.wrap( rsBlob, options );
  }
  Blob blob = new MaterializedBlob( DataHelper.extractBytes( rsBlob.getBinaryStream() ) );
  return javaTypeDescriptor.wrap( blob, options );
}

代码示例来源:origin: hibernate/hibernate-orm

@Override
protected X doExtract(ResultSet rs, String name, WrapperOptions options) throws SQLException {
  Blob rsBlob = rs.getBlob( name );
  if ( rsBlob == null || rsBlob.length() < HANABlobTypeDescriptor.this.maxLobPrefetchSize ) {
    return javaTypeDescriptor.wrap( rsBlob, options );
  }
  Blob blob = new MaterializedBlob( DataHelper.extractBytes( rsBlob.getBinaryStream() ) );
  return javaTypeDescriptor.wrap( blob, options );
}

代码示例来源:origin: nutzam/nutz

public Object get(ResultSet rs, String colName) throws SQLException {
  Blob blob = rs.getBlob(colName);
  if (blob == null)
    return null;
  File f = this.createTempFile();
  Files.write(f, blob.getBinaryStream());
  return new SimpleBlob(f);
}

代码示例来源:origin: nutzam/nutz

public Object get(ResultSet rs, int columnIndex) throws SQLException {
  Blob blob = rs.getBlob(columnIndex);
  if (blob == null)
    return null;
  File f = this.createTempFile();
  Files.write(f, blob.getBinaryStream());
  return new SimpleBlob(f);
}

相关文章

微信公众号

最新文章

更多

ResultSet类方法