java将oracle一个表空间的数据同步到另一个表空间的数据，来看看有没有问题

0 0

java将oracle一个表空间的数据同步到另一个表空间的数据，来看看有没有问题5

代码如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;


public class Bak {
	
	public static String shengchanku = "aaa";//生产库登录名
	public static String shengchanku_pw = "1";//生产库密码
	public static String shengchanku_serviceName = "127.0.0.1";//生产库服务名
	
	public static String ceshiku = "aaatest";//测试库登录名
	public static String ceshiku_pw = "1";//测试库密码
	public static String ceshiku_serviceName = "127.0.0.1";//测试库服务名
	
	/**
	 * @param args
	 * @throws SQLException
	 */
	public static void main(String[] args){
		Date d = new Date();
		long start = d.getTime();
		String msg = "";
		Connection conn = null;
		try {
			conn = getConnection();
		} catch (Exception e1) {
			msg = "获取生产库链接失败";
		}
		Connection connTest = null;
		try {
			connTest = getTestConnection();
		} catch (Exception e1) {
			msg = "获取测试库链接失败";
		}
		if("".equals(msg)){
			try {
				//开启事务
				conn.setAutoCommit(false);
				
				//查询出生产库所有表的名称
				List<String> list_table_names = new ArrayList<String>();
				Statement stmt = conn.createStatement();
				ResultSet rs = stmt.executeQuery("select table_name from user_tables");
				while(rs.next()){
					list_table_names.add(rs.getString(1));
				}
				rs.close();
				stmt.close();
				
				//查询测试库所有表的名称
				List<String> list_table_names_test = new ArrayList<String>();
				stmt = connTest.createStatement();
				rs = stmt.executeQuery("select table_name from user_tables");
				while(rs.next()){
					list_table_names_test.add(rs.getString(1));
				}
				
				//拼接往测试库每个表插数据的sql
				String table_name = "";
				List<String> sql_create = new ArrayList<String>();
				for(int i =0;i<list_table_names.size();i++){
					table_name = list_table_names.get(i);
					sql_create.add("create table "+ceshiku+"."+table_name+" AS SELECT * FROM "+shengchanku+"."+table_name+"");
				}
				
				//拼接删除测试库表的sql
				List<String> sql_drop = new ArrayList<String>();
				for(int i =0;i<list_table_names_test.size();i++){
					table_name = list_table_names_test.get(i);
					sql_drop.add("drop table "+ceshiku+"." + table_name);
				}
				
				//删除测试库的数据
				stmt = conn.createStatement();
				for(int i = 0 ;i<sql_drop.size();i++){
					stmt.addBatch(sql_drop.get(i));
				}
				
				//执行删除sql
				int[] result = stmt.executeBatch();
				System.out.println("执行删除表：" + result.length);
				stmt.close();

				//重新创建测试库的数据
				stmt = connTest.createStatement();
				for(int i = 0 ;i<sql_create.size();i++){
					stmt.addBatch(sql_create.get(i));
				}
				
				//执行创建sql
				result = stmt.executeBatch();
				System.out.println("执行创建表：" + result.length);
				stmt.close();
				
				//提交事务
				conn.setAutoCommit(true);
			} catch (SQLException e) {
				e.printStackTrace();
			}finally{
				try {
					conn.close();
					connTest.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
			}
		}else{
			System.out.println(msg);
		}
		
		d = new Date();
		long end = d.getTime();

		System.out.println("执行时间：" + (end-start) + "毫秒");
	}
	
	//获取生产库链接
	public static Connection getConnection() throws Exception{
		Connection ct = null;
		Class.forName("oracle.jdbc.driver.OracleDriver");
		ct = DriverManager.getConnection("jdbc:oracle:thin:"+shengchanku+"/"+shengchanku_pw+"@"+shengchanku_serviceName+":1521:orcl");
		return ct;
	}
	
	//获取测试库链接
	public static Connection getTestConnection() throws Exception{
		Connection ct = null;
		Class.forName("oracle.jdbc.driver.OracleDriver");
		ct = DriverManager.getConnection("jdbc:oracle:thin:"+ceshiku+"/"+ceshiku_pw+"@"+ceshiku_serviceName+":1521:orcl");
		return ct;
	}

}

大伙来看看这样写有没有什么问题，性能如何，我执行时间大概10秒多，数据量不是很大，不过有个附件表，表空间数据全部导出来大概有300多M

问题补充：两个用户对应两个不同的表空间，但在同一个库里

2013年3月28日 09:31

黑土豆Dean
26
0 0 4

1个答案按时间排序按投票排序

0 0

采纳的答案

看不出什么大问题。只是小问题好多，哈。

setAutoCommit是指是否自动提交，不是开启事务。
你的SQL文貌似都不能回滚的，应该不需要动这个。

另外，这个处理不是

引用

将oracle一个表空间的数据同步到另一个表空间的数据

应该是用户（或者schema），而不是表空间。
表空间是指物理意义上的数据文件。

-------------------

Class.forName("oracle.jdbc.driver.OracleDriver");
调用一遍就好了。

拼SQL文同时直接做批处理就好了，为什么又循环一次。
任意个connection建立失败时，在catch块里直接return掉，就可以省去那个最大的

if("".equals(msg)){  
...
}

嵌套

2013年3月28日 17:38

clxy
825
0 3 62

1条评论

已解决问题

未解决问题

排行榜

查看全部排名>>

java将oracle一个表空间的数据同步到另一个表空间的数据，来看看有没有问题5

1个答案按时间排序按投票排序

采纳的答案

相关推荐

相关推荐

已解决问题

未解决问题

排行榜

java将oracle一个表空间的数据同步到另一个表空间的数据，来看看有没有问题5

1个答案 按时间排序 按投票排序

采纳的答案

相关推荐

相关推荐

已解决问题

未解决问题

排行榜

1个答案按时间排序按投票排序