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

Database.getDatabaseMeta介绍

暂无

代码示例

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

private String[] getQuotedSchemaTablenames( String[] tables ) {
 String[] quoted = new String[ tables.length ];
 for ( int i = 0; i < quoted.length; i++ ) {
  quoted[ i ] = database.getDatabaseMeta().getQuotedSchemaTableCombination( null, tables[ i ] );
 }
 return quoted;
}

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

public boolean checkIndexExists( Database database, String schemaName, String tableName, String[] idx_fields ) throws KettleDatabaseException {
 String tablename = database.getDatabaseMeta().getQuotedSchemaTableCombination( schemaName, tableName );

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

public static String createEntryKey( String connectionGroup, String partitionID, Database database ) {
 StringBuilder key = new StringBuilder( connectionGroup );
 key.append( ':' ).append( database.getDatabaseMeta().getName() );
 if ( !Utils.isEmpty( partitionID ) ) {
  key.append( ':' ).append( partitionID );
 }
 return key.toString();
}

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

public boolean checkIndexExists( Database database, String schemaName, String tableName, String[] idx_fields ) throws KettleDatabaseException {
 String tablename = database.getDatabaseMeta().getQuotedSchemaTableCombination( schemaName, tableName );

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

/**
 * @param database
 *          The database to set.
 */
public void setDatabase( Database database ) {
 connectionDelegate.setDatabase( database );
 connectionDelegate.setDatabaseMeta( database.getDatabaseMeta() );
}

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

/**
 * Returns max VARCHAR length depending on db interface
 */
protected int getRepoStringLength() {
 return database.getDatabaseMeta().getDatabaseInterface().getMaxVARCHARLength() - 1 > 0 ? database.getDatabaseMeta()
   .getDatabaseInterface().getMaxVARCHARLength() - 1 : KettleDatabaseRepository.REP_ORACLE_STRING_LENGTH;
}

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

public synchronized void unlockRepository() throws KettleException {
 if ( database.getDatabaseMeta().needsToLockAllTables() ) {
  database.unlockTables( KettleDatabaseRepository.repositoryTableNames );
 } else {
  database.unlockTables( new String[] { KettleDatabaseRepository.TABLE_R_REPOSITORY_LOG, } );
 }
}

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

public synchronized void lockRepository() throws KettleException {
 if ( database.getDatabaseMeta().needsToLockAllTables() ) {
  database.lockTables( getQuotedSchemaTablenames( KettleDatabaseRepository.repositoryTableNames ) );
 } else {
  database
   .lockTables( getQuotedSchemaTablenames( new String[] { KettleDatabaseRepository.TABLE_R_REPOSITORY_LOG, } ) );
 }
}

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

public boolean checkIndexExists( Database database, String schemaName, String tableName, String[] idx_fields ) throws KettleDatabaseException {
 String tablename = database.getDatabaseMeta().getQuotedSchemaTableCombination( schemaName, tableName );

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

@Test
public void testDBNameNOTOverridden_IfDbNameOverrideNull() throws Exception {
 // Db Name Override is null
 PGBulkLoaderMeta pgBulkLoaderMock = getPgBulkLoaderMock( null );
 Database database = pgBulkLoader.getDatabase( pgBulkLoader, pgBulkLoaderMock );
 assertNotNull( database );
 // Verify DB name is NOT overridden
 assertEquals( CONNECTION_DB_NAME, database.getDatabaseMeta().getDatabaseName() );
 // Check additionally other connection information
 assertEquals( CONNECTION_NAME, database.getDatabaseMeta().getName() );
 assertEquals( CONNECTION_DB_HOST, database.getDatabaseMeta().getHostname() );
 assertEquals( CONNECTION_DB_PORT, database.getDatabaseMeta().getDatabasePortNumberString() );
 assertEquals( CONNECTION_DB_USERNAME, database.getDatabaseMeta().getUsername() );
 assertEquals( CONNECTION_DB_PASSWORD, database.getDatabaseMeta().getPassword() );
}

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

@Test
public void testDBNameOverridden_IfDbNameOverrideSetUp() throws Exception {
 // Db Name Override is set up
 PGBulkLoaderMeta pgBulkLoaderMock = getPgBulkLoaderMock( DB_NAME_OVVERRIDE );
 Database database = pgBulkLoader.getDatabase( pgBulkLoader, pgBulkLoaderMock );
 assertNotNull( database );
 // Verify DB name is overridden
 assertEquals( DB_NAME_OVVERRIDE, database.getDatabaseMeta().getDatabaseName() );
 // Check additionally other connection information
 assertEquals( CONNECTION_NAME, database.getDatabaseMeta().getName() );
 assertEquals( CONNECTION_DB_HOST, database.getDatabaseMeta().getHostname() );
 assertEquals( CONNECTION_DB_PORT, database.getDatabaseMeta().getDatabasePortNumberString() );
 assertEquals( CONNECTION_DB_USERNAME, database.getDatabaseMeta().getUsername() );
 assertEquals( CONNECTION_DB_PASSWORD, database.getDatabaseMeta().getPassword() );
}

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

@Test
public void testDBNameNOTOverridden_IfDbNameOverrideEmpty() throws Exception {
 // Db Name Override is empty
 PGBulkLoaderMeta pgBulkLoaderMock = getPgBulkLoaderMock( DB_NAME_EMPTY );
 Database database = pgBulkLoader.getDatabase( pgBulkLoader, pgBulkLoaderMock );
 assertNotNull( database );
 // Verify DB name is NOT overridden
 assertEquals( CONNECTION_DB_NAME, database.getDatabaseMeta().getDatabaseName() );
 // Check additionally other connection information
 assertEquals( CONNECTION_NAME, database.getDatabaseMeta().getName() );
 assertEquals( CONNECTION_DB_HOST, database.getDatabaseMeta().getHostname() );
 assertEquals( CONNECTION_DB_PORT, database.getDatabaseMeta().getDatabasePortNumberString() );
 assertEquals( CONNECTION_DB_USERNAME, database.getDatabaseMeta().getUsername() );
 assertEquals( CONNECTION_DB_PASSWORD, database.getDatabaseMeta().getPassword() );
}

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

when( db.getDatabaseMeta() ).thenReturn( meta );

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

if ( !Utils.isEmpty( realSchemaName ) ) {
 countStatement =
  selectCount + db.getDatabaseMeta().getQuotedSchemaTableCombination( realSchemaName, realTableName );
} else {
 countStatement = selectCount + db.getDatabaseMeta().quoteField( realTableName );

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

public boolean checkIndexExists( Database database, String schemaName, String tableName, String[] idx_fields ) throws KettleDatabaseException {
 String tablename = database.getDatabaseMeta().getQuotedSchemaTableCombination( schemaName, tableName );

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

if ( !( db.getDatabaseMeta().getDatabaseInterface() instanceof MSSQLServerDatabaseMeta ) ) {
 logError( BaseMessages.getString( PKG, "JobMssqlBulkLoad.Error.DbNotMSSQL", connection
  .getDatabaseName() ) );

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

countSQLStatement =
  selectCount
   + db.getDatabaseMeta().getQuotedSchemaTableCombination( realSchemaname, realTablename );
} else {
 countSQLStatement = selectCount + db.getDatabaseMeta().quoteField( realTablename );

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

data.tablename = data.db.getDatabaseMeta().getQuotedSchemaTableCombination( data.schemaname, data.tablename );
 } else {
  data.tablename = data.db.getDatabaseMeta().quoteField( data.tablename );
 data.tablename = getInputRowMeta().getString( r, data.indexOfTablename );
 if ( !Utils.isEmpty( data.schemaname ) ) {
  data.tablename = data.db.getDatabaseMeta().getQuotedSchemaTableCombination( data.schemaname, data.tablename );
 } else {
  data.tablename = data.db.getDatabaseMeta().quoteField( data.tablename );
columnname = data.db.getDatabaseMeta().quoteField( columnname );

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

data.db.getDatabaseMeta().getQuotedSchemaTableCombination( data.realSchemaName, data.realTableName );

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

schemaTable = data.db.getDatabaseMeta().getQuotedSchemaTableCombination( schemaName, tableName );