0

データベースが事前設定された状態で開始するアプリケーションがあります。アプリケーションを更新して、新しいテーブルを挿入し、事前設定された新しいデータベースをコピーしたいと考えています。アプリケーションを更新するときに、データベースのバージョンを 2 にすると、新しいテーブルが作成されますが、新しいデータベースはコピーされません。しかし、バージョン 1 のままだと、アプリケーションがエラーで停止します。

データベースは assets フォルダーにあり、次のコードを使用して最初にコピーします。

public class DataBaseHelper<E> extends OrmLiteSqliteOpenHelper {
    private static String DB_PATH = "/data/data/com.teste/databases/";
    private static String DB_NAME = "teste.db";
    private static int DB_VERSION = 1;
    private SQLiteDatabase myDataBase;
    Context context;

    public DataBaseHelper(Context context) {
            super(context, DB_NAME, null, DB_VERSION);
            this.context = context;
            try {
                    createDataBase();
            } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
            }
    }

    public void createDataBase() throws IOException {
            boolean dbExist = checkDataBase();
            if (dbExist) {
            } else {
                    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) {
            }
            if (checkDB != null) {
                    checkDB.close();
            }
            return checkDB != null ? true : false;
    }

    private void copyDataBase() throws IOException {
            InputStream myInput = context.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);
            }
            myOutput.flush();
            myOutput.close();
            myInput.close();

    }

    public void openDataBase() throws SQLException {
            String myPath = DB_PATH + DB_NAME;
            myDataBase = SQLiteDatabase.openDatabase(myPath, null,
                            SQLiteDatabase.OPEN_READONLY);

    }

    @Override
    public void onCreate(SQLiteDatabase db, ConnectionSource src) {
            try {
                    TableUtils.createTable(src, Table1.class);
                    TableUtils.createTable(src, Table2.class);
                    TableUtils.createTable(src, Table3.class);
            } catch (Exception e) {
                    e.printStackTrace();
            }
    }

    @Override
    public void onUpgrade(SQLiteDatabase db, ConnectionSource src,
                    int oldVersion, int newVersion) {
            try {
                    TableUtils.dropTable(src, Table1.class, true);
                    TableUtils.dropTable(src, Table2.class, true);
                    TableUtils.dropTable(src, Table3.class, true);

                    onCreate(db, src);
            } catch (Exception e) {
                    e.printStackTrace();
            }
    }

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

ここで、挿入するテーブルがもう 1 つあり、次のコードを使用しています。

public class DataBaseHelper<E> extends OrmLiteSqliteOpenHelper {
private static String DB_PATH = "/data/data/com.teste/databases/";
private static String DB_NAME = "teste.db";
private static int DB_VERSION = 2;
private SQLiteDatabase myDataBase;
Context context;

public DataBaseHelper(Context context) {
        super(context, DB_NAME, null, DB_VERSION);
        this.context = context;
        try {
                createDataBase();
        } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
        }
}

public void createDataBase() throws IOException {
        boolean dbExist = checkDataBase();
        if (dbExist) {
        } else {
                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) {
        }
        if (checkDB != null) {
                checkDB.close();
        }
        return checkDB != null ? true : false;
}

private void copyDataBase() throws IOException {
        InputStream myInput = context.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);
        }
        myOutput.flush();
        myOutput.close();
        myInput.close();

}

public void openDataBase() throws SQLException {
        String myPath = DB_PATH + DB_NAME;
        myDataBase = SQLiteDatabase.openDatabase(myPath, null,
                        SQLiteDatabase.OPEN_READONLY);

}

@Override
public void onCreate(SQLiteDatabase db, ConnectionSource src) {
        try {
                TableUtils.createTable(src, Table1.class);
                TableUtils.createTable(src, Table2.class);
                TableUtils.createTable(src, Table3.class);
                TableUtils.createTable(src, Table4.class);
        } catch (Exception e) {
                e.printStackTrace();
        }
}

@Override
public void onUpgrade(SQLiteDatabase db, ConnectionSource src,
                int oldVersion, int newVersion) {
        try {
                TableUtils.dropTable(src, Table1.class, true);
                TableUtils.dropTable(src, Table2.class, true);
                TableUtils.dropTable(src, Table3.class, true);
                TableUtils.dropTable(src, Table4.class, true);
                onCreate(db, src);
        } catch (Exception e) {
                e.printStackTrace();
        }
}

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

編集2:

onUpgrade で copyDatabase を呼び出すと、DB がコピーされません。見る:

TableUtils.createTable(src, Linhas.class);
TableUtils.createTable(src, Horarios.class);
TableUtils.createTable(src, Itinerarios.class);
TableUtils.createTable(src, Utils.class);
copyDataBase();

何か助けはありますか?

編集3:

メソッドを使用してデータベース アップグレードのバージョンを変更し、アセット フォルダーからデータベースをコピーすると、このフォルダー アセットのデータベースのバージョンが現在のバージョンよりも小さいため、データが表示されないことに気付きました。新しいデータベースが事前設定されたときにコピーして、そのバージョンを変更する方法はありますか?

4

2 に答える 2

0

やりたいことができなかった。それ以外の場合は、最初のシステム起動時にデータベースにデータを入力するファイルを使用します。

public void execSqlFromAssets(String path, SQLiteDatabase db) {
    InputStream input;
    String text;
    try {
        input = context.getAssets().open(path + ".sql");
        int size = input.available();
        byte[] buffer = new byte[size];
        input.read(buffer);
        input.close();
        text = new String(buffer);
        String[] inserts = text.split(";");
        for (String insert : inserts) {
            try {
                db.execSQL(insert);
            } catch (Exception e) {
                String err = (e.getMessage() == null) ? "Cant execute sql"
                        + insert : e.getMessage();
            }
        }

    } catch (IOException e) {
        e.printStackTrace();
    }
}

この上:

@Override
public void onCreate(SQLiteDatabase db, ConnectionSource src) {
    try {
        TableUtils.createTable(src, Linhas.class);
        TableUtils.createTable(src, Horarios.class);
        TableUtils.createTable(src, Itinerarios.class);
        TableUtils.createTable(src, Utils.class);
        execSqlFromAssets("dump_all", db);
    } catch (Exception e) {
        e.printStackTrace();
    }
}
于 2013-09-23T22:24:35.373 に答える
0
            TableUtils.dropTable(src, Table1.class, true);
            TableUtils.dropTable(src, Table2.class, true);
            TableUtils.dropTable(src, Table3.class, true);
            TableUtils.dropTable(src, Table4.class, true);
            onCreate(db, src);

onCreate では、以前のバージョンのアプリで行った方法でデータベースに再度データを入力する必要があります。

私が見る限り、あなたは copyDatabase メソッドを呼び出していません。

于 2013-09-13T12:41:07.783 に答える