您的位置：首页 > 数据库 > Oracle

Oracle迁移之批量迁移INDEX、SEQUENCE、VIEW

2016-01-26 11:54 567 查看

转载请注明来源：/article/9699097.html

最近碰到oracle数据库迁移，由于高级的迁移方法还不会，当前只会手动导入导出迁移。在迁移完所有数据表后，需要继续迁移索引、序列、视图、触发器、函数等。

本文主要说明批量迁移索引、序列、视图。触发器由于执行过程中异常，还没有找到方法自动处理；函数就只有几个手动处理掉了。

1. java程序

本次迁移面临问题：索引较多有68个，序列28个，视图8个。手动一个一个处理，看得眼睛都花了。就弄个java脚本处理。

不过各位碰到具体问题需要做微调。

package com.autonavi.service;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.SQLSyntaxErrorException;
import java.sql.Statement;

import com.autonavi.db.DataBaseConnection;

public class DealOracle {

private static DataBaseConnection cFactory = new DataBaseConnection();
static ResultSet rs = null;
static Connection connection1 = null;
static Connection connection2 = null;
static Statement statement = null;

public static void copyIndex(){
// 1.查询出建索引语句
String SQL = "SELECT DBMS_METADATA.GET_DDL('INDEX',u.index_name) AS id FROM USER_INDEXES u";

try {
int count = 0;
PreparedStatement pState1 = null;
PreparedStatement pState2 = null;

pState1 = cFactory.createConnection4 ().prepareStatement(SQL);
ResultSet rs = pState1.executeQuery();

while(rs.next()){

String str = rs.getString("ID");
String newstr = "";

if(str.contains("(DEGREE 0 INSTANCES 0)") == false){
count++;
String substr = str.substring(0,str.indexOf("TABLESPACE"));

newstr = substr+"TABLESPACE \"RUS\"";
//System.out.println("str:"+str);
System.out.println("newstr:"+newstr);
System.out.println("count:"+count);

try {
pState2 = cFactory.createConnection3().prepareStatement(newstr);
pState2.executeQuery(newstr);
pState2.close();
System.out.println("新建索引成功");
} catch (SQLSyntaxErrorException e) {

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

e.printStackTrace();
}
}
}
pState1.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {

cFactory.releaseConnection4();
cFactory.releaseConnection3();
}
}

public static void copySequence(){
// 1.查询出建序列语句
String SQL = "SELECT DBMS_METADATA.GET_DDL('SEQUENCE',u.sequence_name) AS id FROM USER_SEQUENCES u";

try {
int count = 0;
PreparedStatement pState1 = null;
PreparedStatement pState2 = null;

pState1 = cFactory.createConnection4 ().prepareStatement(SQL);
ResultSet rs = pState1.executeQuery();

while(rs.next()){

String str = rs.getString("ID");

count++;
System.out.println("sequence:"+str);
System.out.println("count:"+count);

try {
pState2 = cFactory.createConnection3().prepareStatement(str);
pState2.executeQuery(str);
pState2.close();
System.out.println("新建序列成功");
} catch (SQLSyntaxErrorException e) {

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

e.printStackTrace();
}
}
pState1.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {

cFactory.releaseConnection4();
cFactory.releaseConnection3();
}

}

public static void copyView(){
// 1.查询出建VIEW语句
String SQL = "SELECT DBMS_METADATA.GET_DDL('VIEW',u.view_name) AS id FROM USER_VIEWS u";

try {
int count = 0;
PreparedStatement pState1 = null;
PreparedStatement pState2 = null;

pState1 = cFactory.createConnection4 ().prepareStatement(SQL);
ResultSet rs = pState1.executeQuery();

while(rs.next()){

String str = rs.getString("ID");

count++;
System.out.println("view:"+str);
System.out.println("count:"+count);

try {
pState2 = cFactory.createConnection3().prepareStatement(str);
pState2.executeQuery(str);
pState2.close();
System.out.println("新建view成功");
} catch (SQLSyntaxErrorException e) {

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

e.printStackTrace();
}
}
pState1.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {

cFactory.releaseConnection4();
cFactory.releaseConnection3();
}

}

// 此方法有问题，不行。不过可以先通过下面的语句查询出触发器，手动创建。
public static void copyTriger(){
// 1.查询出建触发器语句
String SQL = "SELECT DBMS_METADATA.GET_DDL('TRIGGER',u.trigger_name) AS id FROM USER_TRIGGERS u";

try {
int count = 0;
PreparedStatement pState1 = null;
PreparedStatement pState2 = null;

pState1 = cFactory.createConnection4 ().prepareStatement(SQL);
ResultSet rs = pState1.executeQuery();

while(rs.next()){

String str = rs.getString("ID");
String newstr1 = "";
String newstr2 = "";
System.out.println("str:"+str);

newstr1 = str.substring(0,str.indexOf("ALTER"));
newstr2 = str.substring(str.indexOf("ALTER"));

count++;
System.out.println("trigger1:"+newstr1);
System.out.println("trigger2:"+newstr2);
System.out.println("count:"+count);

try {
pState2 = cFactory.createConnection3().prepareCall(newstr1);
pState2.executeUpdate();
//pState2 = cFactory.createConnection3().prepareStatement(newstr2);
//pState2.execute();

pState2.close();
System.out.println("新建触发器成功");
} catch (SQLSyntaxErrorException e) {

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

e.printStackTrace();
}

}
pState1.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {

cFactory.releaseConnection4();
cFactory.releaseConnection3();
}

}

public static void copyFunction(){

}

public static void main(String[] args){

copyView();
}

}