本文整理汇总了Java中org.pentaho.di.core.exception.KettleSecurityException类的典型用法代码示例。如果您正苦于以下问题:Java KettleSecurityException类的具体用法?Java KettleSecurityException怎么用?Java KettleSecurityException使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
KettleSecurityException类属于org.pentaho.di.core.exception包,在下文中一共展示了KettleSecurityException类的17个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: loginToRepository
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void loginToRepository() throws KettleException, KettleSecurityException {
if ( model != null && model.getSelectedRepository() != null ) {
RepositoryMeta repositoryMeta =
input.getRepository( model.getRepositoryIndex( model.getSelectedRepository() ) );
repository =
PluginRegistry.getInstance().loadClass(
RepositoryPluginType.class, repositoryMeta.getId(), Repository.class );
repository.init( repositoryMeta );
repository.connect( model.getUsername(), model.getPassword() );
props.setLastRepository( repositoryMeta.getName() );
props.setLastRepositoryLogin( model.getUsername() );
} else {
log.logDetailed( BaseMessages.getString( PKG, "RepositoryLogin.ErrorLoginToRepository" ) );
throw new KettleException( BaseMessages.getString( PKG, "RepositoryLogin.ErrorLoginToRepository" ) );
}
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:17,代码来源:RepositoriesHelper.java
示例2: getExporter
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
@Override
public IRepositoryExporter getExporter() throws KettleException {
final List<String> exportPerms =
Arrays.asList( IAbsSecurityProvider.CREATE_CONTENT_ACTION, IAbsSecurityProvider.EXECUTE_CONTENT_ACTION );
IAbsSecurityProvider securityProvider = purRepositoryServiceRegistry.getService( IAbsSecurityProvider.class );
StringBuilder errorMessage = new StringBuilder( "[" );
for ( String perm : exportPerms ) {
if ( securityProvider == null && PurRepositoryConnector.inProcess() ) {
return new PurRepositoryExporter( this );
}
if ( securityProvider != null && securityProvider.isAllowed( perm ) ) {
return new PurRepositoryExporter( this );
}
errorMessage.append( perm );
errorMessage.append( ", " );
}
errorMessage.setLength( errorMessage.length() - 2 );
errorMessage.append( "]" );
throw new KettleSecurityException( BaseMessages.getString( PKG, "PurRepository.ERROR_0005_INCORRECT_PERMISSION",
errorMessage.toString() ) );
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:23,代码来源:PurRepository.java
示例3: loginToRepository
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void loginToRepository() throws KettleException, KettleSecurityException{
if(model != null && model.getSelectedRepository() != null) {
RepositoryMeta repositoryMeta = input.getRepository(model.getRepositoryIndex(model.getSelectedRepository()));
repository = PluginRegistry.getInstance().loadClass(RepositoryPluginType.class, repositoryMeta.getId(), Repository.class);
repository.init(repositoryMeta);
repository.connect(model.getUsername(), model.getPassword());
props.setLastRepository(repositoryMeta.getName());
props.setLastRepositoryLogin(model.getUsername());
} else {
log.logDetailed(BaseMessages.getString(PKG, "RepositoryLogin.ErrorLoginToRepository"));//$NON-NLS-1$
throw new KettleException(BaseMessages.getString(PKG, "RepositoryLogin.ErrorLoginToRepository"));//$NON-NLS-1$
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:14,代码来源:RepositoriesHelper.java
示例4: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void validateAction(RepositoryOperation...operations) throws KettleException, KettleSecurityException {
for (RepositoryOperation operation : operations) {
switch(operation) {
case READ_TRANSFORMATION :
break;
case MODIFY_TRANSFORMATION :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case DELETE_TRANSFORMATION :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case EXECUTE_TRANSFORMATION :
break;
case LOCK_TRANSFORMATION :
break;
case READ_JOB :
break;
case MODIFY_JOB :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case DELETE_JOB :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case EXECUTE_JOB :
break;
case LOCK_JOB :
break;
case MODIFY_DATABASE :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case DELETE_DATABASE :
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case EXPLORE_DATABASE :
break;
case MODIFY_SLAVE_SERVER:
case MODIFY_CLUSTER_SCHEMA:
case MODIFY_PARTITION_SCHEMA:
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
case DELETE_SLAVE_SERVER:
case DELETE_CLUSTER_SCHEMA:
case DELETE_PARTITION_SCHEMA:
if (capabilities.isReadOnly()) throw new KettleException(operation+" : repository is read-only");
break;
default:
throw new KettleException("Operation ["+operation+"] is unknown to the security handler.");
}
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:57,代码来源:KettleFileRepositorySecurityProvider.java
示例5: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void validateAction( RepositoryOperation... operations ) throws KettleException, KettleSecurityException {
for ( RepositoryOperation operation : operations ) {
switch ( operation ) {
case READ_TRANSFORMATION:
break;
case MODIFY_TRANSFORMATION:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case DELETE_TRANSFORMATION:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case EXECUTE_TRANSFORMATION:
break;
case LOCK_TRANSFORMATION:
break;
case READ_JOB:
break;
case MODIFY_JOB:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case DELETE_JOB:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case EXECUTE_JOB:
break;
case LOCK_JOB:
break;
case MODIFY_DATABASE:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case DELETE_DATABASE:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case EXPLORE_DATABASE:
break;
case MODIFY_SLAVE_SERVER:
case MODIFY_CLUSTER_SCHEMA:
case MODIFY_PARTITION_SCHEMA:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
case DELETE_SLAVE_SERVER:
case DELETE_CLUSTER_SCHEMA:
case DELETE_PARTITION_SCHEMA:
if ( capabilities.isReadOnly() ) {
throw new KettleException( operation + " : repository is read-only" );
}
break;
default:
throw new KettleException( "Operation [" + operation + "] is unknown to the security handler." );
}
}
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:73,代码来源:KettleFileRepositorySecurityProvider.java
示例6: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
@Override
public void connect( String username, String password ) throws KettleException, KettleSecurityException {
// TODO Auto-generated method stub
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:6,代码来源:MemoryRepository.java
示例7: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public RepositoryConnectResult connect( final String username, final String password ) throws KettleException,
KettleSecurityException;
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:3,代码来源:IRepositoryConnector.java
示例8: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void connect( String username, String password ) throws KettleException, KettleSecurityException {
throw new UnsupportedOperationException();
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:4,代码来源:RepositoryProxy.java
示例9: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* connect:连接资源库. <br/>
* @author jingma
* @return 连接后的资源库
* @throws KettleSecurityException
* @throws KettleException
* @since JDK 1.6
*/
public static Repository connect() throws KettleSecurityException, KettleException{
return connect(null,null);
}
开发者ID:majinju,项目名称:KettleEasyExpand,代码行数:12,代码来源:KettleUtils.java
示例10: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* Validates the supplied operation.
*
* @throws KettleSecurityException in case the provided user is not know or the password is incorrect
* @throws KettleException in case the action couldn't be validated because of an unexpected problem.
*/
public void validateAction(RepositoryOperation...operations) throws KettleException, KettleSecurityException;
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:8,代码来源:RepositorySecurityProvider.java
示例11: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* Connect to the repository. Make sure you don't connect more than once to the same repository with this repository object.
*
* @param username the username of the user connecting to the repository.
* @param password the password of the user connecting to the repository.
* @throws KettleSecurityException in case the supplied user or password is incorrect.
* @throws KettleException in case there is a general unexpected error OR if we're already connected to the repository.
*/
public void connect(String username, String password) throws KettleException, KettleSecurityException;
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:10,代码来源:Repository.java
示例12: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void validateAction(RepositoryOperation...operations) throws KettleException, KettleSecurityException {
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:4,代码来源:BaseRepositorySecurityProvider.java
示例13: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void validateAction(RepositoryOperation... operations) throws KettleException, KettleSecurityException {
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:4,代码来源:KettleDatabaseRepositorySecurityProvider.java
示例14: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* Validates the supplied operation.
*
* @throws KettleSecurityException
* in case the provided user is not know or the password is incorrect
* @throws KettleException
* in case the action couldn't be validated because of an unexpected problem.
*/
public void validateAction( RepositoryOperation... operations ) throws KettleException, KettleSecurityException;
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:10,代码来源:RepositorySecurityProvider.java
示例15: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* Connect to the repository. Make sure you don't connect more than once to the same repository with this repository
* object.
*
* @param username
* the username of the user connecting to the repository.
* @param password
* the password of the user connecting to the repository.
* @throws KettleSecurityException
* in case the supplied user or password is incorrect.
* @throws KettleException
* in case there is a general unexpected error OR if we're already connected to the repository.
*/
public void connect( String username, String password ) throws KettleException, KettleSecurityException;
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:15,代码来源:Repository.java
示例16: validateAction
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
public void validateAction( RepositoryOperation... operations ) throws KettleException, KettleSecurityException {
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:4,代码来源:BaseRepositorySecurityProvider.java
示例17: connect
import org.pentaho.di.core.exception.KettleSecurityException; //导入依赖的package包/类
/**
* Connect to the repository. This repository type allows to connect more than once to the same repository
* object.
*
* @param username
* the username of the user connecting to the repository.
* @param password
* the password of the user connecting to the repository.
* @throws KettleSecurityException
* in case the supplied user or password is incorrect.
* @throws KettleException
* in case there is a general unexpected error.
*/
public void connect( String username, String password ) throws KettleException, KettleSecurityException;
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:15,代码来源:ReconnectableRepository.java
注:本文中的org.pentaho.di.core.exception.KettleSecurityException类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论