feat(info-query): 增加初始化sync_state接口
This commit is contained in:
@@ -104,6 +104,9 @@ public interface InfoService {
|
||||
@Get("/info/sync_state/save_compaction_id")
|
||||
void saveCompactionId(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("application_id") String applicationId);
|
||||
|
||||
@Get("/info/sync_state/save")
|
||||
void saveSyncState(@Query("id") String id);
|
||||
|
||||
@Get("/info/non_updated_version_tables")
|
||||
ImmutableList<String> nonUpdatedVersionTables();
|
||||
|
||||
|
||||
@@ -39,4 +39,9 @@ public class SyncStateController {
|
||||
) {
|
||||
syncStateService.saveCompactionApplicationId(flinkJobId, alias, applicationId);
|
||||
}
|
||||
|
||||
@GetMapping("/sync_state/save")
|
||||
public void saveCompactionId(@RequestParam("id") String id) {
|
||||
syncStateService.saveSyncState(id);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -101,4 +101,20 @@ public class SyncStateService extends BaseService {
|
||||
applicationId
|
||||
);
|
||||
}
|
||||
|
||||
@Retryable(Throwable.class)
|
||||
public void saveSyncState(String id) {
|
||||
mysqlJdbcTemplate.update(
|
||||
SqlBuilder.insertInto(
|
||||
TbAppHudiSyncState._origin_,
|
||||
TbAppHudiSyncState.ID_O,
|
||||
TbAppHudiSyncState.MESSAGE_ID_O
|
||||
)
|
||||
.values()
|
||||
.addValue(Q, Q)
|
||||
.precompileSql(),
|
||||
id,
|
||||
"-1:-1:-1"
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user