return bt;

       }

............

    try {

       String sql =  "{? = call BLOB_PKG_XXX.QUERY_BLOB()} ";

       //取得数据库连接

       Connection conn = dao.createCoon();

       CallableStatement proc = conn.prepareCall(sql);

        //设置返回对象类型为结果集

       proc.registerOutParameter(1, OracleTypes.CURSOR);

        //执行存储过程

       proc.execute();

        //获得结果集

       ResultSet rset = (ResultSet) proc.getObject(1);

       while (rset.next()) {

            //获得结果集中的BLOB对象

           BLOB blob = (BLOB) rset.getBlob(BLOB_ROW_XX);

           byte[] bt = dao.getBlobBytes(blob);

       }

//释放连接     

       proc.close();

       conn.close();

    } catch (NamingException e) {

       e.printStackTrace();

    } catch (SQLException e) {

       e.printStackTrace();

    } catch (Exception e) {

       e.printStackTrace();

    }

............

上一页  [1] [2]