SalesForceのオブジェクトをJavaのAPIで取得し、csvに出力する手順 – その②

package jp.koji;

import java.io.IOException;
import java.rmi.RemoteException;

import javax.xml.rpc.ServiceException;

import com.sforce.soap.enterprise.LoginResult;
import com.sforce.soap.enterprise.SessionHeader;
import com.sforce.soap.enterprise.SforceServiceLocator;
import com.sforce.soap.enterprise.SoapBindingStub;

public class SfdcSession {


/** ユーザーID */
private String uid = null;

/** ユーザーパスワード */
private String pwd = null;

/** エンドポイント */
private String endpoint = null;

/** セールフォースのセッションクラス */
private static SfdcSession currentSession = null;

/** SoapBindingStubクラス */
public SoapBindingStub binding = null;

/** LoginResultクラス */
private LoginResult lr = null;

/** セッションヘッダクラス */
private SessionHeader sh = null;


public SfdcSession(String uid, String pwd, String endpoint) {
    this.uid = uid;
    this.pwd = pwd;
    this.endpoint = endpoint;
}


public static SfdcSession openSession(String uid, String pwd, String endpoint)
throws IOException {

    currentSession = new SfdcSession(uid, pwd, endpoint);
    currentSession.close();
    currentSession.connect();
    return currentSession;
}


public void connect() throws IOException {
    // SOARBinding生成
    try {
        SforceServiceLocator sfl = new SforceServiceLocator();
        sfl.setSoapEndpointAddress(endpoint.trim());
        binding = (SoapBindingStub)sfl.getSoap();
    } catch (ServiceException e) {
        throw new IOException("SFDCへの接続失敗");
    }

    // ログイン
    lr = binding.login(this.uid, this.pwd);

    // エンドポイントURLセット
    binding._setProperty(SoapBindingStub.ENDPOINT_ADDRESS_PROPERTY, lr.getServerUrl());

    // セッションヘッダ作成
    sh = new SessionHeader();
    sh.setSessionId(lr.getSessionId());

    // セッションヘッダをセット
    binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(),
    SessionHeader, sh);
}

/**
 * ログアウト
 *
 */
public void close() {
    if (binding != null) {
        try {
            binding.logout();
        } catch (RemoteException e) {
            e.printStackTrace();
        } finally {
        binding = null;
        }
    }
}


/**
 * タイムアウト時間設定
 *
 * @param timeout タイムアウト時間
 */
public void setTimeOut(int timeout) {
    binding.setTimeout(timeout);
}

}

public class Brand__c  extends com.sforce.soap.enterprise.sobject.SObject  implements java.io.Serializable

package jp.koji;

import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import com.sforce.soap.enterprise.QueryResult;
import com.sforce.soap.enterprise.sobject.Brand__c;
import com.sforce.soap.enterprise.sobject.SObject;


public class SfdcConTest {

private static String SFDC_USER_ID = "userid";

private static String SFDC_PASSWORD = "password";

private static String SFDC_END_POINT = "https://login.salesforce.com/services/Soap/c/21.0/0DF10000000TSF7";

public static void main(String[] args) {

SfdcSession sfdcSession = null;

try{

    System.setProperty("http.proxyHost", "xxxxxxxxxx.co.jp");
    System.setProperty("http.proxyPort", "8080");

    // セールスフォースへのセッションを作成
    sfdcSession = SfdcSession.openSession(
        SFDC_USER_ID,
        SFDC_PASSWORD,
        SFDC_END_POINT);

    // タイムアウト時間設定
    sfdcSession.setTimeOut(600000);

    List<Brand__c> objectList = new ArrayList<Brand__c>();
    // SOQLの作成
    StringBuffer selectQuery = new StringBuffer();
    selectQuery.append("SELECT ");
    selectQuery.append("Id, ");
    selectQuery.append("Name ");
    selectQuery.append("FROM ");
    selectQuery.append("Brand__c ");
    selectQuery.append("where IsDeleted = false ");

    // クエリ実行
    QueryResult rs = sfdcSession.binding.query(selectQuery.toString());

    // 検索結果の取得
    boolean done = false;
    if (rs.getSize() > 0){
        while (!done) {
            for (SObject so : rs.getRecords()) {
                objectList.add((Brand__c)so);
            }
            // 取得件数が多い場合は再検索をおこなう
            if (rs.isDone()) {
                done = true;
            } else {
                rs = sfdcSession.binding.queryMore(rs.getQueryLocator());
            }
        }
    }


    File csv = new File("writers.csv"); // CSVデータファイル

    // 追記モード
    BufferedWriter bw = new BufferedWriter(new FileWriter(csv, true));

    Iterator<Brand__c> iter = objectList.iterator();
    while(iter.hasNext()) {
        Brand__c _sb = iter.next();
        bw.write(_sb.getId() + "," + _sb.getName());
        bw.newLine();
    }
    bw.close();


}catch(Exception e){
    e.printStackTrace();
}

}

}