import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
@Singleton
@Provides
public EntityDataStore<Persistable> provideDatabaseSource() {
    Observable.<Void>just(null).observeOn(Schedulers.io()).subscribe(new Action1<Void>() {
        @Override
        public void call(Void aVoid) {
            raw2data(app, DB_NAME, R.raw.books);
        }
    });

    DatabaseSource source = new DatabaseSource(app, Models.DEFAULT, DB_NAME, DB_VERSION);
    source.setLoggingEnabled(BuildConfig.DEBUG);
    Configuration configuration = source.getConfiguration();

    return new EntityDataStore<>(configuration);
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
public SqliteFunctionalTest(Type type) {
    EntityModel model = Models.DEFAULT;
    Context context = InstrumentationRegistry.getContext();
    dbName = type.toString().toLowerCase() + ".db";
    switch (type) {
        default:
        case ANDROID:
            dataSource = new DatabaseSource(context, model, dbName, 1);
            break;
        case SUPPORT:
            dataSource = new SqlitexDatabaseSource(context, model, dbName, 1);
            break;
        case SQLCIPHER:
            dataSource = new SqlCipherDatabaseSource(context, model, dbName, "test123", 1);
            break;
    }
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
@NonNull
public ReactiveEntityStore<Persistable> getData() throws RuntimeException {
    if (dataStore == null) {
        // override onUpgrade to handle migrating to a new version
        DatabaseSource source = new DatabaseSource(getReflectedContext(), Models.DEFAULT, 1);
        if (BuildConfig.DEBUG) {
            // use this in development mode to drop and recreate the tables on every upgrade
            source.setTableCreationMode(TableCreationMode.DROP_CREATE);
        }
        Configuration configuration = source.getConfiguration();
        dataStore = ReactiveSupport.toReactiveStore(
                new EntityDataStore<Persistable>(configuration));
    }
    return dataStore;
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
@Inject
public DatabaseManager(Context context, @Named("login") String login) {
    this.context = context;
    this.login = login;
    DatabaseSource source = new DatabaseSource(context, Models.DEFAULT, databaseName(login), 24);
    source.setTableCreationMode(TableCreationMode.DROP_CREATE);
    if (BuildConfig.DEBUG) {
        source.setLoggingEnabled(true);
    }
    dataStore = ReactiveSupport.toReactiveStore(SqlHelper.getDataStore(source));
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
public static EntityDataStore<Persistable> getDataStore(DatabaseSource source) {
    Configuration configuration = new ConfigurationBuilder(source, Models.DEFAULT)
            .setMapping(new MainMapping())
            .setStatementCacheSize(100)
            .setEntityCache(new EntityCacheBuilder(Models.DEFAULT)
                    .useReferenceCache(true)
                    .build())
            .build();
    return new EntityDataStore<>(configuration);
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
@Provides
@Singleton
@Override
public SingleEntityStore<Persistable> provideDataStore(@NonNull final Context poContext) {
    final DatabaseSource loSource = new DatabaseSource(poContext, Models.DEFAULT, "mock_android_starter_alt.sqlite", 1);
    final Configuration loConfiguration = loSource.getConfiguration();
    final SingleEntityStore<Persistable> loDataStore = RxSupport.toReactiveStore(new EntityDataStore<>(loConfiguration));
    return loDataStore;
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
public static SingleEntityStore<Persistable> getData() {
    if (dataStore == null) {
        // override onUpgrade to handle migrating to a new version
        DatabaseSource source = new DatabaseSource(context, Models.DEFAULT, 1);
        Configuration configuration = source.getConfiguration();
        dataStore = RxSupport.toReactiveStore(
                new EntityDataStore<Persistable>(configuration));
    }
    return dataStore;
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
public BlockingEntityStore<Persistable> getData() {
    if (dataStore == null) {
        // override onUpgrade to handle migrating to a new version
        DatabaseSource source = new DatabaseSource(this, Models.DEFAULT, 3);
        Configuration configuration = source.getConfiguration();
        dataStore = new EntityDataStore<Persistable>(configuration);
    }
    return dataStore;
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
@Singleton
@Provides
public EntityDataStore<Persistable> provideDatabaseSource() {

    DatabaseSource source = new DatabaseSource(mApplication, Models.DEFAULT, DB_NAME,
            DB_VERSION);
    source.setLoggingEnabled(BuildConfig.DEBUG);
    Configuration configuration = source.getConfiguration();

    return new EntityDataStore<>(configuration);
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
/**
 * @return {@link EntityDataStore} single instance for the application.
 * <p/>
 * Note if you're using Dagger you can make this part of your application level module returning
 * {@code @Provides @Singleton}.
 */
ReactiveEntityStore<Persistable> getData() {
    if (dataStore == null) {
        // override onUpgrade to handle migrating to a new version
        DatabaseSource source = new DatabaseSource(this, Models.DEFAULT, 1);
        if (BuildConfig.DEBUG) {
            // use this in development mode to drop and recreate the tables on every upgrade
            source.setTableCreationMode(TableCreationMode.DROP_CREATE);
        }
        Configuration configuration = source.getConfiguration();
        dataStore = ReactiveSupport.toReactiveStore(
            new EntityDataStore<Persistable>(configuration));
    }
    return dataStore;
}
 

import io.requery.android.sqlite.DatabaseSource; //导入依赖的package包/类
private void setupDatabase() {
    DatabaseSource source = new DatabaseSource(getTargetContext(), Models.DEFAULT,
            DATABASE_VERSION);
    Configuration configuration = new ConfigurationBuilder(source,
            Models.DEFAULT).setEntityCache(new EmptyEntityCache()).build();
    database = new EntityDataStore<>(configuration).toBlocking();
}