package com.megatim.module.compression.impl;
|
|
import java.io.File;
|
import java.io.FileInputStream;
|
import java.io.FileNotFoundException;
|
import java.io.FileOutputStream;
|
import java.io.IOException;
|
import java.util.zip.GZIPInputStream;
|
import java.util.zip.GZIPOutputStream;
|
|
|
import net.lingala.zip4j.exception.ZipException;
|
import com.megatim.module.compression.ifaces.CompressionFace;
|
|
public class JavaZipGZIPImpl implements CompressionFace {
|
|
public static int sChunk = 8192;
|
|
public File zipFile(File fichierAZipper) throws IOException {
|
// TODO Auto-generated method stub
|
|
// create output stream
|
String zipname = removeExtension(fichierAZipper.getPath()) + ".gz";
|
|
GZIPOutputStream zipout;
|
|
try {
|
|
FileOutputStream out = new FileOutputStream(zipname);
|
|
zipout = new GZIPOutputStream(out);
|
|
} catch (IOException e) {
|
|
System.out.println("Couldn't create " + zipname + ".");
|
|
return null;
|
|
}
|
|
byte[] buffer = new byte[sChunk];
|
|
// compress the file
|
try {
|
|
FileInputStream in = new FileInputStream(removeExtension(fichierAZipper.getPath()));
|
|
int length;
|
|
while ((length = in.read(buffer, 0, sChunk)) != -1) {
|
zipout.write(buffer, 0, length);
|
}
|
|
in.close();
|
} catch (IOException e) {
|
|
System.out.println("Couldn't compress " + removeExtension(fichierAZipper.getPath()) + ".");
|
|
}
|
|
try {
|
zipout.close();
|
} catch (IOException e) {
|
}
|
|
return new File(removeExtension(fichierAZipper.getPath()) + ".gz");
|
}
|
|
public File zipFile(File fichierAZipper, File repertoireDestination) throws IOException {
|
return null;
|
}
|
|
public File zipRepository(File repertoireAZipper) throws IOException {
|
// TODO Auto-generated method stub
|
|
// create output stream
|
String zipname = repertoireAZipper.getPath() + ".gz";
|
|
GZIPOutputStream zipout;
|
|
try {
|
|
FileOutputStream out = new FileOutputStream(zipname);
|
|
zipout = new GZIPOutputStream(out);
|
|
} catch (IOException e) {
|
|
System.out.println("Couldn't create " + zipname + ".");
|
|
return null;
|
|
}
|
|
byte[] buffer = new byte[sChunk];
|
|
// compress the file
|
try {
|
|
FileInputStream in = new FileInputStream(repertoireAZipper.getPath());
|
|
int length;
|
|
while ((length = in.read(buffer, 0, sChunk)) != -1) {
|
zipout.write(buffer, 0, length);
|
}
|
|
in.close();
|
} catch (IOException e) {
|
|
System.out.println("Couldn't compress " + repertoireAZipper.getPath() + ".");
|
|
}
|
|
try {
|
zipout.close();
|
} catch (IOException e) {
|
}
|
|
return new File(repertoireAZipper.getPath() + ".gz");
|
|
}
|
|
public File zipRepository(File repertoireAZipper, File repertoireDestination) throws IOException {
|
return null;
|
}
|
|
public void unZipFile(File fichierZipper, File repertoireSorti) throws IOException {
|
// TODO Auto-generated method stub
|
|
// create input stream
|
String zipname, source;
|
if (fichierZipper.getPath().endsWith(".gz")) {
|
zipname = fichierZipper.getPath();
|
source = repertoireSorti.getPath();
|
} else {
|
zipname = fichierZipper.getPath() + ".gz";
|
source = repertoireSorti.getPath();
|
}
|
GZIPInputStream zipin = null;
|
try {
|
FileInputStream in = new FileInputStream(zipname);
|
zipin = new GZIPInputStream(in);
|
} catch (IOException e) {
|
System.out.println("Couldn't open " + zipname + ".");
|
return;
|
}
|
byte[] buffer = new byte[sChunk];
|
// decompress the file
|
try {
|
FileOutputStream out = new FileOutputStream(source);
|
int length;
|
while ((length = zipin.read(buffer, 0, sChunk)) != -1) {
|
out.write(buffer, 0, length);
|
}
|
out.close();
|
} catch (IOException e) {
|
System.out.println("Couldn't decompress " + fichierZipper.getName() + ".");
|
}
|
try {
|
zipin.close();
|
} catch (IOException e) {
|
}
|
|
}
|
|
public void unZipRepository(File repertoireZipper, File repertoireSorti) throws IOException {
|
// TODO Auto-generated method stub
|
|
// create input stream
|
String zipname, source;
|
if (repertoireZipper.getPath().endsWith(".gz")) {
|
zipname = repertoireZipper.getPath();
|
source = repertoireSorti.getPath();
|
} else {
|
zipname = repertoireZipper.getPath() + ".gz";
|
source = repertoireSorti.getPath();
|
}
|
GZIPInputStream zipin = null;
|
try {
|
FileInputStream in = new FileInputStream(zipname);
|
zipin = new GZIPInputStream(in);
|
} catch (IOException e) {
|
System.out.println("Couldn't open " + zipname + ".");
|
return;
|
}
|
byte[] buffer = new byte[sChunk];
|
// decompress the file
|
try {
|
FileOutputStream out = new FileOutputStream(source);
|
int length;
|
while ((length = zipin.read(buffer, 0, sChunk)) != -1) {
|
out.write(buffer, 0, length);
|
}
|
out.close();
|
} catch (IOException e) {
|
System.out.println("Couldn't decompress " + repertoireZipper.getName() + ".");
|
}
|
try {
|
zipin.close();
|
} catch (IOException e) {
|
}
|
|
}
|
|
public void addFile(File fichier, File zipFile) throws IOException, Exception {
|
// TODO Auto-generated method stub
|
|
// create output stream
|
String zipname = zipFile.getPath();
|
|
GZIPOutputStream zipout = null;
|
|
try {
|
|
FileOutputStream out = new FileOutputStream(zipname);
|
|
zipout = new GZIPOutputStream(out);
|
|
} catch (IOException e) {
|
|
System.out.println("Couldn't create " + zipname + ".");
|
|
}
|
|
byte[] buffer = new byte[sChunk];
|
|
// compress the file
|
try {
|
|
FileInputStream in = new FileInputStream(removeExtension(fichier.getPath()));
|
|
int length;
|
|
while ((length = in.read(buffer, 0, sChunk)) != -1) {
|
zipout.write(buffer, 0, length);
|
}
|
|
in.close();
|
} catch (IOException e) {
|
|
System.out.println("Couldn't compress " + fichier + ".");
|
|
}
|
|
try {
|
zipout.close();
|
} catch (IOException e) {
|
}
|
|
}
|
|
public void addRepository(File repository, File zipFile) throws FileNotFoundException, Exception {
|
// TODO Auto-generated method stub
|
|
// create output stream
|
String zipname = zipFile.getPath();
|
|
GZIPOutputStream zipout = null;
|
|
try {
|
|
FileOutputStream out = new FileOutputStream(zipname);
|
|
zipout = new GZIPOutputStream(out);
|
|
} catch (IOException e) {
|
|
System.out.println("Couldn't create " + zipname + ".");
|
|
}
|
|
byte[] buffer = new byte[sChunk];
|
|
// compress the file
|
try {
|
|
FileInputStream in = new FileInputStream(repository.getPath());
|
|
int length;
|
|
while ((length = in.read(buffer, 0, sChunk)) != -1) {
|
zipout.write(buffer, 0, length);
|
}
|
|
in.close();
|
} catch (IOException e) {
|
|
System.out.println("Couldn't compress " + repository.getName() + ".");
|
|
}
|
|
try {
|
zipout.close();
|
} catch (IOException e) {
|
}
|
|
}
|
|
public File zipFile(File fichierAZipper, String password) throws ZipException, Exception {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public File zipRepository(File repertoireAZipper, String password) throws Exception {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public void unZipFile(File fichierZipper, File repertoireSorti, String password) throws Exception {
|
// TODO Auto-generated method stub
|
|
}
|
|
public void unZipRepository(File repertoireZipper, File repertoireSorti, String password)
|
throws ZipException, Exception {
|
// TODO Auto-generated method stub
|
|
}
|
|
public void addFile(File fichier, File zipFile, String password) throws Exception {
|
// TODO Auto-generated method stub
|
|
}
|
|
public void addRepository(File repository, File zipFile, String password) throws Exception {
|
// TODO Auto-generated method stub
|
|
}
|
|
// Remove extension before zip file
|
public static String removeExtension(String s) {
|
|
String separator = System.getProperty("file.separator");
|
|
String filename;
|
|
// Remove the path upto the filename.
|
/*
|
* int lastSeparatorIndex = s.lastIndexOf(separator); if (lastSeparatorIndex ==
|
* -1) { filename = s; } else { filename = s.substring(lastSeparatorIndex + 1);
|
* }
|
*/
|
// Remove the extension.
|
int extensionIndex = s.lastIndexOf(".");
|
|
if (extensionIndex == -1) {
|
return s;
|
}
|
|
return s.substring(0, extensionIndex);
|
}
|
|
public File zipFile(File fichierAZipper,File repertoireDestination, String password) throws IOException {
|
return null;
|
}
|
}
|
