import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
@Override
public void execute() throws BuildException {
	
	checkCronExpression();
	checkScheduleName();
	
	try {
		SoapConnection tc = ConnectionFactory.getToolingConnection(getConfig());
		String apexCode = String.format(SCHEDULE_APEX, className, className, scheduleName, cron);
		executeApex(tc, apexCode);
		log(String.format("%s has been scheduled",scheduleName));
	} catch (ConnectionException e) {
		handleException(e);
	}
	
}
 

import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
public static SoapConnection getToolingConnection(PartnerConnection pc, SalesforceConfig config) throws ConnectionException {
	LoginResult lr = pc.login(config.getUsername(), config.getPassword());
	ConnectorConfig toolingConfig = new ConnectorConfig();
	toolingConfig.setSessionId(pc.getSessionHeader().getSessionId());
	toolingConfig.setServiceEndpoint(lr.getServerUrl().replace("Soap/u/", "Soap/s/"));
	toolingConfig.setManualLogin(false);
	SoapConnection soapConnection = Connector.newConnection(toolingConfig);
	return soapConnection;
}
 

import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
protected void executeApex(SoapConnection tc, String apexCode) throws BuildException {
	try {
		ExecuteAnonymousResult result = tc.executeAnonymous(apexCode); 
		if (!result.isSuccess()) {
			String error = result.isCompiled() ? result.getExceptionMessage() : result.getCompileProblem();
			throw new BuildException(error);
		}
	} catch (ConnectionException e) {
		handleException(e);
	}
}
 

import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
public ExecuteAnonymousResultExt executeAnonymous(String code, LogInfo[] logInfo, Connection connection,
        int readTimeout) {
    ConnectorConfig connectorConfig = connection.getConnectorConfig();
    
    boolean orig_traceMsg = connectorConfig.isTraceMessage();
    boolean orig_prettyPrintXml = connectorConfig.isPrettyPrintXml();
    String orig_sessionId = connectorConfig.getSessionId();
    String orig_serviceEndpoint = connectorConfig.getServiceEndpoint();
    int orig_readTimeout = connectorConfig.getReadTimeout();
    
    connectorConfig.setTraceMessage(true);
    connectorConfig.setPrettyPrintXml(true);
    connectorConfig.setSessionId(connection.getSessionId());
    connectorConfig.setServiceEndpoint(connection.getApexServiceEndpoint(connection.getServiceEndpoint()));
    connectorConfig.setReadTimeout(readTimeout);
    
    SoapConnection apex = null;
    try {
        apex = Connector.newConnection(connectorConfig);
        apex.setDebuggingHeader(logInfo, LogType.None);
        return new ExecuteAnonymousResultExt(apex.executeAnonymous(code), apex.getDebuggingInfo());
    } catch (ConnectionException e) {
        ExecuteAnonymousResult er = errorExecuteAnonymousResult(connectorConfig, e);
        ExecuteAnonymousResultExt erx = new ExecuteAnonymousResultExt(er, null == apex ? null : apex.getDebuggingInfo());
        DebuggingInfo_element dbi = new DebuggingInfo_element();
        dbi.setDebugLog(e.getMessage());
        erx.setDebugInfo(dbi);
        return erx;
    } finally {
        connectorConfig.setTraceMessage(orig_traceMsg);
        connectorConfig.setPrettyPrintXml(orig_prettyPrintXml);
        connectorConfig.setSessionId(orig_sessionId);
        connectorConfig.setServiceEndpoint(orig_serviceEndpoint);
        connectorConfig.setReadTimeout(orig_readTimeout);
    }
}
 

import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
public void execute() {
  	try {
  		if (fileName != null && ! fileName.isEmpty()) {
    	code = new Scanner(new File(fileName)).useDelimiter("\\A").next();
	}

  		SoapConnection connection = getApexConnection();

          LogInfo infoApex = new LogInfo();
          infoApex.setCategory(LogCategory.Apex_code);
          infoApex.setLevel(LogCategoryLevel.Finest);

          LogInfo infoDB = new LogInfo();
          infoDB.setCategory(LogCategory.Db);
          infoDB.setLevel(LogCategoryLevel.Finest);

          connection.setDebuggingHeader(new LogInfo[] { infoApex, infoDB }, LogType.Detail);

          ExecuteAnonymousResult result = connection.executeAnonymous(code);
          if (result.isSuccess()) {
              log(connection.getDebuggingInfo().getDebugLog());
              log("Success");
          } else {
              throw new BuildException(result.getExceptionMessage());
          }
      } catch (ConnectionException e) {
          log("Note: use ant -verbose to get more information on the failure");
          throw new BuildException("Failed: " + e.getMessage(), e);
} catch (IOException ioe) {
	log(ioe.getMessage());
}
  }
 

import com.sforce.soap.apex.SoapConnection; //导入依赖的package包/类
public void setCallOptions(SoapConnection apexConnection, String clientId) throws ForceConnectionException {
    apexConnection.setCallOptions(clientId, null, null);
}