Пишу программу, которая импортирует ексель файл в базу данных. Там есть определенная таблица с теми же полями, что и в ексель файле. Хотелось узнать как правильнее устроить иерархию классов.
Иерархия, которая используется сейчас:
- Main
- DatabaseConnection (создает соединение с базой)
- Configs (содержит данные про базу, которые используются для подключения)
- Handler (выполняет загрузку)
Использую JDBC драйвер дял работы с базой и Apache POI для работы с ексель.
Class Main
import java.sql.SQLException;
import java.util.ArrayList;
public class Main {
public static void main(String[] args) {
Handler handler = null;
try {
handler = new Handler();
Directory directory = new Directory("путь к директории");
ArrayList<String> defunctFiles = new ArrayList<>();
// Файлы, которые были загружены без ошибок
int uploadedFiles = 0;
// Считает время работы программы
Timer timer = new Timer();
System.out.println("Uploading...");
// Индикатор загрузки
ProgressBar progressBar = new ProgressBar();
timer.start();
for (int i = 0; i < directory.getNumberOfFiles(); i++) {
try {
handler.uploadFile(directory.getDirectoryFile(i));
uploadedFiles++;
} catch (Exception exception) {
defunctFiles.add(directory.getDirectoryFile(i).getName() + "(" + exception.getMessage() + ")");
}
progressBar.step(i, directory.getNumberOfFiles() - 1);
}
timer.end();
System.out.println();
System.out.println("Uploaded files: " + uploadedFiles + "\\" + directory.getNumberOfFiles());
if (defunctFiles.size() > 0) {
System.out.println("\nDefunct files: ");
showDefunctFiles(defunctFiles);
}
System.out.println("\nTime: " + timer.getTimeInSeconds() + "s");
} catch (SQLException exception) {
System.out.println("Failed connection");
} catch (ClassNotFoundException e) {
System.out.println("Failed driver registration");
} catch (InterruptedException e) {
System.out.println("Progress is greater than set");
}
}
/**
* Функция создания вывода деффектных файлов
*/
private static void showDefunctFiles(ArrayList<String> files) {
for (int i = 0; i < files.size(); i++) {
System.out.print(files.get(i));
if (i < files.size() - 1) {
System.out.print(", ");
} else {
System.out.println();
}
}
}
}
Class DatabaseConnection
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseConnection extends Configs {
/**
* Функция создания соединения с базой данных
*
* @return возвраащет обьект Connection
*/
public Connection createConnection() throws SQLException, ClassNotFoundException {
Class.forName(driver);
// DriverManager управляет списком драйверов БД. Каждой запрос на соединение требует соответствующего драйвера. Первое совпадение даёт нам соединение.
return DriverManager.getConnection(connectionURL, user, password);
}
}
Class Handler
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.CellType;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import java.io.File;
import java.io.FileInputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Iterator;
public class Handler {
/**
* Поле соединение (Connection)
* Этот интерфейс обеспечивает методами для работы с БД.
* Все взаимодействия с БД происходят исключительно через Connection.
*/
private final Connection connection;
/**
* Конструктор - создание нового объекта
* Создание соединения с базой данных
*/
public Handler() throws SQLException, ClassNotFoundException {
connection = new DatabaseConnection().createConnection();
}
/**
* Функция загрузки файлов Excel в базу данных
*
* @param file - файл, который нужно загрузить
*/
public void uploadFile(final File file) throws Exception {
String sql = "insert into \"название таблицы\"(\"названия колонок\") values (?,?,?,?,?,?,?,?,?,?,?)";
String sheetName = "название таблицы";
//Для подтверждения SQL-запросов мы используем объекты, созданные с использованием этого интерфейса.
PreparedStatement preparedStatement = connection.prepareStatement(sql);
//Класс чтения и записи файлов Microsoft Excel в формате .xlsx
XSSFWorkbook workbook = new XSSFWorkbook(new FileInputStream(file.getPath()));
//Класс может создавать таблицы Excel и позволяет форматировать стиль листа и данные листа.
Sheet sheet = findSheetByName(workbook, sheetName);
//Проверка на null-значение листа. Если null, то таблица не найдена
if (sheet == null) {
//Выброс исключения
throw new Exception();
}
//Класс представляет возможность перебрать все элементы в коллекции без вникания во внутреннюю структуру и устройство коллекций.
Iterator<Row> rowIterator = sheet.rowIterator();
rowIterator.next();
while (rowIterator.hasNext()) {
//Класс включает свойства и методы работы со строками, создания ячеек в строке и т.д.
Row row = rowIterator.next();
Iterator<Cell> cellIterator = row.cellIterator();
cellIterator.next();
while (cellIterator.hasNext()) {
//Ячейки электронной таблицы используются для размещения информации.
Cell cell = cellIterator.next();
//Класс позволяет получить тип информации, которая содержится в ячейке
CellType cellType = cell.getCellType();
//Строковое представление информации, находящейся в ячейке
String cellValue = cellType.equals(CellType.STRING) ? cell.getStringCellValue() : String.valueOf(cell.getNumericCellValue());
//Проверка содержит ли переменная значенние(не пустое)*/
if (!cellValue.isEmpty() && !cellValue.equals(" ")) {
//Проверка типа информации, которая содержиться в даной ячейке
if (cellType.equals(CellType.NUMERIC)) {
//Запись значений в базу даных
preparedStatement.setDouble(cell.getColumnIndex(), Double.parseDouble(cellValue));
} else if (cellType.equals(CellType.STRING)) {
preparedStatement.setString(cell.getColumnIndex(), cellValue);
}
}
}
preparedStatement.setString(11, file.getName());
//Выполняет такие SQL-команды, как INSERT, UPDATE, DELETE, CREATE и возвращает количество измененных строк
preparedStatement.executeUpdate();
}
//Закрываются потоки
preparedStatement.close();
workbook.close();
}
/**
* Функция поиска листа в файле Excel по имени
*
* @return возвращает страницу или null
*/
private Sheet findSheetByName(XSSFWorkbook workbook, String sheetName) {
//Прохождение циклом по всем таблицам файла и поиск нужной
for (int i = 0; i < workbook.getNumberOfSheets(); i++) {
if (workbook.getSheetAt(i).getSheetName().equalsIgnoreCase(sheetName)) {
return workbook.getSheetAt(i);
}
}
return null;
}
}
Class Configs
public class Configs {
protected static final String host = "";
protected static final String port = "";
protected static final String user = "";
protected static final String userName = "";
protected static final String password = "";
protected static final String name = "";
protected static final String connectionURL = "jdbc:oracle:thin:@" + host + ":" + port + "/" + name;
protected static final String driver = "oracle.jdbc.driver.OracleDriver";
}