本文整理了Java中java.sql.ResultSet.getBlob
方法的一些代码示例,展示了ResultSet.getBlob
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ResultSet.getBlob
方法的具体详情如下:
包路径:java.sql.ResultSet
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!