java代码操作数据转移，把一个数据库里的东西移动到另一个数据库，自动建库建表

共12个文件

java：5个

class：4个

prefs：1个

java

mysql

4星 · 超过85%的资源需积分: 50 142 浏览量 2014-07-24 16:25:22 上传评论 5 收藏 21KB ZIP 举报

在IT行业中，数据库迁移是一项常见的任务，特别是在Java开发中，我们经常需要将数据从一个数据库迁移到另一个数据库，比如从测试环境迁移到生产环境。这个过程不仅涉及数据的复制，还包括了数据库结构（如表、索引等）的创建。本篇文章将详细探讨如何使用Java代码来实现这一目标，主要涉及的工具是MySQL数据库。我们需要理解Java与MySQL的交互，这通常通过JDBC（Java Database Connectivity）来实现。JDBC是Java标准API，它提供了一套接口和类，用于连接和操作数据库。在Java代码中，我们需要添加MySQL的JDBC驱动依赖，例如`mysql-connector-java`，这样就可以使用`Connection`对象连接到MySQL服务器。以下是一段建立数据库连接的示例代码： ```java import java.sql.*; public class DatabaseConnectivity { public static void main(String[] args) { String url = "jdbc:mysql://localhost:3306/sourceDB"; String user = "username"; String password = "password"; try (Connection connection = DriverManager.getConnection(url, user, password)) { System.out.println("Connected to the database!"); } catch (SQLException e) { System.err.println("Error connecting: " + e.getMessage()); } } } ``` 在获取连接后，我们需要获取源数据库的元数据，以便了解其结构。这可以通过`DatabaseMetaData`对象完成，可以查询表、列、索引等信息。例如，获取所有表的名称： ```java DatabaseMetaData metaData = connection.getMetaData(); ResultSet tables = metaData.getTables(null, null, null, new String[]{"TABLE"}); while (tables.next()) { System.out.println(tables.getString("TABLE_NAME")); } ``` 有了这些信息，我们就可以编写SQL脚本来创建目标数据库的结构。在Java中，可以使用`Statement`或`PreparedStatement`对象执行这些SQL语句，例如创建表： ```java String createTableSql = "CREATE TABLE targetDB.new_table LIKE sourceDB.old_table"; Statement stmt = connection.createStatement(); stmt.executeUpdate(createTableSql); ``` 接下来，我们需要复制数据。一种方法是先导出源数据库的数据为CSV文件，然后在目标数据库中导入。另一种方法是直接使用SQL的`INSERT INTO SELECT`语句，或者通过Java代码逐行读取源数据库的数据并插入到目标数据库： ```java String copyDataSql = "INSERT INTO targetDB.new_table SELECT * FROM sourceDB.old_table"; stmt.executeUpdate(copyDataSql); ``` 为了实现自动化，你可以创建一个Java程序，该程序接收源和目标数据库的信息作为参数，然后自动完成上述步骤。你还可以添加异常处理和日志记录功能，以确保迁移过程的可靠性。在提供的"override-db"文件中，可能包含了实现上述功能的具体Java代码，包括连接管理、数据库元数据获取、结构创建和数据迁移的逻辑。如果需要进一步的分析和解释，需要查看这些源代码文件。使用Java和MySQL JDBC驱动进行数据库迁移是一个复杂但可实现的过程，涉及到数据库连接、元数据查询、SQL脚本执行等多个步骤。通过合理的编程和错误处理，可以构建一个可靠的自动化迁移工具。

资源推荐

资源详情

资源评论

收起资源包目录

override-db.zip （12个子文件）

override-db

src

Test.java 317B

main

resources

java

com

chinaops

entity

Dept.java 377B

core

CreateTable.java 32KB

CheckTable.java 1KB

util

Conn.java 758B

bin

com

chinaops

entity

Dept.class 736B

core

CreateTable.class 27KB

CheckTable.class 2KB

util

Conn.class 1KB

.classpath 441B

.settings

org.eclipse.jdt.core.prefs 598B

