房间。第一个查询返回空值

Question

在我的Android项目中，我使用Room库来处理SQLite数据库。我使用我的数据库来保存国家电话代码。我的数据库预加载了两个国家（watch大众数据库与国家代码（道：电话代码道）功能）；

@Database(entities = [CountryCode::class], version = 1)
abstract class AppDatabase : RoomDatabase() {
abstract fun createPhoneCodeDao(): PhoneCodeDao

companion object {
    @Volatile
    private var INSTANCE: AppDatabase? = null

    fun getDatabase(context: Context): AppDatabase {
        val tempInstance = INSTANCE
        if (tempInstance != null) {
            return tempInstance
        }
        synchronized(this) {
            val instance = Room.databaseBuilder(
                context.applicationContext,
                AppDatabase::class.java,
                "database"
            ).addCallback(PrepopulationCallback)
                .build()
            INSTANCE = instance
            return instance
        }
    }
}

object PrepopulationCallback : RoomDatabase.Callback() {
    override fun onCreate(db: SupportSQLiteDatabase) {
        super.onCreate(db)
        INSTANCE?.let { database ->
            GlobalScope.launch(Dispatchers.IO) {
                populateDatabaseWithCountryCodes(database.createPhoneCodeDao())
            }
        }
    }

    private fun populateDatabaseWithCountryCodes(dao: PhoneCodeDao) {
        val spainPhoneCode = CountryCode(0, "Spain", 34)
        val rusPhoneCode = CountryCode(1, "Russia", 7)
        val list = LinkedList<CountryCode>()
        list.add(spainPhoneCode)
        list.add(rusPhoneCode)
        dao.insertAllCountryCodes(list)
    }
}
}

国家代码实体

@Entity(tableName = "country_code")
data class CountryCode(
@SerializedName("order")
@ColumnInfo(name = "order_list") val order: Int,
@SerializedName("name")
@ColumnInfo(name = "country_name_eng") val name: String,
@SerializedName("phone_code")
@ColumnInfo(name = "phone_code") val phoneCode: Int
) {
@ColumnInfo(name = "id")
@PrimaryKey(autoGenerate = true)
var id: Long = 0
}

DAO接口

@Dao
interface PhoneCodeDao {

@Insert
fun insertAllCountryCodes(list: List<CountryCode>)

@Query("SELECT phone_code FROM country_code WHERE order_list = :order")
fun selectCountryCodeByOrder(order: Int): Int

}

在我的应用程序中，我按顺序选择国家代码（观察函数selectCountryCodeByOrder（order:Int）：Int）。我在异步｛｝协同例程中异步调用此函数。但我有一个相当奇怪的错误：安装后，我在设备上首次启动我的应用程序并进行查询-查询结果为0（这意味着没有结果）。但在下一次查询和下一次启动期间，它工作得非常出色-它根据order参数返回7和34。所以我对这个错误感到非常困惑。请帮助我解决这个问题

Answer 1

这并不奇怪，数据库是异步预填充的，并且您不会收到实际插入数据的通知。

您可以查看官方AAC样本，特别是要通知的BasicSample：

• 您需要有一个LiveData

.

private final MutableLiveData<Boolean> mIsDatabaseCreated = new MutableLiveData<>();

public static AppDatabase getInstance(final Context context, final AppExecutors executors) {
    if (sInstance == null) {
        synchronized (AppDatabase.class) {
            if (sInstance == null) {
                sInstance = buildDatabase(context.getApplicationContext(), executors);
                sInstance.updateDatabaseCreated(context.getApplicationContext());
            }
        }
    }
    return sInstance;
}

/**
 * Build the database. {@link Builder#build()} only sets up the database configuration and
 * creates a new instance of the database.
 * The SQLite database is only created when it's accessed for the first time.
 */
private static AppDatabase buildDatabase(final Context appContext,
        final AppExecutors executors) {
    return Room.databaseBuilder(appContext, AppDatabase.class, DATABASE_NAME)
            .addCallback(new Callback() {
                @Override
                public void onCreate(@NonNull SupportSQLiteDatabase db) {
                    super.onCreate(db);
                    executors.diskIO().execute(() -> {
                        // ...create the database here

                        // notify that the database was created and it's ready to be used
                        database.setDatabaseCreated();
                    });
                }
            })
        .build();
}

/**
 * Check whether the database already exists and expose it via {@link #getDatabaseCreated()}
 */
private void updateDatabaseCreated(final Context context) {
    if (context.getDatabasePath(DATABASE_NAME).exists()) {
        setDatabaseCreated();
    }
}

private void setDatabaseCreated(){
    mIsDatabaseCreated.postValue(true);
}

>

您需要一个 MediatorLiveData 来使用 0 结果，当结果尚不可用时

mObservableProducts.addSource(mDatabase.productDao().loadAllProducts(),
        productEntities -> {
            if (mDatabase.getDatabaseCreated().getValue() != null) {
                mObservableProducts.postValue(productEntities);
            }
        });

您可以将结果公开为LiveData

Answer 2

这是因为当数据库为空时，它可能正在查询数据库。所以解决这个问题的最好方法是返回一个LiveData，而不是一个原始的int。然后，当数据库被填充时，LiveData将负责更新UI。

 @Query("SELECT phone_code FROM country_code WHERE order_list = :order")
fun selectCountryCodeByOrder(order: Int): LiveData<SomeType>