org.pentaho.di.core.database.Database.checkColumnExists()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(202)

本文整理了Java中org.pentaho.di.core.database.Database.checkColumnExists()方法的一些代码示例,展示了Database.checkColumnExists()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Database.checkColumnExists()方法的具体详情如下:
包路径:org.pentaho.di.core.database.Database
类名称:Database
方法名:checkColumnExists

Database.checkColumnExists介绍

[英]See if the column specified exists by reading
[中]通过读取查看指定的列是否存在

代码示例

代码示例来源:origin: pentaho/pentaho-kettle

  1. @Test
  2. public void jobFail_columnNotExist() throws KettleException {
  3. doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
  4. doNothing().when( db ).connect( anyString(), anyString() );
  5. doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
  6. doReturn( false ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
  7. final Result result = jobEntry.execute( new Result(), 0 );
  8. assertEquals( "Should be some errors", 1, result.getNrErrors() );
  9. assertFalse( "Result should be false", result.getResult() );
  10. verify( db, atLeastOnce() ).disconnect();
  11. }

代码示例来源:origin: pentaho/pentaho-kettle

  1. @Test
  2. public void jobSuccess() throws KettleException {
  3. doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
  4. doNothing().when( db ).connect( anyString(), anyString() );
  5. doReturn( true ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
  6. doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
  7. final Result result = jobEntry.execute( new Result(), 0 );
  8. assertEquals( "Should be no error", 0, result.getNrErrors() );
  9. assertTrue( "Result should be true", result.getResult() );
  10. assertEquals( "Lines written", COLUMNS.length, result.getNrLinesWritten() );
  11. verify( db, atLeastOnce() ).disconnect();
  12. }
  13. }

代码示例来源:origin: pentaho/pentaho-kettle

  1. return checkColumnExists(
  2. databaseMeta.quoteField( columnname ),
  3. databaseMeta.getQuotedSchemaTableCombination( schemaname, tablename ) );

代码示例来源:origin: pentaho/pentaho-kettle

  1. String realColumnname = environmentSubstitute( arguments[i] );
  2. if ( db.checkColumnExists( realSchemaname, realTablename, realColumnname ) ) {
  3. if ( log.isDetailed() ) {
  4. logDetailed( BaseMessages.getString(

代码示例来源:origin: pentaho/pentaho-kettle

  1. columnexists = data.db.checkColumnExists( columnname, data.tablename );

相关文章