Transakcja bazy danych systemu Android

84

Stworzyłem bazę danych. Chcę przeprowadzić transakcję. SaveCustomer()zawiera więcej niż jedno polecenie wstawiania rekordów do Customer, CustomerControl, Profile, Paymenttabeli w tym czasie.

Gdy użytkownik SaveCustomer()wywoła metodę, dane trafią do tych 4 tabel. Więc Jak mogę dokonać transakcji? Jeśli jedno wstawienie tabeli nie powiodło się, trzeba wszystko wycofać. Na przykład, gdy trzecia tabela wstawia rekord, pojawia się błąd, a następnie muszę cofnąć również poprzednie rekordy wstawiania dwóch tabel.

Zobacz mój kod:

public void saveCustomer(){
    DBAdapter dbAdapter = DBAdapter.getDBAdapterInstance(RetailerOrderKeyActivity.this);
    dbAdapter.openDataBase();
    ContentValues initialValues = new ContentValues();
    initialValues.put("CustomerName",customer.getName());
    initialValues.put("Address",customer.getAddress());
    initialValues.put("CustomerPID",strPID);
    initialValues.put("Date",strDateOnly);
    long n = dbAdapter.insertRecordsInDB("Customer", null, initialValues);

}

Podobnie jest z innymi stwierdzeniami.

Kod DBAdpter to:

public long insertRecordsInDB(String tableName, String nullColumnHack,ContentValues initialValues) {
    long n =-1;
    try {
        myDataBase.beginTransaction();
        n = myDataBase.insert(tableName, nullColumnHack, initialValues);

        myDataBase.endTransaction();
        myDataBase.setTransactionSuccessful();
    } catch (Exception e) {
        // how to do the rollback 
        e.printStackTrace();
    }

    return n;
}

Oto pełny kod:

public class DBAdapter extends SQLiteOpenHelper {

    private static String DB_PATH = "/data/data/com.my.controller/databases/";
    private static final String DB_NAME = "customer";
    private SQLiteDatabase myDataBase;
    private final Context myContext;
    private static DBAdapter mDBConnection;


    private DBAdapter(Context context) {
        super(context, DB_NAME, null, 1);
        this.myContext = context;
        DB_PATH = "/data/data/"
                + context.getApplicationContext().getPackageName()
                + "/databases/";
        // The Android's default system path of your application database is
        // "/data/data/mypackagename/databases/"
    }


    public static synchronized DBAdapter getDBAdapterInstance(Context context) {
        if (mDBConnection == null) {
            mDBConnection = new DBAdapter(context);
        }
        return mDBConnection;
    }


    public void createDataBase() throws IOException {
        boolean dbExist = checkDataBase();
        if (dbExist) {
            // do nothing - database already exist
        } else {
            // By calling following method 
            // 1) an empty database will be created into the default system path of your application 
            // 2) than we overwrite that database with our database.
            this.getReadableDatabase();
            try {
                copyDataBase();
            } catch (IOException e) {
                throw new Error("Error copying database");
            }
        }
    }


    private boolean checkDataBase() {
        SQLiteDatabase checkDB = null;

        try {
            String myPath = DB_PATH + DB_NAME;
            checkDB = SQLiteDatabase.openDatabase(myPath, null,SQLiteDatabase.OPEN_READONLY);

        } catch (SQLiteException e) {
            // database does't exist yet.
        }
        if (checkDB != null) {
            checkDB.close();
        }
        return checkDB != null ? true : false;
    }


    private void copyDataBase() throws IOException {
        InputStream myInput = myContext.getAssets().open(DB_NAME);
        String outFileName = DB_PATH + DB_NAME;
        OutputStream myOutput = new FileOutputStream(outFileName);  
    byte[] buffer = new byte[1024];
        int length;
        while ((length = myInput.read(buffer)) > 0) {
            myOutput.write(buffer, 0, length);
        }
            // Close the streams
        myOutput.flush();
        myOutput.close();
        myInput.close();
    }

