バイナリ ストリームを取得すると、次の例外が発生します。
java.io.IOException: The stream is closed.
at com.microsoft.sqlserver.jdbc.BaseInputStream.checkClosed(SimpleInputStream.java:93)
at com.microsoft.sqlserver.jdbc.PLPInputStream.read(PLPInputStream.java:237)
at au.gov.vic.doi.tp.service.binary.dao.BinaryDAOImplTest.retrieveBinary(BinaryDAOImplTest.java:102)
私が使用しているのは、Hibernate 4.1.1、MS SQL Server 2008、および最新の MS SQL JDBC4 ドライバーです。次のカスタム マッピング タイプ 'BlobToStreamUserType' を使用して、SQL Blob (varchar(max)) から InputStream にマッピングします。Hibernate は、SQL BLOB を Java InputStream にマップするタイプを提供していないようです。MaterializedBlobType は、SQL BLOB を Java byte[] にマップするだけです。
「rs.getBinaryStream」を使用して、メモリにバッファリングされたストリームではなく、真のバイナリ ストリームを返します。その理由は、複数のユーザーが同時にアクセスするとメモリの問題が発生する大きな画像があるためです。
マイクロソフトによると
Microsoft ドライバーは、getBinaryStream に関して JDBC 仕様に従います => 注: 返されたストリーム内のすべてのデータは、>other 列の値を取得する前に読み取る必要があります。次に getter メソッドを呼び出すと、暗黙的にストリームが閉じられます。また、メソッド InputStream.available が呼び出されると、データが利用可能かどうかにかかわらず、ストリームは 0 を返す場合があります。
したがって、getBinaryStream は真のバイト ストリームを返すように設計されています。>メモリにバッファリングされていないバイトの真のストリームを返します。これは、サーバーの応答からネットワークからすぐに読み取られるストリームです。実装のすべてのバイトを取得するまで、contentDataResultSet を閉じることはできません。
休止状態のプロパティ 'hibernate.jdbc.use_streams_for_binary' を true と false に設定しようとしましたが、違いはありません。
これが私のコードです：
カスタム ユーザー タイプへのマッピングを示す画像エンティティ クラス。
import java.io.InputStream;
import java.util.Date;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.Id;
import javax.persistence.Table;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import org.hibernate.annotations.GenericGenerator;
import org.hibernate.annotations.Type;
import com.google.common.base.Objects;
@Entity
@DynamicInsert(false)
@DynamicUpdate(false)
@Table(name = "Binary")
public class Binary
{
.........
@Lob
@Column(name = "image")
@Type(type = "my.package.BlobToStreamUserType")
public InputStream getImageStream()
{
return this.imageStream;
}
}
ここに私のカスタムマッピングタイプがあります:
public class BlobToStreamUserType implements UserType
{
public int[] sqlTypes()
{
return new int[]
{ Types.BLOB };
}
public Class returnedClass()
{
return InputStream.class;
}
public Object nullSafeGet(final ResultSet rs, final String[] names, final SessionImplementor session,
final Object owner) throws HibernateException, SQLException
{
return rs.getBinaryStream(names[0]);
}
public void nullSafeSet(final PreparedStatement st, final Object value, final int index,
final SessionImplementor session) throws HibernateException, SQLException
{
if (value != null)
{
if (!InputStream.class.isAssignableFrom(value.getClass()))
{
throw new HibernateException(value.getClass().toString() + " cannot be cast to a java.IO.InputStream");
}
InputStream inStream = (InputStream) value;
st.setBinaryStream(index, inStream);
}
else
{
st.setBytes(index, null);
}
}
public boolean equals(final Object x, final Object y) throws HibernateException
{
return ObjectUtils.equals(x, y);
}
public int hashCode(final Object x) throws HibernateException
{
assert (x != null);
return x.hashCode();
}
public Object deepCopy(final Object value) throws HibernateException
{
return value;
}
public boolean isMutable()
{
return false;
}
public Object replace(final Object original, final Object target, final Object owner) throws HibernateException
{
return original;
}
public Serializable disassemble(final Object value) throws HibernateException
{
//disassemble() is only called when caching the data in the second-level cache
// also safe for mutable objects
throw new UnsupportedOperationException("Not supported yet.");
}
public Object assemble(final Serializable cached, final Object owner) throws HibernateException
{
throw new UnsupportedOperationException("Not supported yet.");
}
}
そして、これが画像ストリームを取得するための私のDAOです
public class BinaryDAOImpl extends AbstractSpringHibernateDAO implements BinaryDAO
{
public Binary getBinary(final String amsAssetId, final String assetMaintainer, final String variant,
final Integer sequence) throws GetException
{
try
{
Query query = super.getSession().createQuery(
"from Binary bin where bin.amsAssetId = :amsAssetId and bin.assetMaintainer = :assetMaintainer "
+ "and bin.variant = :variant and bin.sequence = :sequence");
query.setParameter("amsAssetId", amsAssetId);
query.setParameter("assetMaintainer", assetMaintainer);
query.setParameter("variant", variant);
query.setParameter("sequence", sequence);
return query.uniqueResult();
}
注意:休止状態をバイパスして結果セットから直接ストリームを取得する次の回避策は機能し、例外なくストリームを読み取ることができます。ただし、真のバイナリ ストリームを取得するには、休止状態のマッピングを使用したいと考えています。
変更された DAO メソッド
public Binary getBinary(final String amsAssetId, final String assetMaintainer, final String variant,
final Integer sequence) throws GetException
{
try
{
Query query = super.getSession().createQuery(
"from Binary bin where bin.amsAssetId = :amsAssetId and bin.assetMaintainer = :assetMaintainer "
+ "and bin.variant = :variant and bin.sequence = :sequence");
query.setParameter("amsAssetId", amsAssetId);
query.setParameter("assetMaintainer", assetMaintainer);
query.setParameter("variant", variant);
query.setParameter("sequence", sequence);
Binary binary = (Binary) query.uniqueResult();
final String id = binary.getId();
// Necessary until Hibernate supports InputStream mapping
binary.setImageStream(getSession().doReturningWork(new ReturningWork<InputStream>()
{
public InputStream execute(final Connection connection) throws SQLException
{
PreparedStatement statement = connection.prepareStatement("select image from Binary where id=?",
ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
statement.setString(1, id);
ResultSet resultSet = statement.executeQuery();
return (resultSet.first() ? resultSet.getBinaryStream(1) : null);
}
}));
return binary;
}