Java 类org.springframework.util.FileCopyUtils 实例源码

项目：lams 文件：TemporaryLobCreator.java

@Override
public void setClobAsAsciiStream(
        PreparedStatement ps, int paramIndex, InputStream asciiStream, int contentLength)
        throws SQLException {

    Clob clob = ps.getConnection().createClob();
    try {
        FileCopyUtils.copy(asciiStream, clob.setAsciiStream(1));
    }
    catch (IOException ex) {
        throw new DataAccessResourceFailureException("Could not copy into LOB stream", ex);
    }

    this.temporaryClobs.add(clob);
    ps.setClob(paramIndex, clob);

    if (logger.isDebugEnabled()) {
        logger.debug(asciiStream != null ?
                "Copied ASCII stream into temporary CLOB with length " + contentLength :
                "Set CLOB to null");
    }
}

项目：lams 文件：TemporaryLobCreator.java

@Override
public void setClobAsCharacterStream(
        PreparedStatement ps, int paramIndex, Reader characterStream, int contentLength)
        throws SQLException {

    Clob clob = ps.getConnection().createClob();
    try {
        FileCopyUtils.copy(characterStream, clob.setCharacterStream(1));
    }
    catch (IOException ex) {
        throw new DataAccessResourceFailureException("Could not copy into LOB stream", ex);
    }

    this.temporaryClobs.add(clob);
    ps.setClob(paramIndex, clob);

    if (logger.isDebugEnabled()) {
        logger.debug(characterStream != null ?
                "Copied character stream into temporary CLOB with length " + contentLength :
                "Set CLOB to null");
    }
}

项目：lams 文件：OracleLobHandler.java

@Override
public void setClobAsString(PreparedStatement ps, int paramIndex, final String content)
    throws SQLException {

    if (content != null) {
        Clob clob = (Clob) createLob(ps, true, new LobCallback() {
            @Override
            public void populateLob(Object lob) throws Exception {
                Method methodToInvoke = lob.getClass().getMethod("getCharacterOutputStream", (Class[]) null);
                Writer writer = (Writer) methodToInvoke.invoke(lob, (Object[]) null);
                FileCopyUtils.copy(content, writer);
            }
        });
        ps.setClob(paramIndex, clob);
        if (logger.isDebugEnabled()) {
            logger.debug("Set string for Oracle CLOB with length " + clob.length());
        }
    }
    else {
        ps.setClob(paramIndex, (Clob) null);
        logger.debug("Set Oracle CLOB to null");
    }
}

项目：lams 文件：OracleLobHandler.java

@Override
public void setClobAsAsciiStream(
        PreparedStatement ps, int paramIndex, final InputStream asciiStream, int contentLength)
    throws SQLException {

    if (asciiStream != null) {
        Clob clob = (Clob) createLob(ps, true, new LobCallback() {
            @Override
            public void populateLob(Object lob) throws Exception {
                Method methodToInvoke = lob.getClass().getMethod("getAsciiOutputStream", (Class[]) null);
                OutputStream out = (OutputStream) methodToInvoke.invoke(lob, (Object[]) null);
                FileCopyUtils.copy(asciiStream, out);
            }
        });
        ps.setClob(paramIndex, clob);
        if (logger.isDebugEnabled()) {
            logger.debug("Set ASCII stream for Oracle CLOB with length " + clob.length());
        }
    }
    else {
        ps.setClob(paramIndex, (Clob) null);
        logger.debug("Set Oracle CLOB to null");
    }
}

项目：lams 文件：OracleLobHandler.java

@Override
public void setClobAsCharacterStream(
        PreparedStatement ps, int paramIndex, final Reader characterStream, int contentLength)
    throws SQLException {

    if (characterStream != null) {
        Clob clob = (Clob) createLob(ps, true, new LobCallback() {
            @Override
            public void populateLob(Object lob) throws Exception {
                Method methodToInvoke = lob.getClass().getMethod("getCharacterOutputStream", (Class[]) null);
                Writer writer = (Writer) methodToInvoke.invoke(lob, (Object[]) null);
                FileCopyUtils.copy(characterStream, writer);
            }
        });
        ps.setClob(paramIndex, clob);
        if (logger.isDebugEnabled()) {
            logger.debug("Set character stream for Oracle CLOB with length " + clob.length());
        }
    }
    else {
        ps.setClob(paramIndex, (Clob) null);
        logger.debug("Set Oracle CLOB to null");
    }
}

项目：lams 文件：SimpleBufferingClientHttpRequest.java

@Override
protected ClientHttpResponse executeInternal(HttpHeaders headers, byte[] bufferedOutput) throws IOException {
    for (Map.Entry<String, List<String>> entry : headers.entrySet()) {
        String headerName = entry.getKey();
        for (String headerValue : entry.getValue()) {
            this.connection.addRequestProperty(headerName, headerValue);
        }
    }

    if (this.connection.getDoOutput() && this.outputStreaming) {
        this.connection.setFixedLengthStreamingMode(bufferedOutput.length);
    }
    this.connection.connect();
    if (this.connection.getDoOutput()) {
        FileCopyUtils.copy(bufferedOutput, this.connection.getOutputStream());
    }

    return new SimpleClientHttpResponse(this.connection);
}

项目：spring-cloud-skipper 文件：HelpAwareShellApplicationRunner.java

@Override
public void run(ApplicationArguments args) throws Exception {
    if (ShellUtils.hasHelpOption(args)) {
        String usageInstructions;

        final Reader reader = new InputStreamReader(getInputStream(HelpAwareShellApplicationRunner.class, "/usage.txt"));

        try {
            usageInstructions = FileCopyUtils.copyToString(new BufferedReader(reader));
            usageInstructions.replaceAll("(\\r|\\n)+", System.getProperty("line.separator"));
        }
        catch (Exception ex) {
            throw new IllegalStateException("Cannot read stream", ex);
        }
        System.out.println(usageInstructions);
    }
}