onUpgrade Fehler bei DB

marco.deubel · 27. März 2012

Hey
ich möchte meine DB updaten und von einer alten Tabelle in eine neue Werte übernehmen. Dies wollte ich über die Methode onUpgrade machen. Wenn ich jetzt die Version auf 2 hoch setzte und eine Nachricht im Log über Log.v(... ausgeben lasse geht das super. Jetzt möchte ich aber die Werte der alten Tabelle in die neue schreiben mit ein paar formatierungen der Werte. Wenn ich jetzt .getWritableDatabase aufrufe, dann bekomme ich eine Laufzeitfehler mit der Nachricht "Database is locked" im Log. Wenn ich .getWritableDatabase nicht aufrufe bekomme ich eine null pointer exception, was ja klar ist da die DB erst mal geöffnet werden muss.
Was muss ich denn machen, damit die Datenbank nicht gelocked wird oder ist?

Schon mal vielen Dank im voraus

LG
Marco

matthias · 27. März 2012

Hi Marco,

ich habe für den Datenbankzugriff eine eigene Klasse die von SQLiteOpenHelper erbt. die onUpgrade sieht so aus:

Java

public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
		String[] sqls = context.getResources().getStringArray(R.array.upgrade); 
		for (String sql : sqls) {
			db.execSQL(sql);
		}
	}

Die Datenbank ist ein Übergabeparameter, mit der muss ich nichts weiter anstellen. Mein String[] enthält zwar nur UPDATE Anweisungen aber das müsste analog laufen. Wenn doch ein Lock drauf liegt der nicht weg will, kannst du dir nicht erst alle alten werte raus ziehen, formatieren wie du willst, in einer geeigneten Datenstruktur zwischenspeichern und dann in einer zweiten for-schleife in die nächste Datenbank klopfen?

Schreib mal wie genau du die Datenbankverbindung aufbaust, ob du überhaupt SQLite benutzt (ich bin jetzt einfach mal davon ausgegangen) und wie deine onUpgrade bisher aussieht, falls es nicht geht.

Gruß,
matze

marco.deubel · 27. März 2012

Hey Matthias danke für die schnelle Antwort

das verstehe ich aber nicht ganz. Ich dachte einfach, dass die Methode aufgerufen wird wenn die Version hoch gesetzt wird. Das klappt ja auch bei mir. Und dann habe ich folgendes gemacht: (Ich schreibe jetzt mal den gesamten Quellcode meiner DB hier rein):

Java

public class BerechnerDbAdapter {
	
	private onUpgradeHelper helper;
 
	private static final String DATABASE_NAME = "data";
	private static final String DATABASE_TABLE = "berechner";
	private static final String DATABASE_TABLE2 = "database";
	private final int DATABASE_VERSION = 2;
	
	public static final String KEY_ROWID = "_id";
	public static final String KEY_PREISLITER = "PreisProLiter";
	public static final String KEY_PREIS = "Preis";
	public static final String KEY_LITER = "Liter";
	public static final String KEY_KM = "KM";
	public static final String KEY_DATUM = "Datum";
	public static final String KEY_YEAR = "mwaka";
	public static final String KEY_MONTH = "mwezi";
	public static final String KEY_DAY = "siku";
	public static final String KEY_HOUR = "saa";
	public static final String KEY_MINUTE = "dakika";
	public static final String KEY_SECOND = "pili";
	
	//rawQuery Strings:
	public static final String SQLLiterSumme = "SELECT SUM(" + KEY_LITER + ") FROM " + DATABASE_TABLE2 + " WHERE " + KEY_YEAR + " = 2012 GROUP BY " + KEY_MONTH + " ORDER BY " + KEY_MONTH + ";";
	public static final String SQLLiterGesammt = "SELECT SUM(" + KEY_LITER + ") FROM " + DATABASE_TABLE2 + " WHERE " + KEY_YEAR + " = 2012;";
	public static final String SQLKostenSumme = "SELECT SUM(" + KEY_PREIS + ") FROM " + DATABASE_TABLE2 + " WHERE " + KEY_YEAR + " = 2012 GROUP BY " + KEY_MONTH + " ORDER BY " + KEY_MONTH + ";";
	public static final String SQLKostenGesammt = "SELECT SUM(" + KEY_PREIS + ") FROM " + DATABASE_TABLE2 + " WHERE " + KEY_YEAR + " = 2012;";
	
