001: /* Copyright (c) 1995-2000, The Hypersonic SQL Group.
002: * All rights reserved.
003: *
004: * Redistribution and use in source and binary forms, with or without
005: * modification, are permitted provided that the following conditions are met:
006: *
007: * Redistributions of source code must retain the above copyright notice, this
008: * list of conditions and the following disclaimer.
009: *
010: * Redistributions in binary form must reproduce the above copyright notice,
011: * this list of conditions and the following disclaimer in the documentation
012: * and/or other materials provided with the distribution.
013: *
014: * Neither the name of the Hypersonic SQL Group nor the names of its
015: * contributors may be used to endorse or promote products derived from this
016: * software without specific prior written permission.
017: *
018: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
019: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
020: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
021: * ARE DISCLAIMED. IN NO EVENT SHALL THE HYPERSONIC SQL GROUP,
022: * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
023: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
024: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
025: * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
026: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
027: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
028: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
029: *
030: * This software consists of voluntary contributions made by many individuals
031: * on behalf of the Hypersonic SQL Group.
032: *
033: *
034: * For work added by the HSQL Development Group:
035: *
036: * Copyright (c) 2001-2005, The HSQL Development Group
037: * All rights reserved.
038: *
039: * Redistribution and use in source and binary forms, with or without
040: * modification, are permitted provided that the following conditions are met:
041: *
042: * Redistributions of source code must retain the above copyright notice, this
043: * list of conditions and the following disclaimer.
044: *
045: * Redistributions in binary form must reproduce the above copyright notice,
046: * this list of conditions and the following disclaimer in the documentation
047: * and/or other materials provided with the distribution.
048: *
049: * Neither the name of the HSQL Development Group nor the names of its
050: * contributors may be used to endorse or promote products derived from this
051: * software without specific prior written permission.
052: *
053: * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
054: * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
055: * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
056: * ARE DISCLAIMED. IN NO EVENT SHALL HSQL DEVELOPMENT GROUP, HSQLDB.ORG,
057: * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
058: * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
059: * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
060: * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
061: * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
062: * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
063: * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
064: */
065:
066: package org.hsqldb.lib;
067:
068: import java.io.IOException;
069: import java.io.InputStream;
070: import java.io.OutputStream;
071: import java.util.zip.Deflater;
072: import java.util.zip.DeflaterOutputStream;
073: import java.util.zip.Inflater;
074: import java.util.zip.InflaterInputStream;
075:
076: // oj@openoffice.org - patch 1.8.0 - use FileAccess
077:
078: /**
079: *
080: * New Class based on original Hypersonic code.
081: *
082: * @author Thomas Mueller (Hypersonic SQL Group)
083: * @version 1.7.2
084: * @since Hypersonic SQL
085: */
086: public class ZipUnzipFile {
087:
088: private static final int COPY_BLOCK_SIZE = 1 << 16;
089:
090: public static void compressFile(String infilename,
091: String outfilename, FileAccess storage) throws IOException {
092:
093: InputStream in = null;
094: DeflaterOutputStream f = null;
095: boolean completed = false;
096:
097: // if there is no file
098: if (!storage.isStreamElement(infilename)) {
099: return;
100: }
101:
102: try {
103: byte[] b = new byte[COPY_BLOCK_SIZE];
104:
105: in = storage.openInputStreamElement(infilename);
106: f = new DeflaterOutputStream(storage
107: .openOutputStreamElement(outfilename),
108: new Deflater(Deflater.BEST_SPEED), COPY_BLOCK_SIZE);
109:
110: while (true) {
111: int l = in.read(b, 0, COPY_BLOCK_SIZE);
112:
113: if (l == -1) {
114: break;
115: }
116:
117: f.write(b, 0, l);
118: }
119:
120: completed = true;
121: } catch (Throwable e) {
122: throw FileUtil.toIOException(e);
123: } finally {
124: try {
125: if (in != null) {
126: in.close();
127: }
128:
129: if (f != null) {
130: f.finish(); // reported to be missing from close() in some JRE libs
131: f.close();
132: }
133:
134: if (!completed && storage.isStreamElement(outfilename)) {
135: storage.removeElement(outfilename);
136: }
137: } catch (Throwable e) {
138: throw FileUtil.toIOException(e);
139: }
140: }
141: }
142:
143: public static void decompressFile(String infilename,
144: String outfilename, FileAccess storage) throws IOException {
145:
146: InflaterInputStream f = null;
147: OutputStream outstream = null;
148: boolean completed = false;
149:
150: try {
151: if (!storage.isStreamElement(infilename)) {
152: return;
153: }
154:
155: storage.removeElement(outfilename);
156:
157: f = new InflaterInputStream(storage
158: .openInputStreamElement(infilename), new Inflater());
159: outstream = storage.openOutputStreamElement(outfilename);
160:
161: byte[] b = new byte[COPY_BLOCK_SIZE];
162:
163: while (true) {
164: int l = f.read(b, 0, COPY_BLOCK_SIZE);
165:
166: if (l == -1) {
167: break;
168: }
169:
170: outstream.write(b, 0, l);
171: }
172:
173: completed = true;
174: } catch (Throwable e) {
175: throw FileUtil.toIOException(e);
176: } finally {
177: try {
178: if (f != null) {
179: f.close();
180: }
181:
182: if (outstream != null) {
183: outstream.close();
184: }
185:
186: if (!completed && storage.isStreamElement(outfilename)) {
187: storage.removeElement(outfilename);
188: }
189: } catch (Throwable e) {
190: throw FileUtil.toIOException(e);
191: }
192: }
193: }
194: }
|