Android - Импорт нескольких файлов .CSV в несколько таблиц в базе данных SQLite

Question

На моем устройстве Android есть папка с несколькими файлами .CSV.

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

Все .CSV файлы просты.У них есть только один столбец.

Пример:

File.CSV

12345

123

00000000

AnotherFile.CSV

XXXXX

ZZZZZZZZZZ

FFFF

Вот мой метод, и он не работает.Я не мог понять, почему:

@TargetApi(Build.VERSION_CODES.M)
public void importaTabelas() {

    //Check the read permission
    if (checkSelfPermission(Manifest.permission.READ_EXTERNAL_STORAGE) == PackageManager.PERMISSION_GRANTED) {

        try {

            //Check if the folder exists
            File importDir = new File (Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/ENEL/IMPORTADOS/");
            if (!importDir.exists())
            {
                importDir.mkdirs();
            }

            //Read all file names
            for (File f : importDir.listFiles()) {

                if (f.isFile()) {

                    //Put the files names into variable nomeArq
                    nomeArq = f.getName();

                    //Take off the file extension .csv
                    if (nomeArq.indexOf(".") > 0)
                        nomeArq = nomeArq.substring(0, nomeArq.lastIndexOf("."));

                    SQLiteDatabase db = this.banco.getWritableDatabase();

                    try {

                        //Create table with the name of the .csv file
                        String criaTab = "CREATE TABLE IF NOT EXISTS " + nomeArq +  " (id integer PRIMARY KEY AUTOINCREMENT, codigo varchar (50))";
                        db.execSQL(criaTab);
                        db.close();

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

                    //String for the file location
                    String fn = importDir + "/" + nomeArq + ".csv";

                    //Reads the file
                    FileReader fileReader = new FileReader(fn);

                    BufferedReader buffer = new BufferedReader(fileReader);

                    //ContentValues contentValues = new ContentValues();

                    String line = "";

                    //db.beginTransaction();

                    while ((line = buffer.readLine()) != null) {

                        //String[] colums = line.split("\t");

                        //String[] colums = line.split(";");

                        Toast.makeText(this, line, Toast.LENGTH_SHORT).show();

                        //contentValues.put("codigo", line);

                        //db.insert(nomeArq, null, contentValues);

                        db.execSQL("INSERT INTO " + nomeArq +  " (codigo) VALUES ('" + line + "')");

                    }

                    //db.setTransactionSuccessful();
                    //db.endTransaction();

                }

            }

        } catch (Exception e) {

            Toast.makeText(this, "Catch!", Toast.LENGTH_SHORT).show();
            e.printStackTrace();

        }

    }

    else {

        requestPermissions(new String[]{Manifest.permission.READ_EXTERNAL_STORAGE}, 1);

    }

}

Не могли бы вы помочь мне заставить его работать?Спасибо!

Answer 1

Я реорганизовал ваш код в кучу небольших методов.Каждый метод отвечает за одну вещь, что является хорошей практикой, старайтесь делать это в любое время.

Я сделал всего несколько изменений:

• Строка, создающая FileReader теперь использует файл (меньше подвержен ошибкам) ​​
• Изменил способ вставки, создав один запрос на вставку, чтобы у вас было меньше обращений к базе данных (например, так: INSERT INTO table(codigo) VALUES ('XXXX'), ('ZZZZ'), ('FFFF');)
• Измененотекст в тостах, чтобы лучше определить, откуда исходит ваша ошибка.

Попробуйте и посмотрите, сможете ли вы найти свою ошибку лучше.(Я не пытался скомпилировать код, поэтому вам, возможно, придется немного его настроить, но в целом все должно быть в порядке)

основной метод импорта:

public void importaTabelas() {

    //Check the read permission
    if (checkSelfPermission(Manifest.permission.READ_EXTERNAL_STORAGE) == PackageManager.PERMISSION_GRANTED) {
        try {
            makeDirs();

            //Read all file names
            for (File f : importDir.listFiles()) {
                if (f.isFile()) {
                    importFile(f);
                }
            }
        } catch (IOException e) {
            Toast.makeText(this, "Could not import tables! " + e.getMessage(), Toast.LENGTH_SHORT).show();
            e.printStackTrace();
        }
    } else {
        requestPermissions(new String[]{Manifest.permission.READ_EXTERNAL_STORAGE}, 1);
    }

}

Создание каталогов

private void makeDirs() {
    //Check if the folder exists
    File importDir = new File (Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_DOWNLOADS) + "/ENEL/IMPORTADOS/");
    if (!importDir.exists()) {
        importDir.mkdirs();
    }
}

Импорт одного файла

private void importFile(File f) {
    try {
        SQLiteDatabase db = this.banco.getWritableDatabase();

        //Put the files names into variable nomeArq
        String nomeArq = f.getName();

        //Take off the file extension .csv
        if (nomeArq.indexOf(".") > 0)
            nomeArq = nomeArq.substring(0, nomeArq.lastIndexOf("."));

        createTable(db, nomeArq);

        String insertQuery = buildImportQuery(f, nomeArq);
        db.execSQL(insertQuery);
    } catch (SQLException e) {
        Toast.makeText(this, "Could not import file. " + e.getMessage(), Toast.LENGTH_SHORT).show();
        e.printStackTrace();
    }
}

Создание запроса на вставку для определенного файла

private String buildImportQuery(File f, String nomeArq) {
    StringBuilder sb = new StringBuilder();
    try {
        //Reads the file
        FileReader fileReader = new FileReader(f);
        BufferedReader buffer = new BufferedReader(fileReader);
        String line;

        sb.append("INSERT INTO " + nomeArq +  " (codigo) VALUES ");
        boolean addComma = false;
        while ((line = buffer.readLine()) != null) {
            if(line.length() > 0) {
                if(addComma) {
                    sb.append(",");
                }
                sb.append("('" + line.trim() + "')");
                addComma = true;
            }
        }
        sb.append(";");
    } catch (IOException e) {
        Toast.makeText(this, "Could not write query. " + e.getMessage(), Toast.LENGTH_SHORT).show();
        e.printStackTrace();
    }

    return sb.toString();

}

Создание отдельной таблицы

private void createTable(SQLiteDatabase db, String tableName) {
    try {
        //Create table with the name of the .csv file
        String criaTab = "CREATE TABLE IF NOT EXISTS " + tableName +  " (id integer PRIMARY KEY AUTOINCREMENT, codigo varchar (50))";
        db.execSQL(criaTab);
        db.close();

    } catch (Exception e) {
        Toast.makeText(this, "Could not create table " + tableName + "." +  e.getMessage(), Toast.LENGTH_SHORT).show();
        e.printStackTrace();
    }
}