summaryrefslogtreecommitdiff
path: root/vdrmanager/src
diff options
context:
space:
mode:
Diffstat (limited to 'vdrmanager/src')
-rw-r--r--vdrmanager/src/de/bjusystems/vdrmanager/data/db/OrmDatabaseHelper.java146
1 files changed, 111 insertions, 35 deletions
diff --git a/vdrmanager/src/de/bjusystems/vdrmanager/data/db/OrmDatabaseHelper.java b/vdrmanager/src/de/bjusystems/vdrmanager/data/db/OrmDatabaseHelper.java
index a9e0dd9..55f8314 100644
--- a/vdrmanager/src/de/bjusystems/vdrmanager/data/db/OrmDatabaseHelper.java
+++ b/vdrmanager/src/de/bjusystems/vdrmanager/data/db/OrmDatabaseHelper.java
@@ -1,11 +1,15 @@
package de.bjusystems.vdrmanager.data.db;
import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
+import android.util.Pair;
import com.j256.ormlite.android.AndroidCompiledStatement;
import com.j256.ormlite.android.apptools.OrmLiteSqliteOpenHelper;
@@ -19,27 +23,30 @@ import com.j256.ormlite.table.TableUtils;
import de.bjusystems.vdrmanager.data.Vdr;
/**
- * Database helper class used to manage the creation and upgrading of your database. This class also usually provides
- * the DAOs used by the other classes.
+ * Database helper class used to manage the creation and upgrading of your
+ * database. This class also usually provides the DAOs used by the other
+ * classes.
*/
public class OrmDatabaseHelper extends OrmLiteSqliteOpenHelper {
- // name of the database file for your application -- change to something appropriate for your app
+ public static final String TAG = OrmDatabaseHelper.class.getName();
+ // name of the database file for your application -- change to something
+ // appropriate for your app
private static final String DATABASE_NAME = "vdrmanager.db";
- // any time you make changes to your database objects, you may have to increase the database version
- private static final int DATABASE_VERSION = 1;
+ // any time you make changes to your database objects, you may have to
+ // increase the database version
+ private static final int DATABASE_VERSION = 2;
-
private RuntimeExceptionDao<Vdr, Integer> vdrDAO = null;
-
public OrmDatabaseHelper(Context context) {
super(context, DATABASE_NAME, null, DATABASE_VERSION);
}
/**
- * This is called when the database is first created. Usually you should call createTable statements here to create
- * the tables that will store your data.
+ * This is called when the database is first created. Usually you should
+ * call createTable statements here to create the tables that will store
+ * your data.
*/
@Override
public void onCreate(SQLiteDatabase db, ConnectionSource connectionSource) {
@@ -51,39 +58,108 @@ public class OrmDatabaseHelper extends OrmLiteSqliteOpenHelper {
throw new RuntimeException(e);
}
-// // here we try inserting data in the on-create as a test
-// RuntimeExceptionDao<Note, Integer> dao = getSimpleDataDao();
-// long millis = System.currentTimeMillis();
-// // create some entries in the onCreate
-// Note simple = new Note();
-// dao.create(simple);
-// simple = new SimpleData(millis + 1);
-// dao.create(simple);
-// Log.i(DatabaseHelper.class.getName(), "created new entries in onCreate: " + millis);
+ // // here we try inserting data in the on-create as a test
+ // RuntimeExceptionDao<Note, Integer> dao = getSimpleDataDao();
+ // long millis = System.currentTimeMillis();
+ // // create some entries in the onCreate
+ // Note simple = new Note();
+ // dao.create(simple);
+ // simple = new SimpleData(millis + 1);
+ // dao.create(simple);
+ // Log.i(DatabaseHelper.class.getName(),
+ // "created new entries in onCreate: " + millis);
+ }
+
+ private List<ContentValues> backup() throws SQLException {
+ List<ContentValues> values = new ArrayList<ContentValues>();
+ Cursor c = getVdrCursor();
+ try {
+ if (c != null && c.getCount() == 0) {
+ return values;
+ }
+
+ c.move(-1);
+
+ while (c.moveToNext()) {
+ ContentValues cv = new ContentValues();
+ for (int i = 0; i < c.getColumnCount(); ++i) {
+ cv.put(c.getColumnName(i), c.getString(i));
+ }
+ values.add(cv);
+ }
+ return values;
+ } finally {
+ if (c != null && c.isClosed() == false) {
+ c.close();
+ }
+ }
+
}
/**
- * This is called when your application is upgraded and it has a higher version number. This allows you to adjust
- * the various data to match the new version number.
+ * This is called when your application is upgraded and it has a higher
+ * version number. This allows you to adjust the various data to match the
+ * new version number.
*/
@Override
- public void onUpgrade(SQLiteDatabase db, ConnectionSource connectionSource, int oldVersion, int newVersion) {
- try {
- Log.i(OrmDatabaseHelper.class.getName(), "onUpgrade");
- TableUtils.dropTable(connectionSource, Vdr.class, true);
- // after we drop the old databases, we create the new ones
- onCreate(db, connectionSource);
- } catch (SQLException e) {
- Log.e(OrmDatabaseHelper.class.getName(), "Can't drop databases", e);
- throw new RuntimeException(e);
+ public void onUpgrade(SQLiteDatabase db, ConnectionSource connectionSource,
+ int oldVersion, int newVersion) {
+ // try {
+ Log.i(TAG, "onUpgrade to " + newVersion + " from " + oldVersion);
+ // List<ContentValues> b = backup();
+ // Log.i(OrmDatabaseHelper.class.getName(), "backup");
+ // Dao<Vdr, Integer> dao = getDao(Vdr.class);
+ // List<Vdr> backup = dao.queryForAll();
+ // if (backup != null) {
+ // Log.i(OrmDatabaseHelper.class.getName(),
+ // "backuped " + backup.size() + " instances");
+ // }
+ // TableUtils.dropTable(connectionSource, Vdr.class, true);
+ // after we drop the old databases, we create the new ones
+ // onCreate(db, connectionSource);
+ if (oldVersion == 1) {
+
+ String alter = "ALTER TABLE vdr add livePort INTEGER";
+ Log.i(TAG, "exec: " + alter);
+ int count = getVdrDAO().executeRaw(alter);
+ Log.i(TAG, "alterd " + count + " rows");
+
+ alter = "ALTER TABLE vdr add enableRecStreaming SMALLINT";
+ Log.i(TAG, "exec: " + alter);
+ count = getVdrDAO().executeRaw(alter);
+ Log.i(TAG, "alterd " + count + " rows");
+
+ alter = "ALTER TABLE vdr add recStreamMethod VARCHAR";
+ Log.i(TAG, "exec: " + alter);
+ count = getVdrDAO().executeRaw(alter);
+ Log.i(TAG, "alterd " + count + " rows");
+
+
+ String update = "Update vdr set livePort = 8008, enableRecStreaming = 0, recStreamMethod = 'vdr-live'";
+ Log.i(TAG, "exec: " + update);
+ count = getVdrDAO().executeRaw(update);
+ Log.i(TAG, "alterd " + count + " rows");
}
- }
+ // if (backup != null) {
+ // for (Vdr v : backup) {
+ // dao.create(v);
+ // Log.i(OrmDatabaseHelper.class.getName(),
+ // "recovered " + v.getName());
+ // }
+ // }
+
+ // getVdrDAO().updateRaw(statement, arguments)
+
+ // } catch (SQLException e) {
+ // Log.e(OrmDatabaseHelper.class.getName(), "Can't drop databases", e);
+ // throw new RuntimeException(e);
+ // }
+ }
-
/**
- * Returns the Database Access Object (DAO) for our Label class. It will create it or just give the cached
- * value.
+ * Returns the Database Access Object (DAO) for our Label class. It will
+ * create it or just give the cached value.
*/
public RuntimeExceptionDao<Vdr, Integer> getVdrDAO() {
if (vdrDAO == null) {
@@ -107,8 +183,8 @@ public class OrmDatabaseHelper extends OrmLiteSqliteOpenHelper {
PreparedQuery<Vdr> preparedQuery = qb.prepare();
AndroidCompiledStatement compiledStatement = (AndroidCompiledStatement) preparedQuery
- .compile(getConnectionSource()
- .getReadOnlyConnection(), StatementType.SELECT);
+ .compile(getConnectionSource().getReadOnlyConnection(),
+ StatementType.SELECT);
return compiledStatement.getCursor();
}
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-16 18:52:30 +0000