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

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

本文整理了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

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

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

@Test
 public void jobSuccess() throws KettleException {
  doReturn( db ).when( jobEntry ).getNewDatabaseFromMeta();
  doNothing().when( db ).connect( anyString(), anyString() );
  doReturn( true ).when( db ).checkColumnExists( anyString(), anyString(), anyString() );
  doReturn( true ).when( db ).checkTableExists( anyString(), anyString() );
  final Result result = jobEntry.execute( new Result(), 0 );
  assertEquals( "Should be no error", 0, result.getNrErrors() );
  assertTrue( "Result should be true", result.getResult() );
  assertEquals( "Lines written", COLUMNS.length, result.getNrLinesWritten() );
  verify( db, atLeastOnce() ).disconnect();
 }
}

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

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

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

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

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

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

相关文章

微信公众号

最新文章

更多