android - 从服务器获取的数据在房间数据库中复制了多次
问题描述
在我的应用程序中,我使用房间作为数据库缓存。我正在使用改造库从服务器获取数据并将数据保存在房间数据库中,并在回收站视图中显示房间中的相同数据。
问题:每当活动开始时,它都会从服务器获取数据并将其保存在房间数据库中,因为相同的数据会在回收站视图中多次显示。
我想要什么:我想知道如何检查房间中已经存在的数据是否不应该在房间中保存多次,如果服务器上更新了一些新数据,它应该获取新数据并将其保存到房间数据库中。
这是我到目前为止所做的:
用户道.java
@Dao
public interface UserDao {
@Insert(onConflict = OnConflictStrategy.REPLACE)
void Insert(User... users);
@Query("SELECT * FROM Users")
LiveData<List<User>> getRoomUsers();
}
用户.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;
}
}
用户存储库.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;
}
}
用户视图模型.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.java userRepository.getUserList()
从服务器获取数据并将其保存在房间数据库中。
有人请让我知道我怎样才能得到想要的结果。任何帮助,将不胜感激。
谢谢
解决方案
正如@a_local_nobody 所说,将其添加到您的 Dao 中。
@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
实例并调用insert
您的 Dao Room 时,都会生成一个新的主键。这与您数据库中id
的“重复”不冲突User
,因此 Room 很乐意在不触及之前的“重复”版本的情况下插入这个。
解决方案是从后端获取主键或对实体UNIQUE
的一个字段进行约束。User
推荐阅读
- python - 如何提取文本文件的某些部分?
- mysql - LARAVEL 使用功能测试 phpunit 转换列 JSON
- r - 如何从r中矩阵的下三角形获取元素顺序信息
- google-apps-script - 即使触发器存在,getUserTriggers() 也会返回空数组
- mysql - MySQL将值集重复的第一次出现保持为0
- javascript - TypeError: X is not a function / X 已定义但从未使用过
- c# - 将 MVC 项目从 dotnetcore2.1 降级到 dotnet framework 4.61
- azure - 无法重置工作帐户的密码,因为“没有为您的组织正确设置密码重置”。
- python - 如果存在于python数据框中,如何获得带有NULL字符串的组合列
- apache-spark - pyspark中的增量批处理