    /**
     * Open the database
     * @throws SQLException
     */
    public void openDataBase() throws SQLException {
        String myPath = DB_PATH + DB_NAME;
        myDataBase = SQLiteDatabase.openDatabase(myPath, null, SQLiteDatabase.OPEN_READWRITE);      
    }


    @Override
    public synchronized void close() {
        if (myDataBase != null)
            myDataBase.close();
        super.close();
    }

    /**
     * Call on creating data base for example for creating tables at run time
     */
    @Override
    public void onCreate(SQLiteDatabase db) {
    }


    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        db.execSQL("ALTER TABLE WMPalmUploadControl ADD Testing int");

    }

    public void upgradeDb(){
        onUpgrade(myDataBase, 1, 2);
    }

    public Cursor selectRecordsFromDB(String tableName, String[] tableColumns,
            String whereClase, String whereArgs[], String groupBy,
            String having, String orderBy) {
        return myDataBase.query(tableName, tableColumns, whereClase, whereArgs,
                groupBy, having, orderBy);
    }


    public ArrayList<ArrayList<String>> selectRecordsFromDBList(String tableName, String[] tableColumns,
            String whereClase, String whereArgs[], String groupBy,
            String having, String orderBy) {        

        ArrayList<ArrayList<String>> retList = new ArrayList<ArrayList<String>>();
          ArrayList<String> list = new ArrayList<String>();
          Cursor cursor = myDataBase.query(tableName, tableColumns, whereClase, whereArgs,
                    groupBy, having, orderBy);        
          if (cursor.moveToFirst()) {
             do {
                 list = new ArrayList<String>();
                 for(int i=0; i<cursor.getColumnCount(); i++){                   
                     list.add( cursor.getString(i) );
                 }   
                 retList.add(list);
             } while (cursor.moveToNext());
          }
          if (cursor != null && !cursor.isClosed()) {
             cursor.close();
          }
          return retList;

    }   


    public long insertRecordsInDB(String tableName, String nullColumnHack,ContentValues initialValues) {
        long n =-1;
        try {
            myDataBase.beginTransaction();
            n = myDataBase.insert(tableName, nullColumnHack, initialValues);

            myDataBase.endTransaction();
            myDataBase.setTransactionSuccessful();
        } catch (Exception e) {
            // how to do the rollback 
            e.printStackTrace();
        }

        return n;
    }


    public boolean updateRecordInDB(String tableName,
            ContentValues initialValues, String whereClause, String whereArgs[]) {
        return myDataBase.update(tableName, initialValues, whereClause,
                whereArgs) > 0;             
    }

    public int updateRecordsInDB(String tableName,
            ContentValues initialValues, String whereClause, String whereArgs[]) {
        return myDataBase.update(tableName, initialValues, whereClause, whereArgs);     
    }


    public int deleteRecordInDB(String tableName, String whereClause,
            String[] whereArgs) {
        return myDataBase.delete(tableName, whereClause, whereArgs);
    }


    public Cursor selectRecordsFromDB(String query, String[] selectionArgs) {
        return myDataBase.rawQuery(query, selectionArgs);       
    }


    public ArrayList<ArrayList<String>> selectRecordsFromDBList(String query, String[] selectionArgs) {       
          ArrayList<ArrayList<String>> retList = new ArrayList<ArrayList<String>>();
          ArrayList<String> list = new ArrayList<String>();
          Cursor cursor = myDataBase.rawQuery(query, selectionArgs);            
          if (cursor.moveToFirst()) {
             do {
                 list = new ArrayList<String>();
                 for(int i=0; i<cursor.getColumnCount(); i++){                   
                     list.add( cursor.getString(i) );
                 }   
                 retList.add(list);
             } while (cursor.moveToNext());
          }
          if (cursor != null && !cursor.isClosed()) {
             cursor.close();
          }
          return retList;
       }

}

problem z blokadą bazy danych w HTC Desire .

