Long userId = resultSet2.getLong("userId");

User u = new User(userId, surname, uName, patronymic, job);

FileInfo fi = new FileInfo(u, size, dayOfStorage);

Folder fol = new Folder(folderId, folder.getName());

f = new File(fileId, fName, comment, fol, fi, url);

result.add(f);

allow = false;

}

resultSet2.close();

}

resultSet.close();

}

catch (SQLException sqle) {

System.out.println("Ошибка showFilesFromFolder!");

sqle.printStackTrace();

throw sqle;

}

finally {

connection.close();

}

return result;

}

2. Установить версию файла

public void setVersionOfFile(File file, User user, String comment) throws IOException, ClassNotFoundException, SQLException {

Connection connection = getConnection();

PreparedStatement statement;

try {

connection.setAutoCommit(false);

statement = connection.prepareStatement("SELECT numberOfVersion, numberToPath FROM FILEINFO WHERE fileId=?");

statement.setLong(1, file.getId());

ResultSet resultSet = statement.executeQuery();

resultSet.next();

int numb = resultSet.getInt("numberOfVersion");

int numbtoP = resultSet.getInt("numberToPath");

statement = connection.prepareStatement("INSERT INTO VERSIONS (fileId, version, userId, addDate, comment, numberToPath) values (?, ?,?, ?,?, ?)");

statement.setLong(1, file.getId());

statement.setInt(2, numb + 1);

statement.setLong(3, user.getId());

statement.setTimestamp(4, new Timestamp(new Date().getTime()));

statement.setString(5, comment);

statement.setInt(6, numbtoP + 1);

statement.execute();

statement = connection.prepareStatement("UPDATE FILEINFO SET numberOfVersion=?, numberToPath=? WHERE fileId=?");

statement.setLong(1, numb + 1);

statement.setLong(2, numbtoP + 1);

statement.setLong(3, file.getId());

statement.execute();

connection.commit();

}

catch (SQLException sqle) {

sqle.printStackTrace();

throw sqle;

}

finally {

connection.close();

}

}

3. Удалить выбранную версию файла

public void deleteVersion(File file, int number) throws IOException, ClassNotFoundException, SQLException {

Connection connection = getConnection();

PreparedStatement statement;

try {

connection.setAutoCommit(false);

statement = connection.prepareStatement("DELETE FROM VERSIONS WHERE fileId=? AND version=?");

statement.setLong(1, file.getId());

statement.setInt(2, number);

statement.execute();

statement = connection.prepareStatement("SELECT version FROM VERSIONS WHERE fileId=? AND version>? ");

statement.setLong(1, file.getId());

statement.setInt(2, number);

ResultSet resultSet = statement.executeQuery();

while (resultSet.next()) {

int versionNumb = resultSet.getInt("version");

statement = connection.prepareStatement("UPDATE VERSIONS SET version=? WHERE fileId=? AND version=?");

statement.setInt(1, versionNumb - 1);

statement.setLong(2, file.getId());

statement.setLong(3, versionNumb);

statement.execute();

}

int numb = getNumberOfVersions(file);

statement = connection.prepareStatement("UPDATE FILEINFO SET numberOfVersion=? WHERE fileId=?");

statement.setInt(1, numb - 1);

statement.setLong(2, file.getId());

statement.execute();

connection.commit();

System.out.println("Все версии, кроме заданной, удалены");

}

catch (SQLException sqle) {

connection.rollback();

System.out.println("Ошибка deletVersion!");

sqle.printStackTrace();

throw sqle;

}

finally {connection.close();}

}

4. Удалить задание к файлу

public void deleteTaskFromFile(MyTask myTask) throws IOException, ClassNotFoundException, SQLException {

Connection connection = getConnection();

PreparedStatement statement;

try {

connection.setAutoCommit(false);

statement = connection.prepareStatement("SELECT taskOrder FROM MYTASKS WHERE myTaskId=?");

statement.setLong(1, myTask.getId());

ResultSet resultSet = statement.executeQuery();

resultSet.next();

int taskOrd = resultSet.getInt("taskOrder");

long fileId = myTask.getFile().getId();

statement = connection.prepareStatement("SELECT myTaskId, taskOrder FROM MYTASKS WHERE taskOrder>? AND fileId=?");

statement.setLong(1, taskOrd);

statement.setLong(2, fileId);

ResultSet resultSet1 = statement.executeQuery();

while (resultSet1.next()) {

int id = resultSet1.getInt("myTaskId");

int taskOrd1 = resultSet1.getInt("taskOrder");

statement = connection.prepareStatement("UPDATE MYTASKS SET taskOrder=? WHERE myTaskId=?");

statement.setLong(1, taskOrd1 - 1);

statement.setLong(2, id);

}

statement = connection.prepareStatement("DELETE FROM MYTASKS WHERE myTaskId=?");

statement.setLong(1, myTask.getId());

statement.execute();

connection.commit();

System.out.println("Задание к файлу успешно удалено");

}

catch (SQLException sqle) {

connection.rollback();

System.out.println("Ошибка!");

sqle.printStackTrace();

throw sqle;

}

finally {connection.close();}

}

Размещено на Allbest.ru