@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
    //upgrade db
    Log.d(LOG_TAG, "DB UPGRADE ("+oldVersion+":"+newVersion+")");

    if(oldVersion<2 && newVersion<4) {
        this.resetShipment(db);
    }
    if(oldVersion<3) {
        this.resetKits(db);
        this.resetProducts(db);
        this.resetCustomers(db);
    }
    if(oldVersion<4) {
        ContentValues cv = new ContentValues();
        Cursor cur = null;
        String query = new String();

        try {
            db.execSQL("ALTER TABLE " + DbSchema.ShipmentSchema.TABLE_NAME + " ADD " + DbSchema.ShipmentSchema.COLUMN_SHIP_ID + " TEXT NOT NULL;");
        } catch (Exception e) {
            Log.d(LOG_TAG, "error updating database:  ALTER TABLE " + DbSchema.ShipmentSchema.TABLE_NAME + " ADD " + DbSchema.ShipmentSchema.COLUMN_SHIP_ID + " TEXT NOT NULL;");
        }

        cv = new ContentValues();
        try {
            query = "SELECT " + DbSchema.ShipmentSchema.COLUMN_ID + " FROM " + DbSchema.ShipmentSchema.TABLE_NAME;
            cur = db.rawQuery(query, null);
            if(cur!=null) {
                cur.moveToFirst();
                String kit_id = null;
                Integer id = 0;
                Log.d(LOG_TAG, "DB UPGRADE ("+oldVersion+":"+newVersion+") begin cursor traversal");
                do {
                    kit_id = null;
                    id = 0;
                    cv = new ContentValues();
                    try {
                        kit_id = cur.getString(cur.getColumnIndex(DbSchema.ShipmentSchema.COLUMN_ID));
                        cv.put(DbSchema.ShipmentSchema.COLUMN_ID, kit_id);
                        cv.put(DbSchema.ShipmentSchema.COLUMN_SHIP_ID, "Restored Shipment");
                        db.update(DbSchema.ShipmentSchema.TABLE_NAME, cv, DbSchema.ShipmentSchema.COLUMN_ID+"=?", new String[] { kit_id });
                    } catch(Exception e) {
                        Log.d(LOG_TAG, "error upgrading database: " + e.getMessage());
                    }
                } while(cur.moveToNext());
                cur.close();
            }
        } catch (Exception e) {
            Log.d(LOG_TAG, "error updating database:  "+query);
            cur.close();
        }
    }
}