oracle 连接mysql

import java.sql.*;

public class DatabaseConnector {
    public static void main(String[] args) {
        String oracleUrl = "jdbc:oracle:thin:@localhost:1521:orcl";
        String mysqlUrl = "jdbc:mysql://localhost:3306/mydb";
        String oracleUser = "oracleUser";
        String oraclePassword = "oraclePassword";
        String mysqlUser = "mysqlUser";
        String mysqlPassword = "mysqlPassword";

        try {
            // 连接 Oracle 数据库
            Connection oracleConn = DriverManager.getConnection(oracleUrl, oracleUser, oraclePassword);
            Statement oracleStmt = oracleConn.createStatement();
            ResultSet oracleRs = oracleStmt.executeQuery("SELECT * FROM employees");

            // 连接 MySQL 数据库
            Connection mysqlConn = DriverManager.getConnection(mysqlUrl, mysqlUser, mysqlPassword);
            Statement mysqlStmt = mysqlConn.createStatement();
            mysqlStmt.executeUpdate("CREATE TABLE IF NOT EXISTS employees (id INT, name VARCHAR(255))");

            // 将 Oracle 数据插入 MySQL
            while (oracleRs.next()) {
                int id = oracleRs.getInt("id");
                String name = oracleRs.getString("name");
                mysqlStmt.executeUpdate("INSERT INTO employees (id, name) VALUES (" + id + ", '" + name + "')");
            }

            // 关闭连接
            oracleRs.close();
            oracleStmt.close();
            oracleConn.close();
            mysqlStmt.close();
            mysqlConn.close();

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