&>&&>&&>&&>&如何将DB2数据库中的大对象(BLOB,CLOB)数据类型复制到Oracle数据库中
如何将DB2数据库中的大对象(BLOB,CLOB)数据类型复制到Oracle数据库中
上传大小：91KB
[问题描述]
WII中对LOB对象的复制支持仅限于DB2的数据库。具体的限制请参考：
http://publib./infocenter/db2luw/v8//topic/com.ibm.db2.ii.doc/admin/te0dt000.htm#te0dtrlo
对非DB2数据库的数据复制, 不直接支持LOB(BLOB,ClOB)等大对象数据类型，但在实际应用中,用户需要复制的表中有可能有BLOB等大对象数据,如果数据目标为Oracle,这类大对象复制的需求可通过对WII的复制进行特殊配置实现。下面以一个实际的例子来说明如何将DB2中的BLOB数据类型复制到Oracle中。...展开收缩
综合评分：4.2（5位用户评分）
所需积分：1
下载次数：36
审核通过送C币
创建者：qq_
创建者：nigelyq
创建者：ccbhnldlrb
课程推荐相关知识库
上传者其他资源上传者专辑
数据库热门标签
VIP会员动态
spring mvc+mybatis+mysql+maven+bootstrap 整合实现增删查改简单实例.zip
CSDN&vip年卡&4000万程序员的必选
如何将DB2数据库中的大对象(BLOB,CLOB)数据类型复制到Oracle数据库中
会员到期时间：剩余下载次数：
积分不足！
资源所需积分
当前拥有积分
您可以选择
程序员的必选
绿色安全资源
资源所需积分
当前拥有积分
VIP年卡全年1200次免积分下载
你当前的下载分为234。
如何将DB2数据库中的大对象(BLOB,CLOB)数据类型复制到Oracle数据库中
会员到期时间：
剩余下载次数：
你还不是VIP会员
开通VIP会员权限，免积分下载
你下载资源过于频繁，请输入验证码
你下载资源过于频繁，请输入验证码
您因违反CSDN下载频道规则而被锁定帐户，如有疑问，请联络:!
若举报审核通过，可奖励20下载分
被举报人：
举报的资源分：
请选择类型
资源无法下载
资源无法使用
标题与实际内容不符
含有危害国家安全内容
含有反动色情等内容
含广告内容
版权问题，侵犯个人或公司的版权
*详细原因：2003年5月 DB2大版内专家分月排行榜第二
2003年5月 DB2大版内专家分月排行榜第二
本帖子已过去太久远了，不再提供回复功能。2270人阅读
oracle（3）
oracle/db2 数据库（5）
在项目中使用blob大字段来存储报文，最近有客户需要使用DB2数据库来部署应用，所有只得把oracle中初始化脚本导入到DB2中，在制作DB2的初始化脚本
怎么样把oracle中得含blob字段的表导入到DB2中呢，在网上转了一下没有发现，决定写程序解决
3.解决问题
使用JDBC连接先查出oracle中得表，然后插入到DB2中。先新建java project，然后添加oracle和DB2的驱动包，如下图：
DB2ConnectionFactory源码为：
package com.ylink.
import java.sql.C
import java.sql.DriverM
import java.sql.SQLE
public class DB2ConnectionFactory {
final static String DRIVER = &com.ibm.db2.jcc.DB2Driver&;
final static String CONSTR = &jdbc:db2://172.168.6.212:50000/tps&;
final static String USERNAME = &db2admin&;
final static String USERPASS = &db2admin&;
* 获得数据库连接
public static Connection getConnection(){
Connection con =
Class.forName(DRIVER);
con = DriverManager.getConnection(CONSTR,USERNAME,USERPASS);
con.setAutoCommit(false);
//设置不自动提交事务
}catch (SQLException e) {
System.out.println(&sql语句错误&+e.getMessage());
} catch (ClassNotFoundException e) {
System.out.println(e.getMessage());
IOperationCore接口源码为：
* 数据库常用操作封装
package com.ylink.
import java.lang.reflect.InvocationTargetE
import java.sql.ResultS
import java.sql.SQLE
import java.util.L
/** 类名：IOperationCore&br&
* 作用: 该接口封装了数据库操作的大部分方法&br&
public interface IOperationCore {
/** sql更新语句
* @param queryString 查询语句
* @return 返回一个&code&ResultSet&/code&结果集
* @exception SQLException */
ResultSet executeQuery(String queryString) throws SQLE
* sql更新语句
* @param updateString 数据库更新语句
* @return 更新数据库影响行数
* @exception SQLException */
int executeUpdate(String updateString) throws SQLE
@SuppressWarnings(&unchecked&)
public &T& List&T& queryForList(String sql, Class&T& clazz,
Object... params)throws SQLException, InstantiationException,
IllegalAccessException, InvocationTargetException,
ClassNotFoundE
* 释放系统连接资源
* @exception SQLException 如果关闭失败将抛出&code&SQLException&/code&*/
void dispose() throws SQLE
OperationCoreImpl源码为：
package com.ylink.
import java.lang.reflect.InvocationTargetE
import java.lang.reflect.M
import java.sql.C
import java.sql.PreparedS
import java.sql.ResultS
import java.sql.ResultSetMetaD
import java.sql.SQLE
import java.sql.S
import java.util.ArrayL
import java.util.L
* 类名：OperationCoreImplements&br&
* 作用: 该类实现IOperationCore接口的所有方法&br&
public class OperationCoreImpl implements IOperationCore {
protected Connection aConnection =
protected Statement ps =
protected ResultSet rs =
protected ResultSetMetaData rsmd =
protected static OperationCoreImpl m_instance =
* Singleton 即单例(态)模式,用来生成对象唯一实例的方法
* @return OperationCoreImplements的一个实例
* @throws Exception
public static OperationCoreImpl createFactory() throws Exception {
if (m_instance == null)
m_instance = new OperationCoreImpl();
/** @exception Exception */
public OperationCoreImpl() throws Exception {
private void init() throws Exception {
aConnection = OracleConnectionFactory.getConnection();
* 释放系统连接资源
public void dispose() {
if (rs != null)
rs.close();
} catch (SQLException e) {
e.printStackTrace();
if (ps != null)
ps.close();
} catch (SQLException e) {
e.printStackTrace();
if (aConnection != null)
aConnection.close();
} catch (SQLException e) {
e.printStackTrace();
* 返回ResultSet对象
* @param queryString
* @return 返回一个&code&ResultSet&/code&结果集
* @exception SQLException
public ResultSet executeQuery(String queryString) {
ps = aConnection.createStatement();
rs = ps.executeQuery(queryString);
} catch (SQLException e) {
e.printStackTrace();
//返回list通用
@SuppressWarnings(&unchecked&)
public &T& List&T& queryForList(String sql, Class&T& clazz,
Object... params) throws SQLException, InstantiationException,
IllegalAccessException, InvocationTargetException,
ClassNotFoundException {
if (clazz == null) {
throw new IllegalArgumentException(&clazz is null&);
ResultSet rs =
PreparedStatement ps =
List&T& resultList = new ArrayList&T&();
ps = aConnection.prepareStatement(sql);
if (params != null) {
for (int i = 0; i & params. i++) {
ps.setObject(i + 1, params[i]);
rs = ps.executeQuery();
Method[] allMethod = clazz.getMethods();
List&Method& setterMethodList = new ArrayList&Method&();
for (Method m : allMethod) {
if (m.getName().startsWith(&set&)) {
setterMethodList.add(m);
String columnName =
Class parameterType =
if (rs != null) {
while (rs.next()) {
t = clazz.newInstance();
for (Method m : setterMethodList) {
columnName = m.getName().substring(3, 4).toLowerCase()
+ m.getName()
.substring(4, m.getName().length());
parameterType = m.getParameterTypes()[0];
if (parameterType.isPrimitive()) {
if (parameterType == Boolean.TYPE) {
m.invoke(t, rs.getBoolean(columnName));
} else if (parameterType == Byte.TYPE) {
m.invoke(t, rs.getByte(columnName));
} else if (parameterType == Short.TYPE) {
m.invoke(t, rs.getShort(columnName));
} else if (parameterType == Character.TYPE) {
m.invoke(t, rs.getString(columnName).charAt(0));
} else if (parameterType == Integer.TYPE) {
m.invoke(t, rs.getInt(columnName));
} else if (parameterType == Long.TYPE) {
m.invoke(t, rs.getLong(columnName));
} else if (parameterType == Float.TYPE) {
m.invoke(t, rs.getFloat(columnName));
} else if (parameterType == Double.TYPE) {
m.invoke(t, rs.getDouble(columnName));
m.invoke(t, rs.getObject(columnName));
resultList.add(t);
return resultL
} finally {
dispose();
* 增、删、改操作
* @param updateString
数据库更新语句
* @return 更新数据库影响行数
* @exception SQLException
public int executeUpdate(String updateString) {
int effectedRows = 0;
aConnection.setAutoCommit(false);
ps = aConnection.createStatement();
effectedRows = ps.executeUpdate(updateString);
} catch (SQLException ex) {
System.out.println(&数据库写操作失败!&);
if (aConnection != null) {
aConnection.rollback();
System.out.println(&JDBC事务回滚成功&);
} catch (SQLException e) {
System.out.println(&JDBC事务回滚失败&);
e.printStackTrace();
return effectedR
OracleConnectionFactory源码为：
package com.ylink.
import java.sql.C
import java.sql.DriverM
import java.sql.SQLE
public class OracleConnectionFactory {
final static String DRIVER = &oracle.jdbc.driver.OracleDriver&;
final static String CONSTR = &jdbc:oracle:thin:@172.168.9.70:1521:tps&;
final static String USERNAME = &tps&;
final static String USERPASS = &tps&;
* 获得数据库连接
public static
Connection getConnection(){
Connection con =
Class.forName(DRIVER);
con = DriverManager.getConnection(CONSTR,USERNAME,USERPASS);
con.setAutoCommit(false);
//设置不自动提交事务
}catch (SQLException e) {
System.out.println(&sql语句错误&+e.getMessage());
} catch (ClassNotFoundException e) {
System.out.println(e.getMessage());
运行export即可把oracle的表中数据导入到DB2中
&&相关文章推荐
* 以上用户言论只代表其个人观点，不代表CSDN网站的观点或立场
访问：331420次
积分：3784
积分：3784
排名：第8177名
原创：77篇
转载：58篇
评论：106条
(5)(1)(5)(1)(1)(1)(1)(2)(2)(1)(3)(8)(2)(4)(1)(1)(3)(2)(10)(4)(5)(7)(2)(9)(11)(2)(3)(5)(9)(13)(11)(4)(1)(1)新手园地& & & 硬件问题Linux系统管理Linux网络问题Linux环境编程Linux桌面系统国产LinuxBSD& & & BSD文档中心AIX& & & 新手入门& & & AIX文档中心& & & 资源下载& & & Power高级应用& & & IBM存储AS400Solaris& & & Solaris文档中心HP-UX& & & HP文档中心SCO UNIX& & & SCO文档中心互操作专区IRIXTru64 UNIXMac OS X门户网站运维集群和高可用服务器应用监控和防护虚拟化技术架构设计行业应用和管理服务器及硬件技术& & & 服务器资源下载云计算& & & 云计算文档中心& & & 云计算业界& & & 云计算资源下载存储备份& & & 存储文档中心& & & 存储业界& & & 存储资源下载& & & Symantec技术交流区安全技术网络技术& & & 网络技术文档中心C/C++& & & GUI编程& & & Functional编程内核源码& & & 内核问题移动开发& & & 移动开发技术资料ShellPerlJava& & & Java文档中心PHP& & & php文档中心Python& & & Python文档中心RubyCPU与编译器嵌入式开发驱动开发Web开发VoIP开发技术MySQL& & & MySQL文档中心SybaseOraclePostgreSQLDB2Informix数据仓库与数据挖掘NoSQL技术IT业界新闻与评论IT职业生涯& & & 猎头招聘IT图书与评论& & & CU技术图书大系& & & Linux书友会二手交易下载共享Linux文档专区IT培训与认证& & & 培训交流& & & 认证培训清茶斋投资理财运动地带快乐数码摄影& & & 摄影器材& & & 摄影比赛专区IT爱车族旅游天下站务交流版主会议室博客SNS站务交流区CU活动专区& & & Power活动专区& & & 拍卖交流区频道交流区
稍有积蓄, 积分 275, 距离下一级还需 225 积分
论坛徽章:0
如何将图片插入DB2中的BLOB字段？如果要程序实现，如何实现？TKS
&&nbsp|&&nbsp&&nbsp|&&nbsp&&nbsp|&&nbsp&&nbsp|&&nbsp
白手起家, 积分 14, 距离下一级还需 186 积分
论坛徽章:0
如何将图片插入DB2中的BLOB字段？
将图片文件作为二进制流insert到blob column就可以了
稍有积蓄, 积分 275, 距离下一级还需 225 积分
论坛徽章:0
如何将图片插入DB2中的BLOB字段？
是否有具体的例子？
北京皓辰网域网络信息技术有限公司. 版权所有 京ICP证:060528号 北京市公安局海淀分局网监中心备案编号：
广播电视节目制作经营许可证(京) 字第1234号
中国互联网协会会员&&联系我们：
感谢所有关心和支持过ChinaUnix的朋友们
转载本站内容请注明原作者名及出处