[大数据]Java连接mysql与mongoDB

连接mysql

	// 1.加载驱动
    Class.forName("com.mysql.jdbc.Driver");

    // 2.获取数据库连接
   Connection connection = DriverManager.getConnection(url, user, password);
	
	// 3.操作sql语句
	PreparedStatement statement = mysqlConnect.prepareStatement(executeSql);
	
	// 4.执行（注意connection 和statement 都需要关闭连接）
    int executeResult = statement.executeUpdate();

连接mongoDB

引入依赖：

	<dependency>
	    <groupId>org.mongodb</groupId>
	    <artifactId>mongo-java-driver</artifactId>
	    <version>3.12.10</version>
	</dependency>

	// 1、建立mongoClient连接
	MongoClientURI uri = new MongoClientURI(connectUrl);
    MongoClient client = new MongoClient(uri);
    // 2、连接mongo数据库
    MongoDatabase mongoConnect = client.getDatabase(databaseModel.getDatabaseName());
    // 3、连接mongo集合
    MongoCollection<Document> collection = mongoConnect.getCollection(tableModel.getTableName());
    // 4、执行操作（注意client需要关闭连接）
    DeleteResult result = collection.deleteMany(query);