备案控制台
开发者社区 数据库 文章 正文

Java中将byte[]转为Blob对象

2017-11-14 4165
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
准备先把以前写的持久层及表示层框架写完再写loonframework-game包(实际上是想自己业余建站用，用现成的框架太无聊，重复发明轮子的最 大意义就在于解闷……)，在2005年时写过一个开头，由于自己没有整理文档，现在拿起来就觉得代码很乱，又懒于写文档，于是把一些心得类的东西整理一 下，用以备忘。

在此持久层框架中，我将持久化过程分为两个松耦合模块，第一模块封装jdbc操作，隐藏Connection及相关事务，处理driver差异后执行标准CRUD并释放资源，于第二模块进行实体映射操作。

但 和Spring JdbcTemplate等jdbc封装略有不同的是，我除了直接将结果集转为List和实体返回外，还引入了一个类似CachedRowSet但非继承 CachedRowSet或ResultSet的结果集cache实体（没有提供诸如CachedRowSet的execute功能，原因大家都知 道……PS:05年我用Hibernate还比较少，现在看来和Hierbante的ScrollableResults接口超级类似，颇感java技术 殊途同归|||）。

但在此类get数据时，由于我将所有ResultSet数据无差别以object方式存储，当object为二进制对象时，为实现blob和clob接口就需要进行数据转换，将二进制对象转为blob或clob实现，为此完成代码如下。

比较hibernate的blobimpl而言（hibernate的blobimpl只有getBinaryStream()实现，因为别的对它也没用……），实现了更多的函数以供调用。 

BlobImpl.java
package  org.loon.framework.dao.lob;

 import  java.io.BufferedInputStream;
 import  java.io.ByteArrayInputStream;
 import  java.io.ByteArrayOutputStream;
 import  java.io.IOException;
 import  java.io.InputStream;

 import  java.io.OutputStream;
 import  java.sql.Blob;
 import  java.sql.SQLException;

 import  org.loon.framework.Loon;
 import  org.loon.framework.helper.FileHelper;

 /**
 * <p>
 * Title: LoonFramework
 * </p>
 * <p>
 * Description:二进制大对象Blob实现，用于转化二进制对象为blob实例，只提供get部分方法(虽然象征性的写了
 * set实现，但没有对数据库进行操作，只是摆设……).
 * </p>
 * <p>
 * Copyright: Copyright (c) 2007
 * </p>
 * <p>
 * Company: LoonFramework
 * </p>
 * <p>
 * License: [url]http://www.apache.org/licenses/LICENSE-2.0[/url]
 * </p>
 * 
 * @author chenpeng
 * @email：[email]ceponline@yahoo.com.cn[/email]
 * @version 0.1
 */
public   class  BlobImpl  implements  Blob  {


    private byte[] _bytes = new byte[0];

    private int _length = 0;

    /**
     * 构造函数，以byte[]构建blob
     * 
     * @param bytes
     */
    public BlobImpl(byte[] bytes) {
        init(bytes);
    }

    /**
     * 构造函数，以InputStream构建blob
     * 
     * @param bytes
     */
    public BlobImpl(InputStream input) {
        init(FileHelper.read(input));
    }

    /**
     * 构造函数，以blob重新构建blob
     * 
     * @param bytes
     */
    public BlobImpl(Blob blob) {
        init(blobToBytes(blob));
    }

    /**
     * 初始化byte[]
     * 
     * @param b
     */
    private void init(byte[] bytes) {
        _bytes = bytes;
        _length = _bytes.length;
    }

    /**
     * 将blob转为byte[]
     * 
     * @param blob
     * @return
     */
    private byte[] blobToBytes(Blob blob) {
        BufferedInputStream is = null;
        try {
            is = new BufferedInputStream(blob.getBinaryStream());
            byte[] bytes = new byte[(int) blob.length()];
            int len = bytes.length;
            int offset = 0;
            int read = 0;
            while (offset < len
                    && (read = is.read(bytes, offset, len - offset)) >= 0) {
                offset += read;
            }
            return bytes;
        } catch (Exception e) {
            return null;
        } finally {
            try {
                is.close();
                is = null;
            } catch (IOException e) {
                return null;
            }

        }
    }