Chcę wycofać zmiany, jeśli wystąpiły jakiekolwiek problemy podczas wstawiania danych tabeli.

Proszę pomóż mi

Dzięki.

Wyglądałem na to samo powiązane pytanie:

Kartheepan
źródło

Odpowiedzi:

279

Właściwie robisz źle. Musisz ustawić rozpoczęcie transakcji, jeśli masz wiele rekordów do wstawienia do bazy danych lub jeśli musisz wycofać dane z innej tabeli, jeśli występuje problem z wstawieniem danych do jednej z tabeli bazy danych.

Na przykład

Masz dwa stoły

  1. ZA
  2. b

Teraz chcesz wstawić dane do tych dwóch tabel, ale będziesz musiał wycofać transakcję, jeśli wystąpi błąd w momencie wstawiania danych do tabel.

Teraz pomyślnie wstawiłeś dane do tabeli A, a teraz próbujesz wstawić dane do tabeli B.Teraz, jeśli pojawi się błąd w momencie wstawiania danych do tabeli B, musisz usunąć odpowiednie dane z tabeli A, co oznacza, że muszą wycofać transakcję.

Jak korzystać z transakcji bazy danych w systemie Android

  1. Jeśli chcesz rozpocząć transakcję, jest metoda beginTransaction()
  2. Jeśli chcesz zatwierdzić transakcję, istnieje metoda, setTransactionSuccessful()która zatwierdzi wartości w bazie danych
  3. Jeśli rozpocząłeś transakcję, musisz ją zamknąć, więc istnieje metoda, endTransaction()która zakończy transakcję w bazie danych

Teraz są dwa główne punkty

  1. Jeśli chcesz transakcji ustawionej sukces trzeba napisać setTransactionSuccessful(), a następnie endTransaction()pobeginTransaction()
  2. Jeśli chcesz wycofać swoją transakcję, musisz to zrobić endTransaction()bez zatwierdzania transakcji do dnia setTransactionSuccessful().

Możesz uzyskać szczegółowe informacje o transakcji w bazie danych SQLite tutaj

W Twoim przypadku

Możesz wywołać swoją saveCustomer()funkcję w blokach try and catch

db.beginTransaction();
try {
    saveCustomer();
    db.setTransactionSuccessful();
} catch {
    //Error in between database transaction 
} finally {
    db.endTransaction();
}
Dharmendra
źródło
11
Powinieneś dodać endTransactionswój ostatni, a nie blok try.
VansFannel
6
@VansFannel, masz rację, w końcu jest najlepszym miejscem do zamknięcia transakcji w bazie danych. dzięki za ulepszenie.
Dharmendra
25

powinieneś dodać endTransactionswój finally, a nie blok try

 finally {
     myDataBase.endTransaction();
   }

Zmiany zostaną wycofane, jeśli jakakolwiek transakcja zostanie zakończona bez oznaczenia jako czysta (przez wywołanie setTransactionSuccessful). W przeciwnym razie zostaną popełnieni.

Labeeb Panampullan
źródło
1
Dzięki za informację. W moim 'SaveCustomer () `wywołam' long n = dbAdapter.insertRecordsInDB (" Customer ", null, initialValues); ' w 4 razy z różnymi rekordami. Czy wycofa wszystko, jeśli wystąpi błąd nawet w środkowej tabeli. Mam 4 tabele. Muszę dodać rekordy w 4 tabelach z różnymi rekordami.?
Kartheepan
17

Wstaw rekord za pomocą transakcji, to jest bardzo szybkie

String sql = "INSERT INTO table (col1, col2) VALUES (?, ?)";
db.beginTransaction();

SQLiteStatement stmt = db.compileStatement(sql);
for (int i = 0; i < values.size(); i++) {
    stmt.bindString(1, values.get(i).col1);
    stmt.bindString(2, values.get(i).col2);
    stmt.execute();
    stmt.clearBindings();
}

db.setTransactionSuccessful();
db.endTransaction();
Piyush
źródło