import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
/**
 * Installs the passed MarketEntry into the folder built by
 * buildPluginsFolderPath(marketEntry).
 * 
 * A warning dialog box is displayed if the plugin folder already exists. If
 * the user chooses to install then the plugin folder is deleted and then
 * recreated.
 * 
 * @param marketEntry
 * @throws KettleException
 */
public static void install(final MarketEntry marketEntry) throws KettleException {
  String parentFolderName = buildPluginsFolderPath(marketEntry);
  File pluginFolder = new File(parentFolderName + File.separator + marketEntry.getId());
  if (pluginFolder.exists()) {
    MessageBox mb = new MessageBox(Spoon.getInstance().getShell(), SWT.NO | SWT.YES | SWT.ICON_WARNING);
    mb.setMessage(BaseMessages.getString(PKG, "Marketplace.Dialog.PromptOverwritePlugin.Message", pluginFolder.getAbsolutePath()));
    mb.setText(BaseMessages.getString(PKG, "Marketplace.Dialog.PromptOverwritePlugin.Title"));
    int answer = SWT.NO;
    answer = mb.open();
    if (answer == SWT.YES) {
      ClassLoader cl = PluginRegistry.getInstance().getClassLoader(getPluginObject(marketEntry.getId()));
      if (cl instanceof KettleURLClassLoader) {
        ((KettleURLClassLoader)cl).closeClassLoader();
      }
      deleteDirectory(pluginFolder);
      unzipMarketEntry(parentFolderName, marketEntry.getPackageUrl());
      refreshSpoon();
    }
  } else {
    unzipMarketEntry(parentFolderName, marketEntry.getPackageUrl());
    refreshSpoon();
  }
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
public static void uninstallMarketInSeparateClassLoader(final File path) throws Exception {
  try {
    uninstall("market");
    Spoon.getInstance().getDisplay().asyncExec(new Runnable() {
      public void run() {
       try {
         MessageBox box = new MessageBox(Spoon.getInstance().getShell(), SWT.ICON_WARNING | SWT.OK);
         box.setText(BaseMessages.getString(PKG, "MarketplacesDialog.RestartUninstall.Title"));
         box.setMessage(BaseMessages.getString(PKG, "MarketplacesDialog.RestartUninstall.Message"));
         box.open();
       } finally {
         if (Market.class.getClassLoader() instanceof KettleURLClassLoader) {
           ((KettleURLClassLoader)Market.class.getClassLoader()).closeClassLoader();
         }
         path.delete();
       }
      }
    });
  } catch (Exception e) {
    e.printStackTrace();
  }
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
private static Class<?> LoadAdditionalClass(String strJar, String strClassName) throws KettleException{
	try{
		Thread t = Thread.currentThread();
		ClassLoader cl = t.getContextClassLoader();
		URL u = new URL("jar:file:"+strJar+"!/");
		KettleURLClassLoader kl = new KettleURLClassLoader(new URL[]{u}, cl);
		Class<?> toRun = kl.loadClass(strClassName);
		return toRun;
	}catch(Exception e){
		throw new KettleException(BaseMessages.getString(PKG, "ScriptMeta.Exception.UnableToLoadAdditionalClass"), e); //$NON-NLS-1$
	}
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
private static Class<?> LoadAdditionalClass(String strJar, String strClassName) throws KettleException{
	try{
		Thread t = Thread.currentThread();
		ClassLoader cl = t.getContextClassLoader();
		URL u = new URL("jar:file:"+strJar+"!/");
		KettleURLClassLoader kl = new KettleURLClassLoader(new URL[]{u}, cl);
		Class<?> toRun = kl.loadClass(strClassName);
		return toRun;
	}catch(Exception e){
		throw new KettleException(BaseMessages.getString(PKG, "ScriptValuesMetaMod.Exception.UnableToLoadAdditionalClass"), e); //$NON-NLS-1$
	}
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
/**
 * Uninstalls the passed MarketEntry.
 * 
 * @param marketEntry
 * @throws KettleException
 */
public static void uninstall(final String pluginId) throws KettleException {
  PluginInterface plugin = getPluginObject(pluginId);
  if (plugin == null) {
    throw new KettleException("No Plugin!");
  }
  String pluginFolderName = plugin.getPluginDirectory().getFile();
  File folder = new File(pluginFolderName);
  try {
    ClassLoader cl = PluginRegistry.getInstance().getClassLoader(getPluginObject(pluginId));
    if (cl instanceof KettleURLClassLoader) {
      ((KettleURLClassLoader)cl).closeClassLoader();
    }
  } catch (Throwable t) {
    t.printStackTrace();
  }
  deleteDirectory(folder);

  if (!Display.getDefault().getThread().equals(Thread.currentThread()) ) {
    Spoon.getInstance().getDisplay().asyncExec(new Runnable() {
      public void run() {
        try {
          refreshSpoon();
        } catch (KettleException e) {
          e.printStackTrace();
        }
      }
    });
  } else {
    refreshSpoon();
  }
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
private static Class<?> LoadAdditionalClass( String strJar, String strClassName ) throws KettleException {
  try {
    Thread t = Thread.currentThread();
    ClassLoader cl = t.getContextClassLoader();
    URL u = new URL( "jar:file:" + strJar + "!/" );
    KettleURLClassLoader kl = new KettleURLClassLoader( new URL[] { u }, cl );
    Class<?> toRun = kl.loadClass( strClassName );
    return toRun;
  } catch ( Exception e ) {
    throw new KettleException( BaseMessages
        .getString( PKG, "GremlinScriptMeta.Exception.UnableToLoadAdditionalClass" ), e );
  }
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
private static Class<?> LoadAdditionalClass( String strJar, String strClassName ) throws KettleException {
  try {
    Thread t = Thread.currentThread();
    ClassLoader cl = t.getContextClassLoader();
    URL u = new URL( "jar:file:" + strJar + "!/" );
    // We never know what else the script wants to load with the class loader, so lets not close it just like that.
    @SuppressWarnings( "resource" )
    KettleURLClassLoader kl = new KettleURLClassLoader( new URL[] { u }, cl );
    Class<?> toRun = kl.loadClass( strClassName );
    return toRun;
  } catch ( Exception e ) {
    throw new KettleException(
      BaseMessages.getString( PKG, "ScriptMeta.Exception.UnableToLoadAdditionalClass" ), e );
  }
}
 

import org.pentaho.di.core.plugins.KettleURLClassLoader; //导入依赖的package包/类
private static Class<?> LoadAdditionalClass( String strJar, String strClassName ) throws KettleException {
  try {
    Thread t = Thread.currentThread();
    ClassLoader cl = t.getContextClassLoader();
    URL u = new URL( "jar:file:" + strJar + "!/" );
    // We never know what else the script wants to load with the class loader, so lets not close it just like that.
    @SuppressWarnings( "resource" )
    KettleURLClassLoader kl = new KettleURLClassLoader( new URL[] { u }, cl );
    Class<?> toRun = kl.loadClass( strClassName );
    return toRun;
  } catch ( Exception e ) {
    throw new KettleException( BaseMessages.getString(
      PKG, "ScriptValuesMetaMod.Exception.UnableToLoadAdditionalClass" ), e );
  }
}