    /**
     * 获得blob中数据实际长度
     * 
     * @return
     * @throws SQLException
     */
    public long length() throws SQLException {
        return _bytes.length;
    }

    /**
     * 返回指定长度的byte[]
     * 
     * @param pos
     * @param len
     * @return
     * @throws SQLException
     */
    public byte[] getBytes(long pos, int len) throws SQLException {
        if (pos == 0 && len == length())
            return _bytes;
        try {
            byte[] newbytes = new byte[len];
            System.arraycopy(_bytes, (int) pos, newbytes, 0, len);
            return newbytes;
        } catch (Exception e) {
            throw new SQLException("Inoperable scope of this array");
        }
    }

    /**
     * 返回InputStream
     * 
     * @return
     * @throws SQLException
     */
    public InputStream getBinaryStream() throws SQLException {
        return new ByteArrayInputStream(_bytes);
    }

    /**
     * 获取此byte[]中start的字节位置
     * 
     * @param pattern
     * @param start
     * @return
     * @throws SQLException
     */
    public long position(byte[] pattern, long start) throws SQLException {
        start--;
        if (start < 0) {
            throw new SQLException("start < 0");
        }
        if (start >= _length) {
            throw new SQLException("start >= max length");
        }
        if (pattern == null) {
            throw new SQLException("pattern == null");
        }
        if (pattern.length == 0 || _length == 0 || pattern.length > _length) {
            return -1;
        }
        int limit = (int) _length - pattern.length;
        for (int i = (int) start; i <= limit; i++) {
            int p;
            for (p = 0; p < pattern.length && _bytes[i + p] == pattern[p]; p++) {
                if (p == pattern.length) {
                    return i + 1;
                }
            }
        }
        return -1;
    }

    /**
     * 获取指定的blob中start的字节位置
     * 
     * @param pattern
     * @param start
     * @return
     * @throws SQLException
     */
    public long position(Blob pattern, long start) throws SQLException {
        return position(blobToBytes(pattern), start);
    }

    /**
     * 不支持操作异常抛出
     * 
     */
    void nonsupport() {
        throw new UnsupportedOperationException("This method is not supported！");
    }

    /**
     * 释放Blob对象资源
     * 
     * @throws SQLException
     */
    public void free() throws SQLException {
        _bytes = new byte[0];
        _length = 0;
    }

    /**
     * 返回指定长度部分的InputStream，并返回InputStream
     * 
     * @param pos
     * @param len
     * @return
     * @throws SQLException
     */
    public InputStream getBinaryStream(long pos, long len) throws SQLException {
        return new ByteArrayInputStream(getBytes(pos, (int) len));
    }

    /**
     * 以指定指定长度将二进制流写入OutputStream，并返回OutputStream
     * 
     * @param pos
     * @return
     * @throws SQLException
     */
    public OutputStream setBinaryStream(long pos) throws SQLException {
        // 暂不支持
        nonsupport();
        pos--;
        if (pos < 0) {
            throw new SQLException("pos < 0");
        }
        if (pos > _length) {
            throw new SQLException("pos > length");
        }
        // 将byte[]转为ByteArrayInputStream
        ByteArrayInputStream inputStream = new ByteArrayInputStream(_bytes);
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        byte[] bytes = new byte[(int) pos];
        try {
            bytes = new byte[inputStream.available()];
            int read;
            while ((read = inputStream.read(bytes)) >= 0) {
                os.write(bytes, 0, read);
            }

        } catch (IOException e) {
            e.getStackTrace();
        }

        // 返回OutputStream
        return (OutputStream) os;
    }

    /**
     * 设定byte[]
     * 
     * @param pos
     * @param bytes
     * @param offset
     * @param size
     * @param copy
     * @return
     * @throws SQLException
     */
    private int setBytes(long pos, byte[] bytes, int offset, int size,
            boolean copy) throws SQLException {
        // 暂不支持
        nonsupport();
        pos--;
        if (pos < 0) {
            throw new SQLException("pos < 0");
        }
        if (pos > _length) {
            throw new SQLException("pos > max length");
        }
        if (bytes == null) {
            throw new SQLException("bytes == null");
        }
        if (offset < 0 || offset > bytes.length) {
            throw new SQLException("offset < 0 || offset > bytes.length");
        }
        if (size < 0 || pos + size > (long) Integer.MAX_VALUE
                || offset + size > bytes.length) {
            throw new SQLException();
        }
        // 当copy数据时
        if (copy) {
            _bytes = new byte[size];
            System.arraycopy(bytes, offset, _bytes, 0, size);
        } else { // 否则直接替换对象
            _bytes = bytes;
        }
        return _bytes.length;
    }