	//Kalender Strings:
	private Calendar mCalendar;
	private static final String DATE_FORMAT = "dd.MM.yyyy";
	private static final String TIME_FORMAT = "kk:mm";
	private static final String DATE_TIME_FORMAT = "dd.MM.yyyy kk:mm:ss";
	private static final String HOUR_FORMAT = "kk";
	private static final String MINUTE_FORMAT = "mm";
	private static final String YEAR_FORMAT = "yyyy";
	private static final String MONTH_FORMAT = "MM";
	private static final String DAY_FORMAT = "dd";
	private static final String SECOND_FORMAT = "ss";
	
	private DatabaseHelper mDbHelper;
	private SQLiteDatabase mDb;
	
	private static final String DATABASE_CREATE = "create table " + DATABASE_TABLE + " ("
			+ KEY_ROWID + " INTEGER PRIMARY KEY AUTOINCREMENT, "
			+ KEY_PREISLITER + " TEXT NOT NULL, "
			+ KEY_LITER  + " TEXT NOT NULL, "
			+ KEY_PREIS + " TEXT NOT NULL, "
			+ KEY_KM + " TEXT NOT NULL, "
			+ KEY_DATUM + " TEXT NOT NULL);";
	
	private static final String DATABASE2_CREATE = "create table " + DATABASE_TABLE2 + " ("
			+ KEY_ROWID + " INTEGER PRIMARY KEY AUTOINCREMENT, "
			+ KEY_LITER  + " REAL, "
			+ KEY_PREIS + " REAL, "
			+ KEY_KM + " REAL, "
			+ KEY_YEAR + " INTEGER, "
			+ KEY_MONTH + " INTEGER, "
			+ KEY_DAY + " INTEGER, "
			+ KEY_HOUR + " INTEGER, "
			+ KEY_MINUTE + " INTEGER, "
			+ KEY_DATUM + " TEXT NOT NULL, "
			+ KEY_SECOND + " INTEGER);";
	
	private final Context mCtx;
	
	public BerechnerDbAdapter(Context ctx){
		this.mCtx = ctx;
	}


	public BerechnerDbAdapter open() throws SQLException{
		mDbHelper = new DatabaseHelper(mCtx);
		mDb = mDbHelper.getWritableDatabase();
	
		return this;
	}
	
	public void close(){
		mDbHelper.close();
	}
	
	public long createBerechner(String PreisProLiter, String Liter, String Preis, String km, String Datum){
		ContentValues initialValues = new ContentValues();
        initialValues.put(KEY_PREISLITER, PreisProLiter);
        initialValues.put(KEY_PREIS, Preis);
        initialValues.put(KEY_LITER, Liter);
        initialValues.put(KEY_KM, km);
        initialValues.put(KEY_DATUM, Datum);
        
        return mDb.insert(DATABASE_TABLE, null, initialValues);
	}
	
	public boolean deleteBerechner(Long rowId){
		if (rowId == null){
			return mDb.delete(DATABASE_TABLE, null, null)&gt;0;	
		}else{
		return mDb.delete(DATABASE_TABLE, KEY_ROWID + "=" + rowId, null)&gt;0;
		}
	}
	
	public long createDatabase(Double Liter, Double Preis, Double km, Integer Jahr, Integer Monat, Integer Tag, Integer Stunde, Integer Minute, Integer Sekunde){
		ContentValues initialValues = new ContentValues();
		String Datum = (Tag + "." + Monat + "." + Jahr + " " + Stunde + ":" + Minute);
        initialValues.put(KEY_PREIS, Preis);
        initialValues.put(KEY_LITER, Liter);
        initialValues.put(KEY_KM, km);
        initialValues.put(KEY_YEAR, Jahr);
        initialValues.put(KEY_MONTH, Monat);
        initialValues.put(KEY_DAY, Tag);
        initialValues.put(KEY_HOUR, Stunde);
        initialValues.put(KEY_MINUTE, Minute);
        initialValues.put(KEY_SECOND, Sekunde);
        initialValues.put(KEY_DATUM, Datum);
        
        return mDb.insert(DATABASE_TABLE2, null, initialValues);
	}
	
