7x31/databasir
1
0
Fork 0
mirror of https://github.com/vran-dev/databasir.git synced 2025-11-04 16:26:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: npe when sync project

Browse Source
This commit is contained in:
vran
2022-05-05 20:17:43 +08:00
parent 3f2ff6e2ce
commit c52eab66aa
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
api/src/main/java/com/databasir/job/ProjectSyncTaskScheduler.java
View File

@@ -54,7 +54,8 @@ public class ProjectSyncTaskScheduler {
updateSyncTaskStatus(taskId, ProjectSyncTaskStatus.FINISHED, "ok"); updateSyncTaskStatus(taskId, ProjectSyncTaskStatus.FINISHED, "ok");
saveOperationLog(projectId, userId, null); saveOperationLog(projectId, userId, null);
} catch (Exception e) { } catch (Exception e) {
updateSyncTaskStatus(taskId, ProjectSyncTaskStatus.FAILED, e.getMessage()); String result = Objects.requireNonNullElse(e.getMessage(), "unknown");
updateSyncTaskStatus(taskId, ProjectSyncTaskStatus.FAILED, result);
saveOperationLog(projectId, userId, e); saveOperationLog(projectId, userId, e);
throw e; throw e;
} }

5
core/src/main/java/com/databasir/core/domain/document/service/DocumentService.java
View File

@@ -143,13 +143,16 @@ public class DocumentService {
databasirConfig.setIgnoreTableNameRegex(jsonConverter.fromJson(rule.getIgnoreTableNameRegexArray())); databasirConfig.setIgnoreTableNameRegex(jsonConverter.fromJson(rule.getIgnoreTableNameRegexArray()));
databasirConfig.setIgnoreTableColumnNameRegex(jsonConverter.fromJson(rule.getIgnoreColumnNameRegexArray())); databasirConfig.setIgnoreTableColumnNameRegex(jsonConverter.fromJson(rule.getIgnoreColumnNameRegexArray()));
try { try {
if (jdbcConnection == null) {
throw DomainErrors.CONNECT_DATABASE_FAILED.exception();
}
DatabaseMeta databaseMeta = Databasir.of(databasirConfig) DatabaseMeta databaseMeta = Databasir.of(databasirConfig)
.get(jdbcConnection, dataSource.getDatabaseName(), dataSource.getSchemaName()) .get(jdbcConnection, dataSource.getDatabaseName(), dataSource.getSchemaName())
.orElseThrow(DomainErrors.DATABASE_META_NOT_FOUND::exception); .orElseThrow(DomainErrors.DATABASE_META_NOT_FOUND::exception);
return databaseMeta; return databaseMeta;
} finally { } finally {
try { try {
if (!jdbcConnection.isClosed()) { if (jdbcConnection != null && !jdbcConnection.isClosed()) {
jdbcConnection.close(); jdbcConnection.close();
} }
} catch (SQLException e) { } catch (SQLException e) {