Oracle数据实时同步到MongoDB可以通过以下几种方式实现：
- 使用第三方同步工具，例如Striim或者Pentaho。
- 编写自定义应用程序使用JDBC连接Oracle，并使用MongoDB的Java驱动进行数据同步。
- 使用Oracle GoldenGate进行数据同步，配合自定义脚本将数据导入MongoDB。
以下是一个简单的Java代码示例，展示如何使用JDBC从Oracle读取数据并写入MongoDB：
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.ResultSet;
import java.sql.SQLException;
public class OracleToMongoDB {
public static void main(String[] args) throws SQLException, ClassNotFoundException {
// Oracle数据库连接信息
String oracleUrl = "jdbc:oracle:thin:@localhost:1521:orcl";
String oracleUser = "your_username";
String oraclePassword = "your_password";
// MongoDB连接信息
MongoClient mongoClient = new MongoClient("localhost", 27017);
MongoDatabase mongoDatabase = mongoClient.getDatabase("your_database");
MongoCollection<Document> collection = mongoDatabase.getCollection("your_collection");
// 加载Oracle JDBC驱动
Class.forName("oracle.jdbc.driver.OracleDriver");
// 建立连接
try (Connection conn = DriverManager.getConnection(oracleUrl, oracleUser, oraclePassword);
PreparedStatement pstmt = conn.prepareStatement("SELECT * FROM your_table");
ResultSet rs = pstmt.executeQuery()) {
// 遍历结果集
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
// 假设MongoDB中的文档有'id'和'name'字段
Document doc = new Document("id", id).append("name", name);
collection.insertOne(doc);
}
}
}
}注意：
- 需要将上述代码中的数据库连接信息（如Oracle URL、用户名、密码以及MongoDB的连接信息）替换为实际的数据库信息。
- 需要添加Oracle JDBC驱动依赖到项目中。
- 该示例假设Oracle和MongoDB的表结构相似，并且字段类型兼容。
- 该示例未包含异常处理和性能优化，实际应用中需要添加。
为了实现实时同步，可以使用定时任务或者触发器的方式，在Oracle数据发生变化时同步到MongoDB。