	public boolean deleteDatabase(Long rowId){
		if (rowId == null){
			return mDb.delete(DATABASE_TABLE2, null, null)&gt;0;	
		}else{
		return mDb.delete(DATABASE_TABLE2, KEY_ROWID + "=" + rowId, null)&gt;0;
		}
	}
	
	public Cursor fetchAllDatabase(){
		return mDb.query(DATABASE_TABLE2, new String[] {KEY_ROWID, KEY_DATUM}, null, null, null, null, KEY_MONTH + ", " + KEY_DAY);
	
	}
	
	public Cursor fetchAllBerechner(){	
		return mDb.query(DATABASE_TABLE, new String[] {KEY_ROWID, KEY_PREISLITER, KEY_PREIS, KEY_LITER, KEY_KM, KEY_DATUM}, null, null, null, null, null);
	}
	
	public Cursor fetchBerechner(long rowId) throws SQLException{
		
		Cursor mCursor = mDb.query(true, DATABASE_TABLE, new String[] {KEY_ROWID, KEY_PREISLITER, KEY_PREIS, KEY_LITER, KEY_KM, KEY_DATUM}, KEY_ROWID + "=" + rowId, null, null, null, null, null);
	if(mCursor != null){
		mCursor.moveToFirst();
	}
	return mCursor;
	}
	
	
	
