- 连接mysql
- 连接mongoDB
// 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
引入依赖:
// 1、建立mongoClient连接 MongoClientURI uri = new MongoClientURI(connectUrl); MongoClient client = new MongoClient(uri); // 2、连接mongo数据库 MongoDatabase mongoConnect = client.getDatabase(databaseModel.getDatabaseName()); // 3、连接mongo集合 MongoCollection org.mongodb mongo-java-driver 3.12.10 collection = mongoConnect.getCollection(tableModel.getTableName()); // 4、执行操作(注意client需要关闭连接) DeleteResult result = collection.deleteMany(query);



