java连接两个数据库

要使用Java连接两个数据库，首先需要导入JDBC驱动，然后创建两个数据库连接对象，分别连接到两个数据库。

要使用Java连接两个数据库，你需要遵循以下步骤：

1、添加数据库驱动

2、加载数据库驱动

3、建立数据库连接

4、执行SQL语句

5、关闭数据库连接

以MySQL和Oracle为例，分别介绍如何连接这两个数据库。

1. 添加数据库驱动

需要将MySQL和Oracle的JDBC驱动包添加到项目的类路径中，可以从官网下载对应版本的驱动包，或者使用Maven或Gradle等构建工具添加依赖。

MySQL驱动包（mysqlconnectorjava）：https://dev.mysql.com/downloads/connector/j/

Oracle驱动包（ojdbc8.jar）：https://www.oracle.com/database/technologies/appdev/jdbcucp19cdownloads.html

2. 加载数据库驱动

在Java代码中，需要加载对应的数据库驱动，通常在类的静态初始化块中进行加载。

static {
    try {
        Class.forName("com.mysql.cj.jdbc.Driver"); // 加载MySQL驱动
    } catch (ClassNotFoundException e) {
        e.printStackTrace();
    }
}

3. 建立数据库连接

使用DriverManager类的getConnection方法建立数据库连接，需要提供数据库URL、用户名和密码。

MySQL连接示例：

String url = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
String user = "root";
String password = "your_password";
Connection conn = DriverManager.getConnection(url, user, password);

Oracle连接示例：

String url = "jdbc:oracle:thin:@localhost:1521:xe";
String user = "system";
String password = "your_password";
Connection conn = DriverManager.getConnection(url, user, password);

4. 执行SQL语句

使用Connection对象的createStatement方法创建Statement对象，然后使用Statement对象的executeQuery或executeUpdate方法执行SQL语句，处理查询结果或更新计数。

MySQL示例：

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM users");
while (rs.next()) {
    System.out.println(rs.getString("username"));
}
rs.close();
stmt.close();

Oracle示例：

Statement stmt = conn.createStatement();
int count = stmt.executeUpdate("INSERT INTO users (username, password) VALUES ('test', 'test')");
System.out.println("插入成功，影响行数：" + count);
stmt.close();

5. 关闭数据库连接

在完成数据库操作后，需要关闭Connection、Statement和ResultSet对象，释放资源，可以使用trywithresources语句简化操作。

MySQL示例：

try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement();
     ResultSet rs = stmt.executeQuery("SELECT * FROM users")) {
    while (rs.next()) {
        System.out.println(rs.getString("username"));
    }
} catch (SQLException e) {
    e.printStackTrace();
}

Oracle示例：

try (Connection conn = DriverManager.getConnection(url, user, password);
     Statement stmt = conn.createStatement()) {
    int count = stmt.executeUpdate("INSERT INTO users (username, password) VALUES ('test', 'test')");
    System.out.println("插入成功，影响行数：" + count);
} catch (SQLException e) {
    e.printStackTrace();
}