Package com.jcraft.jsch

Examples of com.jcraft.jsch.ChannelSftp

253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
     * @param session
     *            to connect to
     * @return channelSftp or null if not successful (channel not existent or dead)
     */
    public ChannelSftp getChannelSftp(Session session) throws IOException {
        ChannelSftp channel = null;
        Entry entry = getCacheEntry(session);
        if (entry != null) {
            channel = entry.getChannelSftp();
            if (channel != null && !channel.isConnected()) {
                entry.releaseChannelSftp();
                channel = null;
            }
        }
        return channel;
View Full Code Here
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
   * @throws IOException if any connection problem occurs
   */
  private ChannelSftp getSftpChannel(String pathOrUri) throws IOException {
      Session session = getSession(pathOrUri);
        String host = session.getHost();
        ChannelSftp channel = SshCache.getInstance().getChannelSftp(session);
        if(channel == null) {
            try {
                channel = (ChannelSftp) session.openChannel("sftp");
                channel.connect();
                Message.verbose(":: SFTP :: connected to "+host+"!");
                SshCache.getInstance().attachChannelSftp(session,channel);
            } catch (JSchException e) {
                IOException ex = new IOException(e.getMessage());
                ex.initCause(e);
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
     * retrieves an sftp channel from the cache
     * @param host to connect to
     * @return channelSftp or null if not successful (channel not existent or dead)
     */
    public ChannelSftp getChannelSftp(Session session) throws IOException {
        ChannelSftp channel = null;
        Entry entry = getCacheEntry(session);
        if(entry != null) {
            channel = entry.getChannelSftp();
            if(channel != null && !channel.isConnected()) {
                entry.releaseChannelSftp();
                channel = null;
            }
        }   
        return channel;
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
     * @return a fully initialised resource, able to answer to all its methods without needing
     *   any further connection
     */
  public Resource resolveResource(String path) {
    try {
      ChannelSftp c = getSftpChannel(path);
      Collection r = c.ls(path);
      if (r != null) {
        for (Iterator iter = r.iterator(); iter.hasNext();) {
          Object obj=iter.next();
                  if(obj instanceof LsEntry){
                    LsEntry entry = (LsEntry) obj;
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
118
119
    }
    return new BasicResource(path, false, 0, 0, false);
  }

  public InputStream openStream(SFTPResource resource) throws IOException {
        ChannelSftp c = getSftpChannel(resource.getName());
        try {
      return c.get(resource.getName());
    } catch (SftpException e) {
      e.printStackTrace();
      IOException ex = new IOException("impossible to open stream for "+resource+" on "+getHost()+(e.getMessage() != null?": " + e.getMessage():""));
      ex.initCause(e);
      throw ex;
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
131
132
    }
  }

    public void get(String source, File destination) throws IOException {
        fireTransferInitiated(getResource(source), TransferEvent.REQUEST_GET);
        ChannelSftp c = getSftpChannel(source);
        try {
      c.get(source, destination.getAbsolutePath(), new MyProgressMonitor());
    } catch (SftpException e) {
      e.printStackTrace();
      IOException ex = new IOException("impossible to get "+source+" on "+getHost()+(e.getMessage() != null?": " + e.getMessage():""));
      ex.initCause(e);
      throw ex;
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
    }
    }

  public void put(File source, String destination, boolean overwrite) throws IOException {
        fireTransferInitiated(getResource(destination), TransferEvent.REQUEST_PUT);
        ChannelSftp c = getSftpChannel(destination);
        try {
            if(!overwrite && checkExistence(destination, c))
                throw new IOException("destination file exists and overwrite == true");
          if (destination.indexOf('/') != -1) {
            mkdirs(destination.substring(0, destination.lastIndexOf('/')),c);
          }
      c.put(source.getAbsolutePath(), destination, new MyProgressMonitor());
    } catch (SftpException e) {
      IOException ex = new IOException(e.getMessage());
      ex.initCause(e);
      throw ex;
    }
View Full Code Here
167
168
169
170
171
172
173
174
175
176
177
178
  }


  public List list(String parent) throws IOException {
    try {
      ChannelSftp c = getSftpChannel(parent);
      Collection r = c.ls(parent);
      if (r != null) {
        if (!parent.endsWith("/")) {
          parent = parent+"/";
        }
        List result = new ArrayList();
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
        String unixPath = "target/scp/out.txt";
        File target = new File(unixPath);
        root.mkdirs();
        assertTrue(root.exists());

        ChannelSftp c = (ChannelSftp) session.openChannel("sftp");
        c.connect();
        c.put(new ByteArrayInputStream("0123456789".getBytes()), unixPath);

        assertTrue(target.exists());
        assertEquals("0123456789", readFile(unixPath));

        OutputStream os = c.put(unixPath, null, ChannelSftp.APPEND, -5);
        os.write("a".getBytes());
        os.close();
        c.disconnect();

        assertTrue(target.exists());
        assertEquals("01234a", readFile(unixPath));

        target.delete();
View Full Code Here
173
174
175
176
177
178
179
180
181
182
183
184
        root.delete();
    }

    @Test
    public void testReadDir() throws Exception {
        ChannelSftp c = (ChannelSftp) session.openChannel("sftp");
        c.connect();
        Vector res = c.ls("target/classes/org/apache/sshd/");
        for (Object f : res) {
            System.out.println(f.toString());
        }
    }
View Full Code Here
TOP

Related Classes of com.jcraft.jsch.ChannelSftp

  • cn.baiweigang.qtaf.toolkit.util.SftpFileUtil
  • com.alibaba.antx.config.resource.ssh.SshSession
  • com.carrotgarden.maven.aws.ssh.CarrotSecureShell
  • com.carrotgarden.maven.aws.ssh.SecureShell
  • com.dp.nebula.wormhole.plugins.reader.sftpreader.SftpReaderTest
  • com.dp.nebula.wormhole.plugins.writer.sftpwriter.sftpWriterTest
  • com.tririga.custom.App
  • com.vaadin.tests.integration.WebSpherePortalIntegrationTest
  • genqa.ExportOnServerVerifier
  • gri.gridp.tasks.ssh.SshProxyExecutor
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.