Я хочу использовать ROOM с Rxjava, это мои коды:
мой класс структуры базы данных:
@Entity(tableName = "productSample1")
public class ProductEntity {
@PrimaryKey(autoGenerate = true)
private int id;
private String name;
private String price;
public ProductEntity(int id, String name, String price) {
this.id = id;
this.name = name;
this.price = price;
}
@Ignore
public ProductEntity(String name, String price) {
this.name = name;
this.price = price;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPrice() {
return price;
}
public void setPrice(String price) {
this.price = price;
}
}
это мой класс ProductDAO:
@Dao
public interface ProductDAO {
@Insert(onConflict = OnConflictStrategy.REPLACE)
void insert(ProductEntity productEntity);
@Insert(onConflict = OnConflictStrategy.REPLACE)
void insertAll(List<ProductEntity> products);
@Delete
void delete(ProductEntity productEntity);
@Query("SELECT * FROM productSample1 where id=:id")
ProductEntity getProductById(int id);
@Query("Select * from productSample1 order by id desc")
LiveData<List<ProductEntity>>getAll();
@Query("Select * from productSample1 order by id desc")
Single<List<ProductEntity>> getAllRXjava();
@Query("delete from productSample1")
int deleteAll();
@Query("select count(*) from productSample1")
int getCount();
}
это мой класс базы данных для создания и управления базой данных:
@Database(entities = {ProductEntity.class}, version = 1)
public abstract class AppDatabase extends RoomDatabase {
public static final String DATABASE_NAME="AppDatabase";
private static volatile AppDatabase instance;
private static final Object Lock=new Object();
public abstract ProductDAO productDAO();
public static AppDatabase getInstance(Context context){
if(instance==null){
synchronized (Lock){
if(instance==null){
instance= Room.databaseBuilder(context.getApplicationContext(),
AppDatabase.class,DATABASE_NAME).build();
}
}
}
return instance;
}
}
это моя работа с базой данных:
private AppDatabase mDb;
private ProductDAO mDao;
mDb= AppDatabase.getInstance(this);
mDao=mDb.productDAO();
Log.v("this","dbCreated");
///////////one product
ProductEntity product1=new ProductEntity(1,"prod1","2500");
Completable.fromAction(() ->mDao.insert(product1))
.subscribeOn(Schedulers.io())
.subscribe(new CompletableObserver() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable e) {
Log.v("this","error0 "+ e.getMessage() );
}
});
/////List of Products
List<ProductEntity>productList=new ArrayList<>();
productList.add(new ProductEntity("prod2","3500"));
productList.add(new ProductEntity("prod3","4500"));
productList.add(new ProductEntity("prod4","5500"));
Completable.fromAction(() ->mDao.insertAll(productList))
.subscribeOn(Schedulers.io())
.subscribe(new CompletableObserver() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable e) {
Log.v("this","error1 "+ e.getMessage() );
}
});
//getList of products
mDao.getAllRXjava()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new SingleObserver<List<ProductEntity>>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onSuccess(List<ProductEntity> productEntities) {
for (int i=0;i<productEntities.size();i++){
Log.v("this",productEntities.get(i).getName());
}
}
@Override
public void onError(Throwable e) {
Log.v("this","error "+ e.getMessage() );
}
});
}
вот что происходит, когда я впервые запускаю свой класс активности, ошибки не возникает, когда я загружаю созданную базу данных из эмулятора и открываю ее в менеджере баз данных sqlite, проблема в том, что файл пуст и база данных не создается
когда я возвращаюсь и снова открываю базу данных, я получаю много ошибок:
Cannot run invalidation tracker. Is the db closed?
java.lang.IllegalStateException: Cannot perform this operation because the connection pool has been closed.
at android.database.sqlite.SQLiteConnectionPool.throwIfClosedLocked(SQLiteConnectionPool.java:962)
at android.database.sqlite.SQLiteConnectionPool.waitForConnection(SQLiteConnectionPool.java:599)
at android.database.sqlite.SQLiteConnectionPool.acquireConnection(SQLiteConnectionPool.java:348)
at android.database.sqlite.SQLiteSession.acquireConnection(SQLiteSession.java:894)
at android.database.sqlite.SQLiteSession.executeForChangedRowCount(SQLiteSession.java:752)
at android.database.sqlite.SQLiteStatement.executeUpdateDelete(SQLiteStatement.java:64)
at android.arch.persistence.db.framework.FrameworkSQLiteStatement.executeUpdateDelete(FrameworkSQLiteStatement.java:45)
at android.arch.persistence.room.InvalidationTracker$1.run(InvalidationTracker.java:321)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1080)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:573)
Вы можете мне помочь? что не так с моим кодом?