import org.pentaho.di.core.database.DataSourceNamingException; //导入依赖的package包/类
protected <T extends IDBDatasourceService> DataSource getNamedDataSourceFromService(
  Class<T> dataSourceServiceInterface, String dataSourceName ) throws DataSourceNamingException {
  T datasourceService = PentahoSystem.get( dataSourceServiceInterface, null );

  IDBDatasourceService service =
    ( datasourceService == null ) ? PentahoSystem.get( IDBDatasourceService.class, null ) : datasourceService;

  if ( service != null ) {
    try {
      return service.getDataSource( dataSourceName );
    } catch ( DBDatasourceServiceException ex ) {
      throw new DataSourceNamingException( ex );
    }
  }
  return null;
}
 

import org.pentaho.di.core.database.DataSourceNamingException; //导入依赖的package包/类
/**
 * Implementation of DatasourceProviderInterface.
 * 
 */
public DataSource getNamedDataSource(String datasourceName) throws DataSourceNamingException {
  try {
    return DatabaseUtil.getDataSourceFromJndi(datasourceName);
  } catch (NamingException ex) {
    throw new DataSourceNamingException(ex);
  }
}
 

import org.pentaho.di.core.database.DataSourceNamingException; //导入依赖的package包/类
@Override
public DataSource getNamedDataSource( String dataSourceName, DataSourceProviderInterface.DatasourceType type )
  throws DataSourceNamingException {
  if ( type != null ) {
    switch( type ) {
      case JNDI:
        return getNamedDataSourceFromService( IJndiDatasourceService.class, dataSourceName );
      case POOLED:
        return getNamedDataSourceFromService( IPooledDatasourceService.class, dataSourceName );
    }
  }
  throw new DataSourceNamingException(
    String.format( "Unknown data source type [%s] for named data source [%s]", type, dataSourceName ) );
}
 

import org.pentaho.di.core.database.DataSourceNamingException; //导入依赖的package包/类
/**
 * Implementation of DatasourceProviderInterface.
 */
@Override
public DataSource getNamedDataSource( String datasourceName ) throws DataSourceNamingException {
  ClassLoader original = Thread.currentThread().getContextClassLoader();
  try {
    Thread.currentThread().setContextClassLoader( getClass().getClassLoader() );
    return DatabaseUtil.getDataSourceFromJndi( datasourceName, new InitialContext() );
  } catch ( NamingException ex ) {
    throw new DataSourceNamingException( ex );
  } finally {
    Thread.currentThread().setContextClassLoader( original );
  }

}