import org.h2.util.IOUtils; //导入依赖的package包/类
public static String loadJSONFromResource(String resname, ClassLoader loader) {
    System.out.println("Loading local resource: " + resname);

    try {
        InputStreamReader reader = new InputStreamReader(loader.getResourceAsStream(resname));
        StringWriter writer = new StringWriter();

        IOUtils.copyAndCloseInput(reader, writer, 100000000);

        writer.close();

        return writer.toString();
    } catch (IOException e) {
        e.printStackTrace();
    }

    return "";
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private boolean openWriter() {
    if (printWriter == null) {
        try {
            FileUtils.createDirectories(FileUtils.getParent(fileName));
            if (FileUtils.exists(fileName) && !FileUtils.canWrite(fileName)) {
                // read only database: don't log error if the trace file
                // can't be opened
                return false;
            }
            fileWriter = IOUtils.getBufferedWriter(
                    FileUtils.newOutputStream(fileName, true));
            printWriter = new PrintWriter(fileWriter, true);
        } catch (Exception e) {
            logWritingError(e);
            return false;
        }
    }
    return true;
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
/**
 * Returns the length.
 *
 * @return the length
 */
@Override
public long length() throws SQLException {
    try {
        debugCodeCall("length");
        checkClosed();
        if (value.getType() == Value.CLOB) {
            long precision = value.getPrecision();
            if (precision > 0) {
                return precision;
            }
        }
        return IOUtils.copyAndCloseInput(value.getReader(), null, Long.MAX_VALUE);
    } catch (Exception e) {
        throw logAndConvert(e);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
/**
 * Sets the value of a parameter as an ASCII stream.
 * This method does not close the stream.
 * The stream may be closed after executing the statement.
 *
 * @param parameterIndex the parameter index (1, 2, ...)
 * @param x the value
 * @param length the maximum number of bytes
 * @throws SQLException if this object is closed
 */
@Override
public void setAsciiStream(int parameterIndex, InputStream x, long length)
        throws SQLException {
    try {
        if (isDebugEnabled()) {
            debugCode("setAsciiStream("+parameterIndex+", x, "+length+"L);");
        }
        checkClosedForWrite();
        try {
            Value v = conn.createClob(IOUtils.getAsciiReader(x), length);
            setParameter(parameterIndex, v);
        } finally {
            afterWriting();
        }
    } catch (Exception e) {
        throw logAndConvert(e);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
/**
 * Returns the length.
 *
 * @return the length
 */
@Override
public long length() throws SQLException {
    try {
        debugCodeCall("length");
        checkClosed();
        if (value.getType() == Value.BLOB) {
            long precision = value.getPrecision();
            if (precision > 0) {
                return precision;
            }
        }
        return IOUtils.copyAndCloseInput(value.getInputStream(), null);
    } catch (Exception e) {
        throw logAndConvert(e);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
/**
 * Returns some bytes of the object.
 *
 * @param pos the index, the first byte is at position 1
 * @param length the number of bytes
 * @return the bytes, at most length bytes
 */
@Override
public byte[] getBytes(long pos, int length) throws SQLException {
    try {
        if (isDebugEnabled()) {
            debugCode("getBytes("+pos+", "+length+");");
        }
        checkClosed();
        ByteArrayOutputStream out = new ByteArrayOutputStream();
        InputStream in = value.getInputStream();
        try {
            IOUtils.skipFully(in, pos - 1);
            IOUtils.copy(in, out, length);
        } finally {
            in.close();
        }
        return out.toByteArray();
    } catch (Exception e) {
        throw logAndConvert(e);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private void createFromReader(char[] buff, int len, Reader in,
        long remaining, DataHandler h) throws IOException {
    FileStoreOutputStream out = initLarge(h);
    boolean compress = h.getLobCompressionAlgorithm(Value.CLOB) != null;
    try {
        while (true) {
            precision += len;
            byte[] b = new String(buff, 0, len).getBytes(Constants.UTF8);
            out.write(b, 0, b.length);
            remaining -= len;
            if (remaining <= 0) {
                break;
            }
            len = getBufferSize(h, compress, remaining);
            len = IOUtils.readFully(in, buff, len);
            if (len == 0) {
                break;
            }
        }
    } finally {
        out.close();
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private void createFromStream(byte[] buff, int len, InputStream in,
        long remaining, DataHandler h) throws IOException {
    FileStoreOutputStream out = initLarge(h);
    boolean compress = h.getLobCompressionAlgorithm(Value.BLOB) != null;
    try {
        while (true) {
            precision += len;
            out.write(buff, 0, len);
            remaining -= len;
            if (remaining <= 0) {
                break;
            }
            len = getBufferSize(h, compress, remaining);
            len = IOUtils.readFully(in, buff, len);
            if (len <= 0) {
                break;
            }
        }
    } finally {
        out.close();
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public String getString() {
    int len = precision > Integer.MAX_VALUE || precision == 0 ?
            Integer.MAX_VALUE : (int) precision;
    try {
        if (type == Value.CLOB) {
            if (small != null) {
                return new String(small, Constants.UTF8);
            }
            return IOUtils.readStringAndClose(getReader(), len);
        }
        byte[] buff;
        if (small != null) {
            buff = small;
        } else {
            buff = IOUtils.readBytesAndClose(getInputStream(), len);
        }
        return StringUtils.convertBytesToHex(buff);
    } catch (IOException e) {
        throw DbException.convertIOException(e, fileName);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public byte[] getBytesNoCopy() {
    if (type == CLOB) {
        // convert hex to string
        return super.getBytesNoCopy();
    }
    if (small != null) {
        return small;
    }
    try {
        return IOUtils.readBytesAndClose(
                getInputStream(), Integer.MAX_VALUE);
    } catch (IOException e) {
        throw DbException.convertIOException(e, fileName);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public String getString() {
    int len = precision > Integer.MAX_VALUE || precision == 0 ?
            Integer.MAX_VALUE : (int) precision;
    try {
        if (type == Value.CLOB) {
            if (small != null) {
                return new String(small, Constants.UTF8);
            }
            return IOUtils.readStringAndClose(getReader(), len);
        }
        byte[] buff;
        if (small != null) {
            buff = small;
        } else {
            buff = IOUtils.readBytesAndClose(getInputStream(), len);
        }
        return StringUtils.convertBytesToHex(buff);
    } catch (IOException e) {
        throw DbException.convertIOException(e, toString());
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
/**
 * Read the given file from the file system or from the resources.
 *
 * @param file the file name
 * @return the data
 */
byte[] getFile(String file) throws IOException {
    trace("getFile <" + file + ">");
    if (file.startsWith(TRANSFER + "/") && new File(TRANSFER).exists()) {
        file = file.substring(TRANSFER.length() + 1);
        if (!isSimpleName(file)) {
            return null;
        }
        File f = new File(TRANSFER, file);
        if (!f.exists()) {
            return null;
        }
        return IOUtils.readBytesAndClose(new FileInputStream(f), -1);
    }
    byte[] data = Utils.getResource("/org/h2/server/web/res/" + file);
    if (data == null) {
        trace(" null");
    } else {
        trace(" size=" + data.length);
    }
    return data;
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private static void installPgCatalog(Statement stat) throws SQLException {
    Reader r = null;
    try {
        r = new InputStreamReader(new ByteArrayInputStream(Utils
                .getResource("/org/h2/server/pg/pg_catalog.sql")));
        ScriptReader reader = new ScriptReader(r);
        while (true) {
            String sql = reader.readStatement();
            if (sql == null) {
                break;
            }
            stat.execute(sql);
        }
        reader.close();
    } catch (IOException e) {
        throw DbException.convertIOException(e, "Can not read pg_catalog resource");
    } finally {
        IOUtils.closeSilently(r);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public OutputStream newOutputStream(boolean append) throws IOException {
    try {
        File file = new File(name);
        File parent = file.getParentFile();
        if (parent != null) {
            FileUtils.createDirectories(parent.getAbsolutePath());
        }
        FileOutputStream out = new FileOutputStream(name, append);
        IOUtils.trace("openFileOutputStream", name, out);
        return out;
    } catch (IOException e) {
        freeMemoryAndFinalize();
        return new FileOutputStream(name);
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public FileChannel open(String mode) throws IOException {
    FileDisk f;
    try {
        f = new FileDisk(name, mode);
        IOUtils.trace("open", name, f);
    } catch (IOException e) {
        freeMemoryAndFinalize();
        try {
            f = new FileDisk(name, mode);
        } catch (IOException e2) {
            throw e;
        }
    }
    return f;
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
@Override
public void run() {
    while (true) {
        try {
            int x = in.read();
            if (x < 0) {
                break;
            }
            openOutput();
            if (out != null) {
                out.write(x);
            }
        } catch (IOException e) {
            // ignore
        }
    }
    IOUtils.closeSilently(out);
    IOUtils.closeSilently(in);
    new File(processFile).delete();
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private void cat(String fileName, long length) {
    if (!FileUtils.exists(fileName)) {
        print("No such file: " + fileName);
    }
    if (FileUtils.isDirectory(fileName)) {
        print("Is a directory: " + fileName);
    }
    InputStream inFile = null;
    try {
        inFile = FileUtils.newInputStream(fileName);
        IOUtils.copy(inFile, out, length);
    } catch (IOException e) {
        error(e);
    } finally {
        IOUtils.closeSilently(inFile);
    }
    println("");
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private void processHtml(String fileName) throws Exception {
    String source = "src/tools/org/h2/jcr/";
    String target = "docs/html/";
    byte[] s = BuildBase.readFile(new File(source + "stylesheet.css"));
    BuildBase.writeFile(new File(target + "stylesheet.css"), s);
    String inFile = source + fileName;
    String outFile = target + fileName;
    new File(outFile).getParentFile().mkdirs();
    FileOutputStream out = new FileOutputStream(outFile);
    FileInputStream in = new FileInputStream(inFile);
    byte[] bytes = IOUtils.readBytesAndClose(in, 0);
    if (fileName.endsWith(".html")) {
        String page = new String(bytes);
        page = PageParser.parse(page, session);
        bytes = page.getBytes();
    }
    out.write(bytes);
    out.close();
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private static void processFile(String fileName) throws Exception {
    int idx = fileName.lastIndexOf('.');
    if (idx < 0) {
        return;
    }
    String suffix = fileName.substring(idx + 1);
    if (!suffix.equals("html") && !suffix.equals("xml") && !suffix.equals("jsp")) {
        return;
    }
    // System.out.println("Checking file:" + fileName);
    FileReader reader = new FileReader(fileName);
    String s = IOUtils.readStringAndClose(reader, -1);
    Exception last = null;
    try {
        checkXML(s, !suffix.equals("xml"));
    } catch (Exception e) {
        last = e;
        System.out.println("ERROR in file " + fileName + " " + e.toString());
    }
    if (last != null) {
        last.printStackTrace();
    }
}
 

import org.h2.util.IOUtils; //导入依赖的package包/类
private static void addFiles(File base, File file, ZipOutputStream out)
        throws IOException {
    if (file.isDirectory()) {
        for (File f : file.listFiles()) {
            addFiles(base, f, out);
        }
    } else {
        String path = file.getAbsolutePath().substring(base.getAbsolutePath().length());
        path = path.replace('\\', '/');
        if (path.startsWith("/")) {
            path = path.substring(1);
        }
        byte[] data = IOUtils.readBytesAndClose(new FileInputStream(file), -1);
        ZipEntry entry = new ZipEntry(path);
        CRC32 crc = new CRC32();
        crc.update(data);
        entry.setSize(file.length());
        entry.setCrc(crc.getValue());
        out.putNextEntry(entry);
        out.write(data);
        out.closeEntry();
    }
}