mongodb转存oracle 代码
时间: 2023-07-25 10:37:15 浏览: 56
以下是使用 Java 代码将 MongoDB 中的数据转存到 Oracle 数据库的示例代码:
```java
import com.mongodb.MongoClient;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class MongoDBToOracle {
public static void main(String[] args) {
// MongoDB 配置信息
String mongoHost = "localhost";
int mongoPort = 27017;
String mongoDatabaseName = "test";
String mongoCollectionName = "users";
// Oracle 配置信息
String oracleHost = "localhost";
int oraclePort = 1521;
String oracleDatabaseName = "orcl";
String oracleUsername = "username";
String oraclePassword = "password";
// MongoDB 连接
MongoClient mongoClient = new MongoClient(mongoHost, mongoPort);
MongoDatabase mongoDatabase = mongoClient.getDatabase(mongoDatabaseName);
MongoCollection<Document> mongoCollection = mongoDatabase.getCollection(mongoCollectionName);
// Oracle 连接
Connection oracleConnection = null;
try {
Class.forName("oracle.jdbc.driver.OracleDriver");
String oracleUrl = "jdbc:oracle:thin:@" + oracleHost + ":" + oraclePort + ":" + oracleDatabaseName;
oracleConnection = DriverManager.getConnection(oracleUrl, oracleUsername, oraclePassword);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
// MongoDB 数据读取
for (Document document : mongoCollection.find()) {
try {
// 将 MongoDB 数据转换为 Oracle 数据
int id = document.getInteger("id");
String name = document.getString("name");
String email = document.getString("email");
String phone = document.getString("phone");
// 将 Oracle 数据写入数据库
String sql = "INSERT INTO users (id, name, email, phone) VALUES (?, ?, ?, ?)";
PreparedStatement statement = oracleConnection.prepareStatement(sql);
statement.setInt(1, id);
statement.setString(2, name);
statement.setString(3, email);
statement.setString(4, phone);
statement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 关闭连接
mongoClient.close();
try {
oracleConnection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
```
以上代码仅供参考,实际应用中需要根据具体情况进行修改和调整。
相关推荐
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)