    /**
     * 设定指定开始位置byte[]
     * 
     * @param pos
     * @param bytes
     * @return
     * @throws SQLException
     */
    public int setBytes(long pos, byte[] bytes) throws SQLException {
        // 暂不支持
        nonsupport();
        return setBytes(pos, bytes, 0, bytes.length, true);
    }

    /**
     * 设定byte[]
     * 
     * @param pos
     * @param bytes
     * @param offset
     * @param len
     * @return
     * @throws SQLException
     */
    public int setBytes(long pos, byte[] bytes, int offset, int len)
            throws SQLException {
        // 暂不支持
        nonsupport();
        return setBytes(pos, bytes, offset, len, true);
    }

    /**
     * 截取相应部分数据
     * 
     * @param len
     * @throws SQLException
     */
    public void truncate(long len) throws SQLException {
        if (len < 0) {
            throw new SQLException("len < 0");
        }
        if (len > _length) {
            throw new SQLException("len > max length");
        }
        _length = (int) len;
    }

    public static void main(String[] args) {

        //获得一个指定文件的blob
        //PS:天地良心啊，没抄袭hibernate写法，无奈的写一样了，不过比他多实现了点方法……（还特意把函数改名，不然更像|||）……
        Blob blob = Loon.makeBlob("D:\test.txt"); 
        // 以byte[]获得blob实例
        //Blob blob = new BlobImpl(bytes);
        try {
            // getBytes测试
            // 取出0到blob结束范围的byte[]
            byte[] buffer = blob.getBytes(0, (int) blob.length());
            // 以gb2312编码将byte[]转为string显示
            System.out.println(new String(buffer, "gb2312"));

            // getBinaryStream测试
            BufferedInputStream is = new BufferedInputStream(blob
                    .getBinaryStream());
            buffer = new byte[(int) blob.length()];
            int len = buffer.length;
            int offset = 0;
            int read = 0;
            while (offset < len
                    && (read = is.read(buffer, offset, len - offset)) >= 0) {
                offset += read;
            }
            System.out.println(new String(buffer, "gb2312"));

            // getBinaryStream范围取值测试,取0to4的byte[]
            is = new BufferedInputStream(blob.getBinaryStream(0, 4));
            //将is转为byte[]后转为String显示
            System.out.println(FileHelper.readToString(is, "gb2312"));

        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}


本文转自 cping 51CTO博客，原文链接:http://blog.51cto.com/cping1982/130046


文章标签：
Java
数据库连接
Spring
数据库
存储
关键词：
Java对象
Java byte
byte java
Java blob
科技小能手
目录
相关文章
toKeep
|
17小时前
|
安全 Java 编译器
java中类与对象回顾总结-2
java中类与对象回顾总结
toKeep
16 3
toKeep
|
17小时前
|
Java 编译器
java中类与对象回顾总结-1
java中类与对象回顾总结
toKeep
14 3
桃李春风一杯酒
|
17小时前
|
Java
【专栏】Java反射机制，该机制允许程序在运行时获取类信息、动态创建对象、调用方法和访问属性
【4月更文挑战第27天】本文探讨了Java反射机制，该机制允许程序在运行时获取类信息、动态创建对象、调用方法和访问属性。反射通过Class、Constructor、Method和Field类实现。文中列举了反射的应用场景，如动态创建对象、调用方法、访问属性和处理注解，并提供了相关实例代码演示。
桃李春风一杯酒
31 4
秋说
|
17小时前
|
Java 编译器
【Java开发指南 | 第一篇】类、对象基础概念及Java特征
【Java开发指南 | 第一篇】类、对象基础概念及Java特征
秋说
9 4
长梦
|
17小时前
|
安全 Java 数据安全/隐私保护
Java一分钟之-Java反射机制：动态操作类与对象
【5月更文挑战第12天】本文介绍了Java反射机制的基本用法，包括获取Class对象、创建对象、访问字段和调用方法。同时，讨论了常见的问题和易错点，如忽略访问权限检查、未捕获异常以及性能损耗，并提供了相应的避免策略。理解反射的工作原理和合理使用有助于提升代码灵活性，但需注意其带来的安全风险和性能影响。
长梦
19 4
java开发-郭老师
|
17小时前
|
Java
【JAVA基础篇教学】第五篇：Java面向对象编程：类、对象、继承、多态
【JAVA基础篇教学】第五篇：Java面向对象编程：类、对象、继承、多态
java开发-郭老师
17 1
菜菜的后端私房菜
|
17小时前
|
缓存 Java 程序员
关于创建、销毁对象⭐Java程序员需要掌握的8个编程好习惯
关于创建、销毁对象⭐Java程序员需要掌握的8个编程好习惯
菜菜的后端私房菜
20 5
关于创建、销毁对象⭐Java程序员需要掌握的8个编程好习惯
toKeep
|
17小时前
|
Java
从源码出发：JAVA中对象的比较
从源码出发：JAVA中对象的比较
toKeep
19 3
长梦
|
17小时前
|
Java
Java一分钟之-类与对象：面向对象编程入门
【5月更文挑战第8天】本文为Java面向对象编程的入门指南，介绍了类与对象的基础概念、常见问题及规避策略。文章通过代码示例展示了如何定义类，包括访问修饰符的适当使用、构造器的设计以及方法的封装。同时，讨论了对象创建与使用时可能遇到的内存泄漏、空指针异常和数据不一致等问题，并提供了相应的解决建议。学习OOP需注重理论与实践相结合，不断编写和优化代码。
长梦
28 1
Yeats_Liao
|
17小时前
|
SQL Java 数据库连接
15：MyBatis对象关系与映射结构-Java Spring
15：MyBatis对象关系与映射结构-Java Spring
Yeats_Liao
31 4

热门文章

最新文章

  • 1
    Byte Hex CRC计算笔记
  • 2
    使用Redis进行Java缓存策略设计
  • 3
    Java语言开发的AI智慧导诊系统源码springboot+redis 3D互联网智导诊系统源码
  • 4
    【JAVA】Java 中什么叫单例设计模式？请用 Java 写出线程安全的单例模式
  • 5
    基于Java的公司员工工作日志办公系统的设计与实现(源码+lw+部署文档+讲解等)
  • 6
    【JAVA】线程的run()和start()有什么区别？
  • 7
    高德地图爬虫实践：Java多线程并发处理策略
  • 8
    [AIGC] 21世纪Java与Go的相爱相杀
  • 9
    Java多线程实战-CompletableFuture异步编程优化查询接口响应速度
  • 10
    打造个人的Minecraft服务器：Java+cpolar实现我的世界联机游戏
  • 1
    Java String应用与开发
    22
  • 2
    去哪儿网开源的一个对应用透明，无侵入的Java应用诊断工具
    18
  • 3
    【Java探索之旅】解密构造方法 对象初始化的关键一步
    17
  • 4
    【Java探索之旅】用面向对象的思维构建程序世界
    11
  • 5
    【Java探索之旅】基本类型与引用类型 数组的应用 二维数组
    14
  • 6
    【Java探索之旅】数组使用 初探JVM内存布局
    26
  • 7
    【Java探索之旅】方法重载 递归
    10
  • 8
    【Java探索之旅】运算符解密 位运算，移位运算
    22
  • 9
    【Java探索之旅】数据类型与变量 字面常量 整型变量
    23
  • 10
    【Java探索之旅】运算符解析 算术运算符，关系运算符
    23

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0

    • 相关实验场景

    更多
  • 基于ECS搭建Java Web开发环境
  • 使用Aliyun Java Intializr进行项目开发
  • 搭建Java Web开发环境
  • 部署基于Dragonwell的Java运行环境
  • 阿里云平台上进行Java程序的编译与运行
    • 下一篇
    2024年阿里云免费云服务器及学生云服务器申请教程参考