Java WebResult类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.pentaho.di.www.WebResult类的典型用法代码示例。如果您正苦于以下问题：Java WebResult类的具体用法？Java WebResult怎么用？Java WebResult使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

WebResult类属于org.pentaho.di.www包，在下文中一共展示了WebResult类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: pause

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
protected void pause() {
  TreeEntry treeEntry = getTreeEntry();
  if (treeEntry == null)
    return;

  // Transformations
  //
  if (treeEntry.isTransformation()) {
    try {
      WebResult webResult = slaveServer.pauseResumeTransformation(treeEntry.name, treeEntry.id);
      if (!webResult.getResult().equalsIgnoreCase(WebResult.STRING_OK)) {
        EnterTextDialog dialog = new EnterTextDialog(shell, BaseMessages.getString(PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Title"),
            BaseMessages.getString(PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Message"), webResult.getMessage());
        dialog.setReadOnly();
        dialog.open();
      }
    } catch (Exception e) {
      new ErrorDialog(shell, BaseMessages.getString(PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Title"), BaseMessages.getString(PKG,
          "SpoonSlave.ErrorPausingOrResumingTrans.Message"), e);
    }
  }
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:23，代码来源:SpoonSlave.java

示例2: cancel

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
public synchronized void cancel() throws SQLException {
  
  // Kill the service transformation on the server...
  // Only ever try once.
  //
  if (!stopped.get()) {
    stopped.set(true);
    try {
      String reply = HttpUtil.execService(new Variables(), 
          connection.getHostname(), connection.getPort(), connection.getWebAppName(), 
          connection.getService()+"/stopTrans"+"/?name="+URLEncoder.encode(serviceTransName, "UTF-8")+"&id="+Const.NVL(serviceObjectId, "")+"&xml=Y",
          connection.getUsername(), connection.getPassword(), 
          connection.getProxyHostname(), connection.getProxyPort(), connection.getNonProxyHosts());
      
      WebResult webResult = new WebResult(XMLHandler.loadXMLString(reply, WebResult.XML_TAG));
      if (!"OK".equals(webResult.getResult())) {
        throw new SQLException("Cancel on remote server failed: "+webResult.getMessage());
      }
      
    } catch(Exception e) {
      throw new SQLException("Couldn't cancel SQL query on slave server", e);
    }
  }
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:25，代码来源:ThinResultSet.java

示例3: cleanupSlaveServer

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
/**
 * Cleanup the slave server as part of a clustered transformation.
 *
 * @param transSplitter
 *          the TransSplitter object
 * @param slaveServer
 *          the slave server
 * @param slaveTransMeta
 *          the slave transformation meta-data
 * @throws KettleException
 *           if any errors occur during cleanup
 */
public static void cleanupSlaveServer( TransSplitter transSplitter, SlaveServer slaveServer,
    TransMeta slaveTransMeta ) throws KettleException {
  String transName = slaveTransMeta.getName();
  try {
    String carteObjectId = transSplitter.getCarteObjectMap().get( slaveTransMeta );
    WebResult webResult = slaveServer.cleanupTransformation( transName, carteObjectId );
    if ( !WebResult.STRING_OK.equals( webResult.getResult() ) ) {
      throw new KettleException( "Unable to run clean-up on slave server '" + slaveServer + "' for transformation '"
          + transName + "' : " + webResult.getMessage() );
    }
  } catch ( Exception e ) {
    throw new KettleException( "Unexpected error contacting slave server '" + slaveServer
        + "' to clear up transformation '" + transName + "'", e );
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:28，代码来源:Trans.java

示例4: pause

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
protected void pause() {
  TreeEntry treeEntry = getTreeEntry();
  if ( treeEntry == null ) {
    return;
  }

  if ( treeEntry.isTransformation() ) {
    // Transformation
    try {
      WebResult webResult = slaveServer.pauseResumeTransformation( treeEntry.name, treeEntry.id );
      if ( !WebResult.STRING_OK.equalsIgnoreCase( webResult.getResult() ) ) {
        EnterTextDialog dialog =
          new EnterTextDialog( shell,
            BaseMessages.getString( PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Title" ),
            BaseMessages.getString( PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Message" ),
            webResult.getMessage() );
        dialog.setReadOnly();
        dialog.open();
      }
    } catch ( Exception e ) {
      new ErrorDialog( shell,
        BaseMessages.getString( PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Title" ),
        BaseMessages.getString( PKG, "SpoonSlave.ErrorPausingOrResumingTrans.Message" ), e );
    }
  }
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:27，代码来源:SpoonSlave.java

示例5: cleanupSlaveServer

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
public static void cleanupSlaveServer(TransSplitter transSplitter, SlaveServer slaveServer, TransMeta slaveTransMeta) throws KettleException {
  String transName = slaveTransMeta.getName();
  try {
    String carteObjectId = transSplitter.getCarteObjectMap().get(slaveTransMeta);
    WebResult webResult = slaveServer.cleanupTransformation(transName, carteObjectId);
    if (!WebResult.STRING_OK.equals(webResult.getResult()))
    {
        throw new KettleException("Unable to run clean-up on slave server '"+slaveServer+"' for transformation '"+transName+"' : "+webResult.getMessage());
    }
  } catch(Exception e) {
    throw new KettleException("Unexpected error contacting slave server '"+slaveServer+"' to clear up transformation '"+transName+"'", e);
  }
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:14，代码来源:Trans.java

示例6: remove

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
protected void remove() {
  TreeEntry treeEntry = getTreeEntry();
  if (treeEntry == null)
    return;

  // Transformations
  //
  if (treeEntry.isTransformation()) {
    SlaveServerTransStatus transStatus = slaveServerStatus.findTransStatus(treeEntry.name, treeEntry.id);
    if (transStatus != null) {
      if (!transStatus.isRunning() && !transStatus.isPaused() && !transStatus.isStopped()) {
        try {
          WebResult webResult = slaveServer.removeTransformation(treeEntry.name, transStatus.getId());
          if (!webResult.getResult().equalsIgnoreCase(WebResult.STRING_OK)) {
            EnterTextDialog dialog = new EnterTextDialog(shell, BaseMessages.getString(PKG, "SpoonSlave.ErrorRemovingTrans.Title"), BaseMessages.getString(
                PKG, "SpoonSlave.ErrorRemovingTrans.Message"), webResult.getMessage());
            dialog.setReadOnly();
            dialog.open();
          }
        } catch (Exception e) {
          new ErrorDialog(shell, BaseMessages.getString(PKG, "SpoonSlave.ErrorRemovingTrans.Title"), BaseMessages.getString(PKG,
              "SpoonSlave.ErrorRemovingTrans.Message"), e);
        }
      }
    }
  }

  // TODO: support for jobs
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:30，代码来源:SpoonSlave.java

示例7: cleanupSlaveServer

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
/**
 * Cleanup the slave server as part of a clustered transformation.
 *
 * @param transSplitter the TransSplitter object
 * @param slaveServer the slave server
 * @param slaveTransMeta the slave transformation meta-data
 * @throws KettleException if any errors occur during cleanup
 */
public static void cleanupSlaveServer(TransSplitter transSplitter, SlaveServer slaveServer, TransMeta slaveTransMeta) throws KettleException {
  String transName = slaveTransMeta.getName();
  try {
    String carteObjectId = transSplitter.getCarteObjectMap().get(slaveTransMeta);
    WebResult webResult = slaveServer.cleanupTransformation(transName, carteObjectId);
    if (!WebResult.STRING_OK.equals(webResult.getResult()))
    {
        throw new KettleException("Unable to run clean-up on slave server '"+slaveServer+"' for transformation '"+transName+"' : "+webResult.getMessage());
    }
  } catch(Exception e) {
    throw new KettleException("Unexpected error contacting slave server '"+slaveServer+"' to clear up transformation '"+transName+"'", e);
  }
}

开发者ID:bsspirit，项目名称:kettle-4.4.0-stable，代码行数:22，代码来源:Trans.java

示例8: sendXML

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
public String sendXML(String xml, String service) throws Exception
{
	byte[] content = xml.getBytes(Const.XML_ENCODING);
	PutMethod put = getSendByteArrayMethod(content, service);
	
    // Get HTTP client
    // 
    HttpClient client = new HttpClient();
    addCredentials(client);
    
    // Execute request
    // 
    try
    {
        int result = client.executeMethod(put);
        
        // The status code
        log.logDebug(toString(), Messages.getString("SlaveServer.DEBUG_ResponseStatus", Integer.toString(result))); //$NON-NLS-1$
        
        // the response
        InputStream inputStream = new BufferedInputStream(put.getResponseBodyAsStream(), 1000);
        
        StringBuffer bodyBuffer = new StringBuffer();
        int c;
        while ( (c=inputStream.read())!=-1) bodyBuffer.append((char)c);
        inputStream.close();
        String bodyTmp = bodyBuffer.toString();
        
        switch(result)
        {
        case 401: // Security problem: authentication required
          // Non-internationalized message
            String message = "Authentication failed"+Const.DOSCR+Const.DOSCR+bodyTmp; //$NON-NLS-1$
            WebResult webResult = new WebResult(WebResult.STRING_ERROR, message);
            bodyBuffer.setLength(0);
            bodyBuffer.append(webResult.getXML());
            break;
        }

        String body = bodyBuffer.toString();
        

        // String body = post.getResponseBodyAsString(); 
        log.logDebug(toString(), Messages.getString("SlaveServer.DEBUG_ResponseBody",body)); //$NON-NLS-1$
        
        return body;
    }
    finally
    {
        // Release current connection to the connection pool once you are done
        put.releaseConnection();
        log.logDetailed(toString(), Messages.getString("SlaveServer.DETAILED_SentXmlToService", service, environmentSubstitute(hostname))); //$NON-NLS-1$
    }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:55，代码来源:SlaveServer.java

示例9: sendExport

import org.pentaho.di.www.WebResult; //导入依赖的package包/类
/**
 * Send an exported archive over to this slave server
 * @param filename The archive to send
 * @param type The type of file to add to the slave server (AddExportServlet.TYPE_*)
 * @param load The filename to load in the archive (the .kjb or .ktr)
 * @return the XML of the web result
 * @throws Exception in case something goes awry
 */
public String sendExport(String filename, String type, String load) throws Exception
{
	String serviceUrl=AddExportServlet.CONTEXT_PATH;
	if (type!=null && load!=null) {
		serviceUrl = serviceUrl+= "/?"+AddExportServlet.PARAMETER_TYPE+"="+type+"&"+AddExportServlet.PARAMETER_LOAD+"="+URLEncoder.encode(load, "UTF-8");
	}

    String urlString = constructUrl(serviceUrl);
    log.logDebug(toString(), Messages.getString("SlaveServer.DEBUG_ConnectingTo", urlString)); //$NON-NLS-1$

    PutMethod putMethod = new PutMethod(urlString);
    
    // Request content will be retrieved directly from the input stream
    // 
	FileObject fileObject = KettleVFS.getFileObject(filename);
    RequestEntity entity = new InputStreamRequestEntity(KettleVFS.getInputStream(fileObject));
    
    putMethod.setRequestEntity(entity);
    putMethod.setDoAuthentication(true);
    putMethod.addRequestHeader(new Header("Content-Type", "binary/zip"));
	
    // Get HTTP client
    // 
    HttpClient client = new HttpClient();
    addCredentials(client);
    
    // Execute request
    // 
    try
    {
        int result = client.executeMethod(putMethod);
        
        // The status code
        log.logDebug(toString(), Messages.getString("SlaveServer.DEBUG_ResponseStatus", Integer.toString(result))); //$NON-NLS-1$
        
        // the response
        InputStream inputStream = new BufferedInputStream(putMethod.getResponseBodyAsStream(), 1000);
        
        StringBuffer bodyBuffer = new StringBuffer();
        int c;
        while ( (c=inputStream.read())!=-1) bodyBuffer.append((char)c);
        inputStream.close();
        String bodyTmp = bodyBuffer.toString();
        
        switch(result)
        {
        case 401: // Security problem: authentication required
          // Non-internationalized message
            String message = "Authentication failed"+Const.DOSCR+Const.DOSCR+bodyTmp; //$NON-NLS-1$
            WebResult webResult = new WebResult(WebResult.STRING_ERROR, message);
            bodyBuffer.setLength(0);
            bodyBuffer.append(webResult.getXML());
            break;
        }

        String body = bodyBuffer.toString();
        

        // String body = post.getResponseBodyAsString(); 
        log.logDebug(toString(), Messages.getString("SlaveServer.DEBUG_ResponseBody",body)); //$NON-NLS-1$
        
        return body;
    }
    finally
    {
        // Release current connection to the connection pool once you are done
        putMethod.releaseConnection();
        log.logDetailed(toString(), Messages.getString("SlaveServer.DETAILED_SentExportToService", AddExportServlet.CONTEXT_PATH, environmentSubstitute(hostname))); //$NON-NLS-1$
    }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:79，代码来源:SlaveServer.java