如何在工作管理器中访问房间数据库以定期同步？

Question

我想定期同步 Room 数据库。我正在使用工作管理器来做到这一点。我已经创建了定期工作请求，并且想要发送带有 的表格setInputData(TABLE HERE..)。我想知道我是否做得对。如果正确，我如何定期将表格发送给工作经理？如果错误，请帮我提供合适的解决方案。

这是我的代码：

//schedule recurring task only once
//Fragment
    if(!SessionManager.getBoolenFromPreferences(getActivity(),REFRESH_ATTENDANCE)){
        attendanceViewModel.setupPeriodicRefreshWork();
        SessionManager.putBoolenInPreferences(getActivity(), true, REFRESH_ATTENDANCE);
    }

//view model
public void setupPeriodicRefreshWork() {
    AttendanceScheduler.refreshWork();
}

//Scheduler
public static void refreshWork() {

    //define constraints
    Constraints myConstraints = new Constraints.Builder()
            .setRequiredNetworkType(NetworkType.CONNECTED)
            .build();

  //How to Set Data Here ?
    Data source = new Data.Builder()
            .put(HERE)
            .build();

    PeriodicWorkRequest refreshWork =
            new PeriodicWorkRequest.Builder(AttendanceWorker.class, 1, TimeUnit.HOURS)
                    .setConstraints(myConstraints)
                    .setInputData(source)
                    .build();

    WorkManager.getInstance().enqueue(refreshWork);
}

这是我的工人代码：

public class AttendanceWorker extends Worker {

    private Executor executor;
    private static final String TAG = "AttendanceWorker";

    public AttendanceWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
        super(context, workerParams);
        executor = Executors.newSingleThreadExecutor();
    }


    @SuppressLint("CheckResult")
    @NonNull
    @Override
    public Result doWork() {
        Context context = getApplicationContext();
        AttendanceDao attendanceDao = DatabaseInstance.getInstance(context).attendanceDao();
        Attendance attendance = attendanceDao.getAttendanceDetailsForSync();
        NetworkUtils.getAPIService().saveAttendanceDetails(attendance).compose(RxUtils.applySchedulers())
                .subscribe(
                        (AttendanceResponse attendanceResponse) -> executor.execute(() ->
                        {
                            if (attendanceResponse != null) {
                                if (attendanceResponse.getResult().equals("1")) {
                                    Log.d(TAG, "Attendance Synced!");
                                }
                            }
                        }),
                        Throwable::printStackTrace
                );
        return Result.success();
    }

}