sql >> Database teknologi >  >> RDS >> SQLite

Hvordan kører man SQLite-forespørgsel asynkront på baggrundstråd?

Denne https://developer.android.com/reference/android/app/LoaderManager.html vil sandsynligvis passe til dig.

Desuden er her en kort implementering til dig, men dette er ikke RxJava.

For det første skal du implementere LoaderManager.LoaderCallbacks<Cursor> , og normalt er denne grænseflade implementeret af Activity (eller Fragment).

I onCreateLoader , en CursorLoader skal oprettes og returneres. Her er blot et eksempel med MyCursorLoader som efterkommer af CursorLoader , hvor du kan udføre forbindelse til database og forespørgsler.

I onLoadFinished du skal behandle markøren med resultaterne af forespørgslen.

Overvej venligst linket til android.com, nævnt ovenfor.

public class MainActivity extends AppCompatActivity implements LoaderManager.LoaderCallbacks<Cursor>{

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
}

@Override
protected void onResume() {
    super.onResume();

    // start loading data using LoaderManager of Activity
    // third argument only has sense in this case
    getLoaderManager().initLoader(0, null, this);
}

private static final String ACTIVITY_NAME = "main_activity";

private void treatCursorRow(Cursor cursor){
    // treat record from cursor
}

@Override
public Loader<Cursor> onCreateLoader(int id, Bundle args) {
    // this callback is called by LoaderManager in order to obtain CursorLoader
    // here a new one loader is created
    // created loader will be processed by LoaderManager
    return new MyCursorLoader(this, ACTIVITY_NAME);
}

@Override
public void onLoadFinished(Loader<Cursor> loader, Cursor data) {
    // this callback is called when loader finishes load cursor
    // you don't need to destroy loader - just tread the data
    if(data != null)
        while(data.moveToNext())
            treatCursorRow(data);
}

@Override
public void onLoaderReset(Loader<Cursor> loader) {
    // here you can do something
    // relevant to cancelling of loading data
    // in example, when you have an event that cancels current
    // loading and restarts new one
}

class MyCursorLoader extends CursorLoader {

    private static final String DATABASE_NAME = "my_database";
    private static final int DATABASE_VERSION = 1;
    private String name_param;

    public MyCursorLoader(Context context, String activity_name) {
        super(context);
        name_param = activity_name;
    }

    @Override
    public Cursor loadInBackground() {
        // assuming, that we have implemented SQLiteOpenHelper
        // to treat sqlite-database
        MyDatabaseHelper dbh = new MyDatabaseHelper(
                MainActivity.this,
                DATABASE_NAME,
                null,
                DATABASE_VERSION
        );
        return dbh.getWritableDatabase().rawQuery(
                "SELECT * FROM some_table WHERE name=?",
                new String[]{ name_param }
        );
    }

}

}

En anden måde er at bruge ContentProvider https://developer.android.com/guide/topics/providers/content-providers.html .

På denne måde kan du adskille datalag og forretningslogik. Din dataadgang vil blive abstraheret til uris.Using ContentProvider , definerer du dine forespørgsler i den og indlæser data ved hjælp af Uri:

@Override
public Loader<Cursor> onCreateLoader(int id, Bundle args) {
    return getContentResolver().query(
            YourContentProvider.SOME_URI,
            null,
            null,
            null,
            null
    );
}

Dette er en praktisk måde, hvis du har mere end en eller to kunder til dine data (aktiviteter eller fragmenter) - du vil bruge kun foruddefinerede uris i stedet for at gentage sql-forespørgsler eller oprette mange CursorLoaders descendands .

Desuden ContentProvider kan bruges uden for din app, hvis du vil.




  1. Sådan kontrolleres serverstatus i MySQL Workbench ved hjælp af GUI

  2. implodering af en liste til brug i en python MySQLDB IN-klausul

  3. django.db.utils.ProgrammingError:Relationen eksisterer allerede

  4. Oracle Indsæt via Vælg fra flere tabeller, hvor én tabel muligvis ikke har en række