java-web - Hibernate读取Mysql blob大字段数据

Question

1.项目中用到了oauth2.0东西(基于spring-security)，在mysql数据库中有几张简单的表，目前我需要读取其中一张表oauth_access_token。

2.表中有两个blob的大字段，大字段存储的是两种不同类的java对象
表结构:

CREATE TABLE `oauth_access_token` (
  `token_id` varchar(256) DEFAULT NULL,
  `token` blob,
  `authentication_id` varchar(256) DEFAULT NULL,
  `user_name` varchar(256) DEFAULT NULL,
  `client_id` varchar(256) DEFAULT NULL,
  `authentication` blob,
  `refresh_token` varchar(256) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

3.存储的类分别是springframework.security.oauth2.common.DefaultOAuth2AccessToken和.springframework.security.oauth2.provider.OAuth2Authentication

4.我想用Hibernate的SQLQuery去查询，请问如何设置返回的类型，我想查询出来后仍然将这两个字段的数据转换成对应的类型对象。

5.下面是我目前的做法，虽然成功的查询，但是返回的字符串数据有些乱码而且杂乱

@Transactional(readOnly=true)
    public List<OauthAccessToken> findTokenByUserNameOrClientId(){
        
        String queryString="select token_id as tokenId,token,authentication_id as authenticationId, "
                            + "user_name as userName,client_id as clientId,authentication, "
                            + "refresh_token as refreshToken "
                            + "from oauth_access_token ";
        
        SQLQuery query=this.getSession().createSQLQuery(queryString);
        query.addScalar("tokenId", StringType.INSTANCE);
        query.addScalar("token", StringType.INSTANCE);
        query.addScalar("authenticationId", StringType.INSTANCE);
        query.addScalar("userName", StringType.INSTANCE);
        query.addScalar("clientId", StringType.INSTANCE);
        query.addScalar("authentication", StringType.INSTANCE);
        query.addScalar("refreshToken", StringType.INSTANCE);
        
        query.setFirstResult(0);
        query.setMaxResults(10);
        
        List<Object>list=query.list();

6.断点调试看到的结果

Answer 1

已解決
1.首先設定回傳的類型為Blob根據不通的資料庫來的，我是mysql包下面的
query.addScalar("authentication", BlobType.INSTANCE);

2.然後取得大字段類型的時候需要轉換一下

//Hibernate 查询出来的不是Blob类的实例，而是一个代理的实例无法强转
        SerializableBlobProxy tokenProxy=(SerializableBlobProxy)Proxy.getInvocationHandler(ob[1]);
        SerializableBlobProxy authenticationProxy=(SerializableBlobProxy)Proxy.getInvocationHandler(ob[5]);
        Blob tokenBlob=(Blob)tokenProxy.getWrappedBlob();
        Blob authenticationBlob=(Blob)authenticationProxy.getWrappedBlob();

3.最後是將blob物件反序列化成具體的物件

ObjectInputStream tokenObject=new ObjectInputStream(blobMap.get("tokenBlob").getBinaryStream());
            ObjectInputStream authenticationObject=new ObjectInputStream(blobMap.get("authenticationBlob").getBinaryStream());
            DefaultOAuth2AccessToken token=(DefaultOAuth2AccessToken)tokenObject.readObject();
            OAuth2Authentication auhtentication=(OAuth2Authentication)authenticationObject.readObject();