db2导入数据库
Ⅰ db2数据库的导入
db2move newdbname import 即可
因为你db2move export 出来的是ixf，所以包含了表结构。
不过视图，过程等对象是不包含的，你可以使用db2look 导出结构。
Ⅱ 批处理导入DB2数据库
1，bat文件（替换方括号中的内容）
db2 connect to [数据库别名] user [用户名] using [密码]
db2 import from 'D:\Temp\backup.del' of del insert_update into [表名(字段列表)]
db2 connect reset
2，调用
db2cmd bat文件
注意事项：
1，目标表需要定义主键
2，数据文件的字段顺序需要与语句中的字段顺序一一对应
3，若数据文件较大，需要在import命令增加COMMITCOUNT的选项
4，db2cmd的调用需要确认是否配置了环境变量，否则需要在db2客户端的目录下执行
Ⅲ txt文件如何导入到db2数据库中
db2 import from c:\aaa.txt of del modify by coldel| insert into table1
其中c:\aaa.txt为原始文本文件全名，可以带有完整路径
of del表示文件的类型为定界ASCII类型，即每个列有分隔符的文本文件
coldel参数用于指定每个列的分隔符，后面的竖线“|”与coldel之间不要有空格
Ⅳ DB2怎么跨库导入数据
可以在表前加数据库名和用户名来实现。下面是想法你可试下
你的意思是不是从table1 表中查询数据写到table2中？？
user database2
go
insert table2
select 字段1,字段2,字段3,。。。。from database1..table1
go
Ⅳ 在DB2中，怎么导入数据
EXPORT TO 文件名 OF 文件类型 select查询 ...... ---------导出,支持IXF，DEL或WSF 文件格式
LOAD FROM 文件名 OF 文件类型 INSERT INTO .... ----导入，支持IXF，DEL，ASC或WSF 文件格式
IMPORT FROM 文件名 OF 文件类型 INSERT INTO .....----导入，支持IXF，DEL，ASC或WSF 文件格式
Ⅵ 如何把db2的数据导入到oracle
数据迁移：
1、在DB2数据库中通过以下表查询出表的结构
SELECT
TABNAME TAB, --表英文名称
COLNAME COL, --列名称
CASE
WHEN TYPENAME='VARCHAR' THEN 'VARCHAR2'
WHEN TYPENAME LIKE 'SMALLINT' OR TYPENAME LIKE 'BIGINT' THEN 'INTEGER'
WHEN TYPENAME ='CHARACTER' THEN 'CHAR'
WHEN TYPENAME='DECFLOAT' OR TYPENAME ='DECIMAL' THEN 'NUMBER'
ELSE TYPENAME
END TY
, --数据类型
LENGTH LEN , --列长度
scale S, --精度
CASE
WHEN NULLS='N' THEN '否'
WHEN NULLS='Y' THEN '是'
END N --是否为空
--TY||'('||LEN||')'
FROM
SYSCAT.COLUMNS S
WHERE
LEFT( TABSCHEMA, 3 ) <> 'SYS'
/* and s.SCALE <>0*/
ORDER BY
S.TABNAME,
S.COLNO
2、根据表的结构在oracle数据库中建表（脚本见《create_tab_onOracle.sql》）
3、通过编写java程序把数据从DB2导入到oracle数据库中（以下代码思想仅供参考）
3.1、 导入db2jcc_license_cu.jar 、db2jcc.jar 、ojdbc14.jar 三个jar包即可
3.2、 编写三个工具类
此类链接DB2数据库工具类
package com.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionDB2 {
private static final String URL="jdbc:db2://192.168.0.98:50000/sem"; //DB2数据库url
private static final String USER="db2admin"; //DB2数据库账号
private static final String PASSWORD="dnhc9988"; //DB2数据库密码
static{
try {
Class.forName("com.ibm.db2.jcc.DB2Driver").newInstance(); //利用反射注册驱动
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public Connection getConnection(){
Connection conn=null;
try {
conn=DriverManager.getConnection(URL, USER, PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}
此类链接oracle数据库工具类
package com.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionDB2 {
private static final String URL="jdbc:db2://192.168.0.98:50000/sem"; //DB2数据库url
private static final String USER="db2admin"; //DB2数据库账号
private static final String PASSWORD="dnhc9988"; //DB2数据库密码
static{
try {
Class.forName("com.ibm.db2.jcc.DB2Driver").newInstance(); //利用反射注册驱动
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public Connection getConnection(){
Connection conn=null;
try {
conn=DriverManager.getConnection(URL, USER, PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
}
此类用来关闭数据库连接工具类
package com.util;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class CloseFunction {
//关闭连接方法,释放资源
public static void closeConnection(Connection conn){
if (conn !=null){
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
//关闭执行sql，释放资源
public static void closeExecuteSQL(Statement preparedStatement){
if (preparedStatement !=null){
try {
preparedStatement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
//关闭查询SQL结果，释放资源
public static void closeResultSet(ResultSet resultSet){
if(resultSet !=null){
try {
resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
关键在此类：需要从DB2数据库查询语句放在db2SQL变量中，往oracle插入数据的语句放在oracleSQL变量中。注意，查询和插入的语句中字段顺序要一致，在while循环里要对日期时间处理(用setDate)，然后执行junit测试类就可以了。
package com.;
import java.security.interfaces.RSAKey;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.junit.Test;
import com.util.CloseFunction;
import com.util.ConnectionDB2;
import com.util.ConnectionOracle;
public class FromDB2ToOracle {
@Test
public void test1() throws SQLException{
long startTime=System.currentTimeMillis(); //记录开始时间
Connection connDB2=null; //链接DB2数据库
Connection connOracle=null; //链接oracle数据库
Statement statement=null;
ResultSet resultSet=null;
PreparedStatement preparedStatement=null;
try {
ConnectionOracle connectionOracle=new ConnectionOracle();
// System.out.println(connectionOracle+"链接oracle成功！");
ConnectionDB2 connectionDB2=new ConnectionDB2();
// System.out.println(connectionDB2+"-->>>链接DB2数据库成功！");
connDB2=connectionDB2.getConnection();
//执行DB2数据库sql语句，此处并非固定代码
String
db2SQL="SELECT ID,SENDNO,SENDTYPE,BRNUMBER
,SENDTIME,ALARMTIME,SENDCONTENT,ISSEND ,ELEALARMID from
DB2ADMIN.ET_SENDMESSAGEINFO";
//执行oracle数据库sql语句，此处并非固定代码
//String oracleSQL="INSERT INTO EPC.SYS_LOG(ID,REMARK) values(?,?)";
String
oracleSQL="INSERT INTO
EPC.ET_SENDMESSAGEINFO(ID,SENDNO,SENDTYPE,BRNUMBER
,SENDTIME,ALARMTIME,SENDCONTENT,ISSEND ,ELEALARMID )"
+ "VALUES(?,?,?,?,?,?,?,?,?)";
statement=connDB2.createStatement();
statement.execute(db2SQL); //执行sql语句
resultSet=statement.getResultSet(); //获取DB2数据库的结果集
connOracle=connectionOracle.getConnection(); //获取oracle数据库连接
connOracle.setAutoCommit(false); //把oracle数据库设置为非自动提交，以免在再循环里每次都提交，减低效率
preparedStatement=connOracle.prepareStatement(oracleSQL); //执行oracle语句，预编译
int num=0;
while (resultSet.next()) {
num ++;
preparedStatement.setString(1,resultSet.getString("ID"));
preparedStatement.setString(2, resultSet.getString("SENDNO"));
preparedStatement.setString(3, resultSet.getString("SENDTYPE"));
preparedStatement.setString(4, resultSet.getString("BRNUMBER"));
preparedStatement.setDate(5, resultSet.getDate("SENDTIME"));
preparedStatement.setDate(6, resultSet.getDate("ALARMTIME"));
preparedStatement.setString(7, resultSet.getString("SENDCONTENT"));
preparedStatement.setString(8, resultSet.getString("ISSEND"));
preparedStatement.setString(9, resultSet.getString("ELEALARMID"));/*
preparedStatement.setString(10, resultSet.getString("CONSUMETIME"));
preparedStatement.setString(11, resultSet.getString("TASKID"));
preparedStatement.setString(12, resultSet.getString("ISSYNCHRO"));
preparedStatement.setString(13,resultSet.getString("LOGTYPE"));
preparedStatement.setString(14, resultSet.getString("ISCACHE"));
preparedStatement.setString(15, resultSet.getString("LAST_RPORT_TIME"));
preparedStatement.setString(16, resultSet.getString("AUTO_REMEMBER"));
preparedStatement.setString(17, resultSet.getString("REMARK"));*/
preparedStatement.addBatch();
//每一万次在oracle数据库里提交事务
if(num>10000){
preparedStatement.executeBatch();
connOracle.commit();
num=0;
}
}
preparedStatement.executeBatch();
connOracle.commit();
} catch (Exception e) {
connOracle.rollback(); //oracle数据库事务回滚
e.printStackTrace();
}finally{
new CloseFunction().closeConnection(connOracle); //关闭oracle数据库，释放资源
new CloseFunction().closeConnection(connDB2); //关闭DB2数据库，释放资源
long endTime=System.currentTimeMillis(); //记录程序结束时间
System.out.println("总的时间："+(endTime-startTime)/1000+"秒");
}
}
}
Ⅶ 如何读取Excel数据并导入DB2数据库
import Java.io.FileInputStream;import java.io.IOException;import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import org.apache.poi.hssf.usermodel.HSSFCell; import org.apache.poi.hssf.usermodel.HSSFRow; import org.apache.poi.hssf.usermodel.HSSFSheet; import org.apache.poi.hssf.usermodel.HSSFWorkbook; import org.apache.poi.poifs.filesystem.POIFSFileSystem; public class POITest {private static Connection conn = null; private static Statement stmt = null; private static boolean connectDB2() {String url = ""; String username = "username"; String password = "password"; //加载驱动程序以连接数据库try {//添加类库驱动包db2jcc.jar和db2jcc_license_cu.jarClass.forName ("com.ibm.db2.jcc.DB2Driver"); url = "JDBC:db2://192.168.0.1:50000/dbname"; //添加类库驱动包db2java.jar// Class.forName("com.ibm.db2.jdbc.app.DB2Driver").newInstance(); //url = "jdbc:db2:njtcdata"; conn = DriverManager.getConnection(url, username, password);stmt = conn.createStatement();} //捕获加载驱动程序异常catch (ClassNotFoundException cnfex) {System.err.println("装载JDBC驱动程序失败。"); cnfex.printStackTrace();return false;} //捕获连接数据库异常catch (SQLException sqlex) {System.err.println("无法连接数据库"); sqlex.printStackTrace();//System.exit(1); // terminate programreturn false;}return true;} private static boolean readExcelToDB2() {POIFSFileSystem fs = null;HSSFWorkbook wb = null; try {fs = new POIFSFileSystem (new FileInputStream("c:\\test.xls")); wb = new HSSFWorkbook(fs);} catch (IOException e) {e.printStackTrace();return false;} HSSFSheet sheet = wb.getSheetAt(0); HSSFRow row = null;HSSFCell cell = null; String name = "";int id = 0;int rowNum, cellNum;int i;rowNum = sheet.getLastRowNum(); for (i = 0; i <= rowNum; i++) {row = sheet.getRow(i); //cellNum = row.getLastCellNum(); cell = row.getCell((short) 0); name = cell.getStringCellValue(); cell = row.getCell((short) 1); id = (int) cell.getNumericCellValue(); String sql = "insert into TEST(ID, NAME) values(" + id + ",'" + name + "')"; try {stmt.executeUpdate(sql);} catch (SQLException e1) {e1.printStackTrace(); return false;}}return true; }public static void main(String[] args) {if (connectDB2()==true){if (readExcelToDB2()==true)System.out.println("数据导入成功"); elseSystem.out.println("数据导入失败"); }else{System.out.println("数据库连接失败");}}}（T006）
Ⅷ db2 dat 文件怎么导入数据库
右键数据库-->所有任务-->还原数据库-->写入你想要的新的数据库名字-->从设备专-->选择设备-->添加-->选择你的属文件-->确定-->确定-->选项-->改为现在的data目录的路径-->OK
其中：
"写入名字"-->不要与现在的冲突了，或选强制恢复
"改为现在的data目录的路径"-->如默认是"c:\....data\....mdf"而现在的sql的data目录是d:\....data就改为d:\...data\...mdf
Ⅸ db2导入数据库全步骤，谢谢。。。
你是导入表还是什么、
导入表用 LOAD