Транзакция базы данных Android

Question

Транзакция базы данных Android

Я создал базу данных. Я хочу сделать транзакцию. SaveCustomer() содержит более одного оператора для вставки записей в Customer, CustomerControl, Profile, Payment стол в то время.

Когда пользователь звонит SaveCustomer() метод, то эти данные будут идти в эти 4 таблицы. Как я могу сделать транзакцию? Если не удалось вставить одну таблицу, нужно откатить все. Например, когда 3-я таблица вставляет запись, в которой я получил ошибку, необходимо также откатить предыдущие две записи таблицы вставки.

Смотрите мой код:

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);

}

Аналогично и другое утверждение тоже есть.

Код DBAdpter:

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 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;
       }

}

проблема блокировки базы данных в HTC Desire.

Я хочу откатиться, если при вставке данных таблицы возникли проблемы.

пожалуйста, помогите мне

Благодарю.

Я посмотрел этот же связанный вопрос:

87

android sqlite transactions

Источник

user877931 16 ноя '11 в 06:06

3 ответа

Другие вопросы по тегам android sqlite transactions

user630668 17 ноя '11 в 06:49 2011-11-17 06:49 · Answer 1 · 2011-11-17 06:49

На самом деле вы делаете не так. Вы должны установить начальную транзакцию, если у вас есть несколько записей для вставки в базу данных или если вам нужно откатить данные из другой таблицы, если есть проблема при вставке данных в одну из таблиц базы данных.

Например

У вас есть две таблицы

В

Теперь вы хотите вставить данные в эти две таблицы, но вам придется откатить транзакцию, если вы получите какую-либо ошибку во время вставки данных в таблицы.

Теперь вы успешно вставили данные в таблицу A, и теперь вы пытаетесь вставить данные в таблицу B. Теперь, если вы получили ошибку во время вставки данных в таблицу B, вам нужно удалить соответствующие данные из таблицы A, что означает, что вы придется откатить транзакцию.

Как вы можете использовать транзакцию базы данных в Android

Если вы хотите начать транзакцию, есть метод beginTransaction()
Если вы хотите совершить транзакцию, есть метод setTransactionSuccessful() который будет фиксировать значения в базе данных
Если вы начали транзакцию, вам нужно закрыть транзакцию, чтобы был метод endTransaction() который завершит вашу транзакцию базы данных

Теперь есть два основных момента

Если вы хотите, чтобы транзакция прошла успешно, вам нужно написать setTransactionSuccessful() а потом endTransaction() после beginTransaction()
Если вы хотите откатить транзакцию, вам нужно endTransaction() без совершения сделки setTransactionSuccessful(),

Вы можете получить подробную информацию о транзакции базы данных SQLite здесь

В твоем случае

Вы можете позвонить saveCustomer() функция в блоки try и catch

db.beginTransaction();
try {
    saveCustomer();
    db.setTransactionSuccessful();
} catch {
    //Error in between database transaction 
} finally {
    db.endTransaction();
}

user477754 16 ноя '11 в 06:16 2011-11-16 06:16 · Answer 2 · 2011-11-16 06:16

Ты должен добавить endTransaction в вашем finally, не в вашем блоке try

 finally {
     myDataBase.endTransaction();
   }

Изменения будут отменены, если какая-либо транзакция будет завершена без пометки как чистые (путем вызова setTransactionSuccessful). В противном случае они будут совершены.

25

Источник

user477754 16 ноя '11 в 06:16

user729405 26 апр '14 в 17:47 2014-04-26 17:47 · Answer 3 · 2014-04-26 17:47

Вставить запись с помощью транзакции, это очень быстро

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();

19

Источник

user729405 26 апр '14 в 17:47