Salesforceの添付ファイルを移行用にダウンロードする

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
 
import com.sforce.soap.partner.Connector;
import com.sforce.soap.partner.PartnerConnection;
import com.sforce.soap.partner.QueryResult;
import com.sforce.soap.partner.sobject.SObject;
import com.sforce.ws.ConnectionException;
import com.sforce.ws.ConnectorConfig;
import com.sforce.ws.bind.XmlObject;
import com.sforce.ws.util.Base64;
 
 
public class Main {
   
  static final String USERNAME = "YOUR-USERNAME";
  static final String PASSWORD = "YOUR-PASSWORD&SECURITY-TOKEN";
  static final String OUTPUT_DIR = "C:\OUTPUT\";
  //対象のオブジェクトのAPI参照名をセット
  static final String OBJ_TYPE = "Account";
  static PartnerConnection connection;
 
  public static void main(String[] args) {
 
    ConnectorConfig config = new ConnectorConfig();
    config.setUsername(USERNAME);
    config.setPassword(PASSWORD);
    //config.setTraceMessage(true);
    //config.setProxy("xxxxxxxxx.co.jp", 8888);
 
     
    try {
       
      connection = Connector.newConnection(config);
       
      // display some current settings
      System.out.println("Auth EndPoint: "+config.getAuthEndpoint());
      System.out.println("Service EndPoint: "+config.getServiceEndpoint());
      System.out.println("Username: "+config.getUsername());
      System.out.println("SessionId: "+config.getSessionId());
       
 
      queryAttachments();
       
       
    } catch (ConnectionException e1) {
        e1.printStackTrace();
    }  
 
  }
   
 
  private static void queryAttachments() {
        
    try {
         
      QueryResult queryResults = connection.query("SELECT Id, Name "
            + "FROM Attachment "
            + "WHERE Parent.Type IN ('"+ OBJ_TYPE + "')");
       
      System.out.println(queryResults.getSize());
       
      if (queryResults.getSize() > 0) {
          for (int i=0;i<queryResults.getRecords().length;i++) {
               
              SObject s = (SObject)queryResults.getRecords()[i];
               
              QueryResult queryAttachResults = connection.query("SELECT Id, Name, Body, "
                        + "BodyLength, ContentType, "
                        + "IsDeleted, Description, OwnerId, IsPrivate, "
                        + "ParentId, Parent.Id, Parent.Name "
                        + "FROM Attachment "
                        + "WHERE Id = '" + s.getId() + "'");
               
              SObject sAttach = (SObject)queryAttachResults.getRecords()[0];
               
              System.out.println("Id: " + sAttach.getId() + " " + sAttach.getField("Id") + " " + 
                      sAttach.getField("Name") +  sAttach.getField("ContentType"));
               
              XmlObject obj = (XmlObject)sAttach.getField("Parent");
              System.out.println(obj.getField("Id"));
              System.out.println(obj.getField("Name"));
 
              writeAttachments(sAttach, obj);
            
          }
        }
       
    } catch (Exception e) {
      e.printStackTrace();
    }    
     
  }
   
   
  private static void writeAttachments(SObject sObject, XmlObject xmlObj) throws IOException{
       
        FileOutputStream writer = null;
      
        try {
            String subdir = OUTPUT_DIR + xmlObj.getField("Id") + "_"+ xmlObj.getField("Name");
            File suvdir = new File(subdir);
 
            suvdir.mkdir();
 
            writer = new FileOutputStream(subdir + "\" + (String)sObject.getField("Name"));
 
            String s1= (String)sObject.getField("Body");
 
            writer.write(Base64.decode(s1.getBytes()));
  
            if (writer != null) {
                writer.close();
            }
 
        }catch(Exception e){
            e.printStackTrace();
             
        } 
        finally {
            if (writer != null) {
                writer.close();     }
      
        }
    }
   
  
}