	public Cursor fetchLiterSumme () throws SQLException{
		Cursor mCursor = mDb.rawQuery(SQLLiterSumme , null);
				if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	public Cursor fetchLiterGesammt () throws SQLException{
		Cursor mCursor = mDb.rawQuery(SQLLiterGesammt, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchKostenSumme () throws SQLException{
		Cursor mCursor = mDb.rawQuery(SQLKostenSumme , null);
				if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	public Cursor fetchKostenGesammt () throws SQLException{
		Cursor mCursor = mDb.rawQuery(SQLKostenGesammt, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		
		return mCursor;
		
	}
	
	public Cursor fetchMonate () throws SQLException{
		Cursor mCursor = mDb.query(true, DATABASE_TABLE2, new String[] {KEY_MONTH}, KEY_YEAR + " = 2012", null, null, null, KEY_MONTH, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;	
	}
	
public Cursor fetchDatabase(long rowId) throws SQLException{
		
		Cursor mCursor = mDb.query(true, DATABASE_TABLE2, new String[] {KEY_ROWID, KEY_PREIS, KEY_LITER, KEY_KM, KEY_YEAR, KEY_MONTH, KEY_DAY, KEY_HOUR, KEY_MINUTE, KEY_SECOND}, KEY_ROWID + "=" + rowId, null, null, null, null, null);
	if(mCursor != null){
		mCursor.moveToFirst();
	}
	return mCursor;
	}
	
	public Cursor fetchPreis(){
		Cursor mCursor = mDb.query(true, DATABASE_TABLE, new String[] {KEY_PREIS}, null, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchDatum(){
		Cursor mCursor = mDb.query(true, DATABASE_TABLE, new String[] {KEY_DATUM}, null, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchLiter(){
		Cursor mCursor = mDb.query(true, DATABASE_TABLE, new String[] {KEY_LITER}, null, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchKilometer(){
		Cursor mCursor = mDb.query(DATABASE_TABLE, new String[] {KEY_KM}, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchId() {
		Cursor mCursor = mDb.query(true, DATABASE_TABLE, new String[] {KEY_ROWID}, null, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchIdDatabase() {
		Cursor mCursor = mDb.query(true, DATABASE_TABLE2, new String[] {KEY_ROWID}, null, null, null, null, null, null);
		if(mCursor != null){
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	public Cursor fetchPreisMonat(){
	
			Cursor mCursor = mDb.query(true, DATABASE_TABLE2, new String[] {KEY_PREIS}, (KEY_DATUM + " &lt; 20120299"), null, null, null, null, null);
		return mCursor;
	}
	
	public boolean updateBerechner(long rowId, String PreisProLiter, String Preis, String Liter, String km, String Datum){
	ContentValues args = new ContentValues();
    args.put(KEY_PREIS, Preis);
    args.put(KEY_LITER, Liter);
    args.put(KEY_KM, km);
    args.put(KEY_DATUM, Datum);
    
    return mDb.update(DATABASE_TABLE, args, KEY_ROWID + "=" + rowId, null)&gt;0;
	}
	
	public boolean updateDatabase(long rowId, Double Preis, Double Liter, Double km, Integer Jahr, Integer Monat, Integer Tag, Integer Stunde, Integer Minute, Integer Sekunde){
		ContentValues args = new ContentValues();
	    args.put(KEY_PREIS, Preis);
	    args.put(KEY_LITER, Liter);
	    args.put(KEY_KM, km);
	    args.put(KEY_YEAR, Jahr);
	    args.put(KEY_MONTH, Monat);
	    args.put(KEY_DAY, Tag);
	    args.put(KEY_HOUR, Stunde);
	    args.put(KEY_MINUTE, Minute);
	    args.put(KEY_SECOND, Sekunde);
	    
	    return mDb.update(DATABASE_TABLE2, args, KEY_ROWID + "=" + rowId, null)&gt;0;
		}
	
	
	


	public class DatabaseHelper extends SQLiteOpenHelper {
	       DatabaseHelper(Context context) {
	    	super(context, DATABASE_NAME, null, DATABASE_VERSION);   
	       }
	       
	       @Override
	       public void onCreate(SQLiteDatabase db){
	    	   db.execSQL(DATABASE2_CREATE);
	    	   db.execSQL(DATABASE_CREATE);
	    	   
	       }
	       
	       @Override
	       public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion){
	    	   Log.v("DatabaseHelper", "Datenbank Upgrade von " + oldVersion + " auf " + newVersion);
	    	open();   
                if (oldVersion &lt; 2 && newVersion == 2) {
	   	Cursor CursorOldTable = fetchId();
		CursorOldTable.moveToPosition(-1);
		ArrayList&lt;Integer&gt; id = new ArrayList&lt;Integer&gt;();
		while (CursorOldTable.moveToNext()) {
			id.add(Integer.parseInt(CursorOldTable.getString(0)));
		}
		CursorOldTable.close();
		
		if (id.size() &gt; 0){
			for (int i=0;id.size()&gt;i;i++){
				CursorOldTable = fetchLiter();
				Double liter = Double.parseDouble(CursorOldTable.getString(i));
				CursorOldTable.close();
				CursorOldTable = fetchPreis();
				Double preis = Double.parseDouble(CursorOldTable.getString(i));
				CursorOldTable.close();
				CursorOldTable = fetchKilometer();
				Double km = Double.parseDouble(CursorOldTable.getString(i));
				CursorOldTable.close();
				CursorOldTable = fetchDatum();
				SimpleDateFormat dateTimeFormat = new SimpleDateFormat(DATE_TIME_FORMAT);
			    Date date = null;
				try{
			    	String dateString = CursorOldTable.getString(i);
			    	date = dateTimeFormat.parse(dateString);
			    	mCalendar.setTime(date);
			    } catch (ParseException e) {
			    	Log.e("BerechnerActivity", e.getMessage(), e);
			    }
				CursorOldTable.close();
			    mCalendar.setTime(date);
				SimpleDateFormat yearFormat = new SimpleDateFormat(YEAR_FORMAT);
		    	SimpleDateFormat monthFormat = new SimpleDateFormat(MONTH_FORMAT);
		    	SimpleDateFormat dayFormat = new SimpleDateFormat(DAY_FORMAT);
		    	SimpleDateFormat hourFormat = new SimpleDateFormat(HOUR_FORMAT);
		    	SimpleDateFormat minuteFormat = new SimpleDateFormat(MINUTE_FORMAT);
		    	SimpleDateFormat secondFormat = new SimpleDateFormat(SECOND_FORMAT);    	
		    	Integer Jahr =Integer.parseInt(yearFormat.format(mCalendar.getTime()));
		    	Integer Monat =Integer.parseInt(monthFormat.format(mCalendar.getTime()));
		    	Integer Tag =Integer.parseInt(dayFormat.format(mCalendar.getTime()));
		    	Integer Stunde =Integer.parseInt(hourFormat.format(mCalendar.getTime()));
		    	Integer Minute =Integer.parseInt(minuteFormat.format(mCalendar.getTime()));
		    	Integer Sekunde =Integer.parseInt(secondFormat.format(mCalendar.getTime()));
		    	createDatabase(liter, preis, km, Jahr, Monat, Tag, Stunde, Minute,  Sekunde);
			}
		}
	}	
	   		}
	    }


		
	}
	
	
	
	
}

Alles anzeigen

So und damit kommt die Fehlermeldung "Database is locked" im Log, ohne das überhaupt die nachricht im Log ausgegeben wird, welche eigentlich ganz am Anfang von onUpgrade steht. Und wenn ich das "open()" unter der Log Nachricht in onUpgrade entferne, dann kommt besagte null pointer exception und auch keine Nachricht im Log.
Ich bin ratlos

Irgendetwas mache ich wohl falsch

LG
Marco

matthias · 27. März 2012

Uff

Du nimmst ja deinen Übergabeparameter gar nicht her ...

Java

@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion){
	Log.v("DatabaseHelper", "Datenbank Upgrade von " + oldVersion + " auf " + newVersion);
	open();   
	if (oldVersion &lt; 2 && newVersion == 2) {
		Cursor CursorOldTable = fetchId();
		CursorOldTable.moveToPosition(-1);
		...	
	}
}

Da in fetchId musst du den Übergabeparameter "db" mit geben bzw deine Variable "mDb" setzen.

EDIT: und das open() gehört weg

marco.deubel · 28. März 2012

Hey danke schon mal für die Tipps und die Zeit die du dir genommen hast

Ich blicke da aber noch nicht ganz durch und habe noch ein paar Fragen

Für was bracht man den Übergabeparameter? Was übergibt er und wo für? Wie benutze ich ihn, also wie implementiere ich in im Java Quell Text?

Es wäre super wenn du mir diese paar Fragen noch beantworten könntest

Vielen Dank noch mal
LG
Marco

matthias · 28. März 2012

Der Übergabeparameter SQLiteDatabase db ist eine bereits offene Verbindung zur Datenbank, die von SQLiteOpenHelper kommt. Betrachte es einfach als Geschenk, weil du dich jetzt selbst nicht mehr darum kümmern musst

Was du jetzt tun musst, ist in dein Methode folgendes einfügen:

Java

mDb = db;

Damit setzt du die Instanz der SQLiteDatabase auf deine Membervariable und du kannst von überall aus in der Klasse zugreifen, so wie du es eh schon gehandhabt hast. Also im Prinzip nur folgendes:

Java

@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion){
	Log.v("DatabaseHelper", "Datenbank Upgrade von " + oldVersion + " auf " + newVersion);
	// Übergabeparameter db in mDb merken
	mDb = db; 
	if (oldVersion &lt; 2 && newVersion == 2) {
		// fetchId benutzt mDb dann um aus der DB zu lesen
		Cursor CursorOldTable = fetchId();
		CursorOldTable.moveToPosition(-1);
		// hier der restliche Code, den ich der Übersicht halber entfernt habe
	}
}

Alles anzeigen

mDb ist jetzt nicht mehr null, du benutzt den Übergabeparameter, musst nicht selbst noch einmal mit open() eine Verbindung aufbauen weil dir bereits eine übergeben wurde und es müsste jetzt funktionieren.

Gruß,
matze

marco.deubel · 4. April 2012

Hey
vielen vielen Dank
es hat wunderbar geklappt...
Das war die Lösung und ich wäre alleine glaube ich nie drauf gekommen
Also vielen Dank noch mal

LG
Marco

matthias · 5. April 2012

Hi Marco,

sehr schön, freut mich zu hören.
Setz doch bitte das Thema noch als erledigt Macht man ganz unten.

Gruß,
matze

onUpgrade Fehler bei DB

Jetzt mitmachen!

Teilen

Tags

Benutzer online in diesem Thema