提问者:小点点

从服务器获取的数据在房间数据库中复制多次


在我的应用程序中,我使用房间作为数据库缓存。我正在使用改造库从服务器获取数据,并将数据保存在房间数据库中,并在回收器视图中显示来自房间的相同数据。

问题:每当活动开始时,它都会从服务器获取数据并将其保存在房间数据库中,因为相同的数据在回收器视图中显示多次。

我想要什么:我想知道如何检查房间中已经存在的数据是否不应该在房间中保存多次时间,如果服务器上更新了一些新数据,它应该获取新数据并将其保存到房间数据库中。

这是我到目前为止所做的:

UserDao.java

@Dao
public interface UserDao {

@Insert(onConflict = OnConflictStrategy.REPLACE)
void Insert(User... users);

@Query("SELECT * FROM Users")
LiveData<List<User>> getRoomUsers();

}

User.java

@Entity(tableName = "Users")
public class User {

@PrimaryKey
private String id;

@ColumnInfo(name = "name")
@SerializedName("name")
@Expose
private String name;

@ColumnInfo(name = "age")
@SerializedName("age")
@Expose
private String age;

public User(String id,String name, String age) {
    this.id = id; 
    this.name = name;
    this.age = age;
}

public String getId() {
    return id;
}

public void setId(String id) {
    this.id = id;
}

public String getName() {
    return name;
}

public void setName(String name) {
    this.name = name;
}

public String getAge() {
    return age;
}

public void setAge(String age) {
    this.age = age;
}
}

UserRepository.java

public class UserRepository {

private Context context;
private UserDb userDb;
private LiveData<List<User>> listLiveData;

public UserRepository(Context context) {
    this.context = context;
    userDb = UserDb.getInstance(context);
    listLiveData = userDb.userDao().getRoomUsers();
}

public void getUserList(){

          Retrofit retrofit = RetrofitClient.getInstance();
          ApiService apiService = retrofit.create(ApiService.class);

          Call<List<User>> userList = apiService.getUser();

          userList.enqueue(new Callback<List<User>>() {
              @Override
              public void onResponse(Call<List<User>> call, final Response<List<User>> response) {

                  Completable.fromAction(new Action() {
                          @Override
                          public void run() throws Exception {

                              if(response.body() != null) {

                                  List<User> list = response.body();

                                  for (int i = 0; i < list.size(); i++) {

                                      String names = list.get(i).getName();
                                      String age = list.get(i).getAge();
                                      String id = UUID.randomUUID().toString();


                                      User user = new User(id,names,age);

                                      userDb.userDao().Insert(user);
                                  }

                              }

                          }
                      }).subscribeOn(Schedulers.io())
                        .observeOn(AndroidSchedulers.mainThread())
                        .subscribe(new CompletableObserver() {
                            @Override
                            public void onSubscribe(Disposable d) {

                            }

                            @Override
                            public void onComplete() {

                                Toast.makeText(context,"Data inserted",Toast.LENGTH_SHORT).show();
                            }

                            @Override
                            public void onError(Throwable e) {

                                Toast.makeText(context,e.getMessage(),Toast.LENGTH_SHORT).show();
                            }
                        });


              }

              @Override
              public void onFailure(Call<List<User>> call, Throwable t) {
                  Toast.makeText(context,t.getMessage(),Toast.LENGTH_LONG).show();
              }
          });

}

public LiveData<List<User>> getRoomUsers(){

    return listLiveData;
}
}

UserViewModel.java

public class UserViewModel extends AndroidViewModel {

private UserRepository repo;
private LiveData<List<User>> listLiveData;

public UserViewModel(@NonNull Application application) {
    super(application);

    repo = new UserRepository(application);
    listLiveData = repo.getRoomUsers();

}

public LiveData<List<User>> getListLiveData() {
    return listLiveData;
}
}

MainActivity.java

public class MainActivity extends AppCompatActivity {

UserRepository userRepository;
RecyclerView recyclerView;
UserViewModel userModel;
List<User> userList;
UserAdapter adapter;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    Toolbar toolbar = findViewById(R.id.toolbar);
    setSupportActionBar(toolbar);

    userRepository = new UserRepository(this);
    userModel = ViewModelProviders.of(this).get(UserViewModel.class);

    recyclerView = findViewById(R.id.recyclerView);
    recyclerView.setHasFixedSize(true);
    recyclerView.setLayoutManager(new LinearLayoutManager(this));

    userList = new ArrayList<>();

    adapter = new UserAdapter(userList,this);
    recyclerView.setAdapter(adapter);

    userModel.getListLiveData().observe(this, new Observer<List<User>>() {

        @Override
        public void onChanged(List<User> users) {
            adapter.setUserList(users);
        }
    });

    FloatingActionButton fab = findViewById(R.id.fab);
    fab.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View view) {
            Intent i = new Intent(MainActivity.this,AddUser.class);
            startActivity(i);
        }
    });

    userRepository.getUserList();
}

在MainActivity.javauserReposory. getUserList()从服务器获取数据并将其保存在房间数据库中。

有人请告诉我如何才能得到想要的结果。任何帮助都将不胜感激。

谢谢


共3个答案

匿名用户

正如@a_local_nobody所说,把这个加到你的道上。

@Insert(onConflict = OnConflictStrategy.REPLACE)

但是这并不能完全解决您的问题。如果您看到SQLite文档,它说

The ON CONFLICT clause applies to UNIQUE, NOT NULL, CHECK, and PRIMARY KEY constraints. The ON CONFLICT algorithm does not apply to FOREIGN KEY constraints.

您的实体定义了一个主键,但它被标记为autoGenerate=true。因此,每当您创建一个新的User实例并在您的道室上调用插入时,都会生成一个新的主键。这个id与您数据库中的“重复”User不冲突,因此Room很乐意在不触及以前的“重复”版本的情况下插入这个。

解决方案是拥有来自后端的主键或在User实体的一个字段上具有UNIQUE约束。

匿名用户

考虑查看此room注释:

@Insert(onConflict = OnConflictStrategy.REPLACE)

有了这个,如果你插入任何已经存在的东西,它会简单地替换它。

你在哪里打电话:

@覆盖公共无效onChanged(列表

尝试先清除适配器的列表

匿名用户

任何未来的人。最好的方法是在插入新数据之前删除表。例如。

在您的@道类中定义@删除查询

@Query("DELETE FROM Users")
void deleteAllUsersData();

并在将新数据插入数据库之前每次调用此查询。如果您想要相同的主键,请将@主键自动生成设置为false。