.project 387B

package com.chinaops.db.core; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import com.chinaops.db.entity.Dept; import com.chinaops.db.util.Conn; public class CreateTable { /* public static final String Y_RACENTER_USER = "root"; public static final String Y_RACENTER_PASS = "root"; public static final String Y_RACENTER_URL = "jdbc:mysql://localhost:3306/ecloud_auth"; public static final String Y_METADATE_USER = "root"; public static final String Y_METADATE_PASS = "root"; public static final String Y_METADATE_URL = "jdbc:mysql://localhost:3306/ecloud_metadata"; public static final String Y_BILLING_USER = "root"; public static final String Y_BILLING_PASS = "root"; public static final String Y_BILLING_URL = "jdbc:mysql://localhost:3306/ecloud_billing"; public static final String M_USER = "root"; public static final String M_PASS = "root"; public static final String M_URL = "jdbc:mysql://localhost:3306/ecloud_billing"; */ public static final String Y_RACENTER_USER = "racenter"; public static final String Y_RACENTER_PASS = "china-ops"; public static final String Y_RACENTER_URL = "jdbc:mysql://172.16.56.62:3306/ecloud_auth"; public static final String Y_METADATE_USER = "metadata"; public static final String Y_METADATE_PASS = "china-ops"; public static final String Y_METADATE_URL = "jdbc:mysql://172.16.56.64:3306/ecloud_metadata"; public static final String Y_BILLING_USER = "billing"; public static final String Y_BILLING_PASS = "china-ops"; public static final String Y_BILLING_URL = "jdbc:mysql://172.16.56.74:3306/ecloud_billing"; public static final String M_USER = "billing"; public static final String M_PASS = "china-ops"; public static final String M_URL = "jdbc:mysql://172.16.56.74:3306/ecloud_billing"; public static void main(String[] args) { CreateTable c = new CreateTable(); // ***Tables 为写入如数据的操作，数据库连接的是目标数据，方法内调用了***SQL // ***SQL 为查询要写入数据的sql语句，数据库连接的是源数据 c.createTables(); c.insertSQLTable(); c.updateResourcesTable(); c.updateOrderTable(); /* List<String> b = c.updateResourcesSQL(); int j = 0; if(b != null && b.size()>0){ for(String s:b){ System.out.println(j+" ** "+s); j++; } } List<String> orders = c.updateOrderSQL(); if(orders != null && orders.size()>0){ for(int i=0;i<orders.size();i++){ System.out.println(i+" ** "+orders.get(i)); if(i%19 == 0 && i != 0){ System.out.println("--------------------------------------------------------------------------------------------------------------------"); } j++; } } System.out.println("================================================ "+j+" ================================================"); */ } // OK public void createTables(){ CheckTable ct = new CheckTable(); // 要构建的数据库的SQL语句信息 // String userName = "billing"; // String password = "china-ops"; // String url = "jdbc:mysql://172.16.56.74:3306/ecloud_billing"; Connection conn = null; Statement stmt = null; if(!ct.isExist(M_USER,M_PASS,M_URL,"company_res_order_cfg")){ try { conn = Conn.getConn(M_URL, M_USER, M_PASS); stmt = conn.createStatement(); String sql="CREATE TABLE company_res_order_cfg ("+ "id int(11) NOT NULL AUTO_INCREMENT,"+ "company_id varchar(25) DEFAULT NULL COMMENT '公司ID',"+ "max_instances int(11) DEFAULT '0' COMMENT '最大云主机数量',"+ "max_volumes int(11) DEFAULT '0' COMMENT '最大存储数量',"+ "max_snapshots int(11) DEFAULT '0' COMMENT '最大快照数量',"+ "min_ebs_size int(11) DEFAULT '0' COMMENT '最小ebs启动存储大小',"+ "max_ebs_size int(11) DEFAULT '0' COMMENT '最大ebs启动存储大小',"+ "max_security_groups int(11) DEFAULT '0' COMMENT '最大安全规则组（虚拟网络防火墙）数量',"+ "max_keypairs int(11) DEFAULT '0' COMMENT '最大密钥数量',"+ "ecu_mon_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)包月数量',"+ "vol_mon_size int(11) DEFAULT '0' COMMENT '存储产品(volume)包月大小',"+ "snap_mon_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)包月大小',"+ "ha_mon_count int(11) DEFAULT '0' COMMENT 'HA(主机保护)产品(ha)包月数量',"+ "elb_mon_count int(11) DEFAULT '0' COMMENT 'Elb产品(elb)包天数量',"+ "ip_mon_count int(11) DEFAULT '0' COMMENT 'IP产品(ip)包月数量',"+ "ecu_day_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)包天数量',"+ "vol_day_size int(11) DEFAULT '0' COMMENT '存储产品(volume)包天小大',"+ "snap_day_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)包天小大',"+ "ecu_hour_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)计时数量',"+ "vol_hour_size int(11) DEFAULT '0' COMMENT '存储产品(volume)计时小大',"+ "snap_hour_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)计时大小',"+ "create_time datetime DEFAULT NULL COMMENT '创建时间',"+ "update_time datetime DEFAULT NULL COMMENT '更新时间',"+ "PRIMARY KEY (id)"+ ") ENGINE=MyISAM AUTO_INCREMENT=86 DEFAULT CHARSET=utf8;"; System.out.println(stmt.executeUpdate(sql)+" "+sql); } catch (SQLException e) { e.printStackTrace(); }finally{ try{ stmt.close(); conn.close(); }catch(Exception ex){ ex.getStackTrace(); } } }else{ try { conn = Conn.getConn(M_URL, M_USER, M_PASS); stmt = conn.createStatement(); String dropsql = "DROP TABLE IF EXISTS company_res_order_cfg;"; System.out.println(stmt.executeUpdate(dropsql)+" "+dropsql); String sql="CREATE TABLE company_res_order_cfg ("+ "id int(11) NOT NULL AUTO_INCREMENT,"+ "company_id varchar(25) DEFAULT NULL COMMENT '公司ID',"+ "max_instances int(11) DEFAULT '0' COMMENT '最大云主机数量',"+ "max_volumes int(11) DEFAULT '0' COMMENT '最大存储数量',"+ "max_snapshots int(11) DEFAULT '0' COMMENT '最大快照数量',"+ "min_ebs_size int(11) DEFAULT '0' COMMENT '最小ebs启动存储大小',"+ "max_ebs_size int(11) DEFAULT '0' COMMENT '最大ebs启动存储大小',"+ "max_security_groups int(11) DEFAULT '0' COMMENT '最大安全规则组（虚拟网络防火墙）数量',"+ "max_keypairs int(11) DEFAULT '0' COMMENT '最大密钥数量',"+ "ecu_mon_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)包月数量',"+ "vol_mon_size int(11) DEFAULT '0' COMMENT '存储产品(volume)包月大小',"+ "snap_mon_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)包月大小',"+ "ha_mon_count int(11) DEFAULT '0' COMMENT 'HA(主机保护)产品(ha)包月数量',"+ "elb_mon_count int(11) DEFAULT '0' COMMENT 'Elb产品(elb)包天数量',"+ "ip_mon_count int(11) DEFAULT '0' COMMENT 'IP产品(ip)包月数量',"+ "ecu_day_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)包天数量',"+ "vol_day_size int(11) DEFAULT '0' COMMENT '存储产品(volume)包天小大',"+ "snap_day_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)包天小大',"+ "ecu_hour_count float(11,0) DEFAULT '0' COMMENT 'ECU产品(ecu)计时数量',"+ "vol_hour_size int(11) DEFAULT '0' COMMENT '存储产品(volume)计时小大',"+ "snap_hour_size int(11) DEFAULT '0' COMMENT '快照产品(snapshot)计时大小',"+ "create_time datetime DEFAULT NULL COMMENT '创建时间',"+ "update_ti

评论收藏

内容反馈