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

JDBC操作DB2 Clob、Blob字段的Bug探究

2017-11-21 1792
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
J2EE的开发之路布满了陷阱，相信很多人都深有体会。
 
IBM的东西就是傻大笨粗，巨难用！！！
最近再用JDBC操作DB2的Clob和Blob时候出现了些问题：
我用的是DB2 V9安装程序自带的驱动，相传DB2驱动很多，这个最常用，也是最规范一个。
 
我用的驱动名字如下：
db2jcc.jar
db2jcc_license_cisuz.jar
db2jcc_license_cu.jar
 
Clob出现的问题：写入Clob没有问题，读取出问题。
Blob出现的问题：都写通常情况下没有问题。但当同时写入Data和Blob字段时候，会出问题。（一个例子中遇到的，不足以给出肯定结果）。
 
抛出的异常代码如下：
com.ibm.db2.jcc.c.SqlException
 at com.ibm.db2.jcc.c.ec.<init>(ec.java:183)
 at com.ibm.db2.jcc.b.d.b(d.java:1328)
 at com.ibm.db2.jcc.c.s.a(s.java:748)
 at com.ibm.db2.jcc.c.s.U(s.java:1393)
 at com.ibm.db2.jcc.c.wf.getClob(wf.java:914)
 ......
 

为测试搭建环境：
CREATE  TABLE ZFZVF.T_LOB ( 
   NAME  VARCHAR(24), 
  TXT CLOB(2M) LOGGED  NOT COMPACT, 
  IMG BLOB(2M) LOGGED  NOT COMPACT 
); 
 
DROP  TABLE ZFZVF.NJ_GT; 
COMMIT; 
CREATE  TABLE ZFZVF.NJ_GT ( 
  ID  BIGINT, 
  ZTBS  BIGINT, 
  NJBS  BIGINT, 
  ND  VARCHAR(4), 
  NJNR BLOB(2M) LOGGED  NOT COMPACT, 
  SJC  TIMESTAMP 
); 
COMMIT; 
COMMENT  ON  TABLE ZFZVF.NJ_GT  IS  '年检_个体'; 
COMMENT  ON ZFZVF.NJ_GT ( 
  ID  IS  'ID', 
ZTBS  IS  '主体BS', 
NJBS  IS  '年检BS', 
ND  IS  '年度', 
NJNR  IS  '年检内容', 
SJC  IS  '时间戳' ); 
COMMIT;


例子如下：
package lob;  

import java.io.*;  
import java.sql.*;  

/**  
* DB2 Clob、Blob Bug探究  
* File: TestLob4DB2.java  
* User: leizhimin  
* Date: 2008-3-3 8:56:00  
*/  
public  class TestLob4DB2{  
     public  static  final String url =  "jdbc:db2://127.0.0.1:50000/zfzvf";  
    public static final String username = "zfzvf";  
    public static final String password = "zfzvfdb2";  
    public static final String driverClassName = "com.ibm.db2.jcc.DB2Driver";  

    /**  
     * 获取数据库连接Connection  
     *  
     * @return 数据库连接Connection  
     */  
    public static Connection makeConnection() {  
        Connection conn = null;  
        try {  
            Class.forName(driverClassName);  
        } catch (ClassNotFoundException e) {  
            e.printStackTrace();  
        }  
        try {  
            conn = DriverManager.getConnection(url, username, password);  
        } catch (SQLException e) {  
            e.printStackTrace();  
        }  
        return conn;  
    }  

