feat(database): Sync current user database objects with all projects when grouping databases

server/odc-server/src/main/java/com/oceanbase/odc/server/web/controller/v2/DBObjectIndexController.java

@@ -68,5 +68,12 @@ public SuccessResponse<Boolean> syncDatabaseObjects(@RequestBody SyncDBObjectReq
         return Responses.success(dbSchemaIndexService.syncDatabaseObjects(req));
     }
 
+    @ApiOperation(value = "syncCurrentUserDatabaseObjectsWithProject",
+            notes = "Sync all database objects under the project that the current user is joining")
+    @RequestMapping(value = "/syncAllWithProject", method = RequestMethod.POST)
+    public SuccessResponse<Boolean> syncCurrentUserDatabaseObjectsWithProject() {
+        return Responses.success(dbSchemaIndexService.syncCurrentUserDatabaseObjectsWithProject());
+    }
+
 
 }

server/odc-service/src/main/java/com/oceanbase/odc/metadb/connection/DatabaseRepository.java

@@ -46,6 +46,9 @@ public interface DatabaseRepository extends JpaRepository<DatabaseEntity, Long>,
 
     List<DatabaseEntity> findByProjectIdAndExisted(Long projectId, Boolean existed);
 
+    List<DatabaseEntity> findByProjectIdInAndExistedAndObjectSyncStatusNot(Collection<Long> projectIds, Boolean existed,
+            DBObjectSyncStatus dbObjectSyncStatus);
+
     List<DatabaseEntity> findByIdIn(Collection<Long> ids);
 
     List<DatabaseEntity> findByNameIn(Collection<String> name);

server/odc-service/src/main/java/com/oceanbase/odc/service/connection/database/DatabaseService.java

@@ -459,6 +459,17 @@ public Set<Database> listExistDatabasesByProjectId(@NonNull Long projectId) {
                 .map(databaseMapper::entityToModel).collect(Collectors.toSet());
     }
 
+    @SkipAuthorize("internal usage")
+    public Set<Database> listExistAndNotPendingDatabasesByProjectIdIn(@NonNull Collection<Long> projectIds) {
+        if (CollectionUtils.isEmpty(projectIds)) {
+            return Collections.emptySet();
+        }
+        return databaseRepository
+                .findByProjectIdInAndExistedAndObjectSyncStatusNot(projectIds, true, DBObjectSyncStatus.PENDING)
+                .stream()
+                .map(databaseMapper::entityToModel).collect(Collectors.toSet());
+    }
+
     @SkipAuthorize("internal usage")
     public Set<Database> listDatabaseByNames(@NotEmpty Collection<String> names) {
         return databaseRepository.findByNameIn(names).stream().map(databaseMapper::entityToModel)

server/odc-service/src/main/java/com/oceanbase/odc/service/db/schema/DBSchemaIndexService.java

@@ -199,6 +199,18 @@ public QueryDBObjectResp listDatabaseObjects(@NonNull @Valid QueryDBObjectParams
         return resp;
     }
 
+    public Boolean syncCurrentUserDatabaseObjectsWithProject() {
+        this.databaseService.refreshExpiredPendingDBObjectStatus();
+        long userId = authenticationFacade.currentUserId();
+        Set<Long> joinedProjectIds = projectService.getMemberProjectIds(userId);
+        if (CollectionUtils.isEmpty(joinedProjectIds)) {
+            return true;
+        }
+        dbSchemaSyncTaskManager
+                .submitTaskByDatabases(databaseService.listExistAndNotPendingDatabasesByProjectIdIn(joinedProjectIds));
+        return true;
+    }
+
     public Boolean syncDatabaseObjects(@NonNull @Valid SyncDBObjectReq req) {
         this.databaseService.refreshExpiredPendingDBObjectStatus();
         Set<Database> databases = new HashSet<>();