    /**  
     * 测试连接  
     */  
    public static void testConnection() {  
        Connection conn = makeConnection();  
        try {  
            Statement stmt = conn.createStatement();  
            ResultSet rs = stmt.executeQuery("SELECT * FROM ZFZVF.DM_HYML");  
            while (rs.next()) {  
                String s1 = rs.getString(1);  
                String s2 = rs.getString(2);  
                System.out.println(s1 + s2);  
            }  
            rs.close();  
            stmt.close();  
        } catch (SQLException e) {  
            e.printStackTrace();  
        } finally {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  

    /**  
     * 插入文件测试  
     */  
    public static void testInsertlob() {  
        Connection conn = makeConnection();  
        try {  
            conn.setAutoCommit(false);  
            File txtFile = new File("C:\\txt.txt");  
            File imgFile = new File("C:\\img.png");  
            int txt_len = (int) txtFile.length();  
            int img_len = (int) imgFile.length();  
            try {  
                InputStream fis1 = new FileInputStream(txtFile);  
                InputStream fis2 = new FileInputStream(imgFile);  
                PreparedStatement pstmt = conn.prepareStatement("INSERT INTO ZFZVF.T_LOB(NAME,TXT,IMG) VALUES('G',?,?)");  
                pstmt.setAsciiStream(1, fis1, txt_len);  
                pstmt.setBinaryStream(2, fis2, img_len);  
                pstmt.executeUpdate();  
                conn.commit();  
            } catch (FileNotFoundException e) {  
                e.printStackTrace();  
            }  
        } catch (SQLException e) {  
            e.printStackTrace();  
        } finally {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  

    /**  
     * 查询DB2 Clob测试 ,会抛出异常  
     */  
    public static void testQueryLob() {  
        Connection conn = makeConnection();  
        try {  
            conn.setAutoCommit(true);  
            PreparedStatement stmt = conn.prepareStatement("SELECT TXT,IMG FROM ZFZVF.T_LOB");  
            ResultSet rs = stmt.executeQuery();  
            while (rs.next()) {  
                Clob clob = rs.getClob("TXT");  
                Blob blob = rs.getBlob("IMG");  
                InputStreamReader ir = (InputStreamReader) clob.getCharacterStream();  
                File fileOutput = new File("C:\\txt_1.txt");  
                FileOutputStream fo = new FileOutputStream(fileOutput);  
                int c;  
                while ((c = ir.read()) != -1) {  
                    fo.write(c);  
                    break;  
                }  
                fo.close();  
            }  
        } catch (SQLException e) {  
            e.printStackTrace();  
        } catch (IOException e) {  
            e.printStackTrace();  
        } finally {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  

    /**  
     * 查询DB2 Blob测试  
     */  
    public static void testBlobQuery() {  
        Connection conn = makeConnection();  
        try {  
            conn.setAutoCommit(true);  
            PreparedStatement stmt = conn.prepareStatement("SELECT img FROM ZFZVF.T_LOB");  
            ResultSet rs = stmt.executeQuery();  
            int i = 0;  
            while (rs.next()) {  
                Blob blob = rs.getBlob(1);  
                InputStream inputStream = blob.getBinaryStream();  
                File fileOutput = new File("c:\\str_x" + i + ".txt");  
                FileOutputStream fo = new FileOutputStream(fileOutput);  
                int c;  
                while ((c = inputStream.read()) != -1)  
                    fo.write(c);  
                fo.close();  
                System.out.println("Blob " + i + "  retrieved!!");  
                i++;  
            }  
        } catch (SQLException e) {  

        } catch (FileNotFoundException e) {  
            e.printStackTrace();  
        } catch (IOException e) {  
            e.printStackTrace();  
        } finally {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  
    }  

    /**  
     * 查询DB2 Clob测试 ,会抛出异常  
     */  
    public static void testClobQuery() {  
        Connection conn = makeConnection();  
        try {  
            conn.setAutoCommit(false);  
            PreparedStatement stmt = conn.prepareStatement("SELECT TXT FROM ZFZVF.T_LOB");  
            ResultSet rs = stmt.executeQuery();  
            conn.commit();  
            while (rs.next()) {  
                Clob clob = rs.getClob(1);  
                InputStream is = clob.getAsciiStream();  
                File fileOutput = new File("C:\\ttttt.txt");  
                FileOutputStream fo = new FileOutputStream(fileOutput);  
                int c;  
                while ((c = is.read()) != -1)  
                    fo.write(c);  
                fo.close();  
                break;  
            }  
        } catch (SQLException e) {  
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.  
        } catch (FileNotFoundException e) {  
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.  
        } catch (IOException e) {  
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.  
        } finally {  
            try {  
                conn.close();  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
        }  

    }  

    public static void main(String args[]) {  
        testConnection();  
        testInsertlob();  
//        testQueryLob();  
        testBlobQuery();  
       testClobQuery();  

    }  
}
 
一一运行各个测试方法，可以看到操作Clob时候抛出了异常。
 
由于DB2驱动比较多，而一般都用测试用的这个驱动做开发，因此我也没有尝试用别的驱动了。对于这个问题，我自己用Blob来存储本应用Clob来处理的字段，也就是将原Clob定义为Blob，通过Blob来操作。具体代码就不赘述了。
 
由于大量使用Blob，又从中发现个问题，就是日期和Blob同时插入时会出一些问题。有兴趣的博友可以尝试尝试，最近很忙，也没有那么精力去细究。希望IBM能尽快解决这些问题。
 
本文转自 leizhimin 51CTO博客，原文链接：http://blog.51cto.com/lavasoft/64683，如需转载请自行联系原作者
文章标签：
Java
关系型数据库
数据库连接
存储
开发框架
关键词：
jdbc操作
jdbc字段
jdbc blob
jdbc clob
jdbc blob字段
技术小阿哥
目录
相关文章
程序三两行
|
7月前
|
SQL Java 数据库连接
java使用jdbc操作数据库
java使用jdbc操作数据库
程序三两行
88 2
飞翔的佩奇
|
7月前
|
Java 数据库 数据安全/隐私保护
基于JavaSE+JDBC使用控制台操作的简易购物系统【源码+数据库】
基于JavaSE+JDBC使用控制台操作的简易购物系统【源码+数据库】
飞翔的佩奇
99 0
阿甘兄
|
SQL Java 数据库连接
Hive教程（08）- JDBC操作Hive
Hive教程（08）- JDBC操作Hive
阿甘兄
946 0
ha_lydms
|
SQL 存储 Java
原生Jdbc获取库、表、字段
原生Jdbc获取库、表、字段
ha_lydms
143 0
苍何
|
SQL Java 关系型数据库
JDBC操作数据库
JDBC是实现java程序对各种数据库的访问，是一组类和接口，位于java.sql与javax.sql包
苍何
55 0
念君思宁
|
SQL Java 关系型数据库
Java的JDBC编程＜-----用Java代码操作数据库（MySQL数据库）
Java的JDBC编程＜-----用Java代码操作数据库（MySQL数据库）
念君思宁
61 0
嘟嘟嘟嘟嘟嘟
|
7月前
|
Java 关系型数据库 数据库连接
实时计算 Flink版操作报错之在使用JDBC连接MySQL数据库时遇到报错，识别不到jdbc了，怎么解决
在使用实时计算Flink版过程中，可能会遇到各种错误，了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题，查看Flink的日志是关键，它们通常会提供更详细的错误信息和堆栈跟踪，有助于定位问题。此外，Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
嘟嘟嘟嘟嘟嘟
281 2
闫嘉辉
|
7月前
|
SQL Java 数据库连接
Java JDBC连接与操作深度解析
Java JDBC连接与操作深度解析
闫嘉辉
53 1
好奇的菜鸟
|
6月前
|
SQL Java 数据库连接
使用Python通过JDBC操作数据库(达梦数据库)
使用Python通过JDBC操作数据库(达梦数据库)
好奇的菜鸟
949 0
芯在这
|
7月前
|
Java 数据库连接 数据库
实时计算 Flink版操作报错合集之flink jdbc写入数据时，长时间没写入后报错，是什么原因导致的
在使用实时计算Flink版过程中，可能会遇到各种错误，了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题，查看Flink的日志是关键，它们通常会提供更详细的错误信息和堆栈跟踪，有助于定位问题。此外，Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
芯在这
228 9

热门文章

最新文章

  • 1
    聊聊 Sharding-JDBC 分库分表
  • 2
    JDK6笔记（6）----JDBC4.0高级应用(2)
  • 3
    使用JDBC获取各数据库的Meta信息——表以及对应的列
  • 4
    利用JDBC-ODBC驱动访问SQL SERVER2008
  • 5
    Maven仓库添加Oracle JDBC驱动
  • 6
    JDBC调用MySQL5存储过程
  • 7
    OAF_JDBC系列2 - 通过JDBC连接SQLSERVER数据库DriverManager.getConnection
  • 8
    使用JDBC连接MySQL数据库
  • 9
    SoapUI Pro Project Solution Collection-DataSource(jdbc,excel)
  • 10
    hibernate错误：IllegalArgumentException以及Could not execute JDBC batch update
  • 1
    【服务器】python通过JDBC连接到位于Linux远程服务器上的Oracle数据库
    107
  • 2
    零基础轻松入门Java数据库连接（JDBC）
    65
  • 3
    c.t.t.handler.GlobalExceptionHandler : 捕获异常：org.springframework.jdbc.BadSqlGrammarException:
    61
  • 4
    JDBC编程
    56
  • 5
    JDBC Java标准库提供的一些api(类+方法) 统一各种数据库提供的api
    58
  • 6
    Scala应用 —— JDBC的创建
    100
  • 7
    Springboot框架整合Spring JDBC操作数据
    92
  • 8
    启动项目出现com.mysql.jdbc.exceptions.jdbc4.MySQLNonTransientConnectionException异常解决方法
    80
  • 9
    JDBC实现往MySQL插入百万级数据
    67
  • 10
    JDBC批量插入mysql数据
    64

    • 相关课程

    更多
  • JDBC数据库开发入门
  • JDBC数据库开发进阶
  • 数据库及SQL/MySQL基础

    • 相关电子书

    更多
  • PostgresChina2018_赖思超_PostgreSQL10_hash索引的WAL日志修改版final
  • 从理论到实践，深度解析MySQL Group Replication
  • PostgresChina2018_董红禹_SQL_Server迁移PG经验分享

    • 相关实验场景

    更多
  • 使用SQL语句实现数据插入、修改和删除操作
  • SQL进阶之约束、索引
    • 下一篇
    DataWorks售前咨询