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

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

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

Database.<init>介绍

[英]Construct a new Database Connection
[中]构造一个新的数据库连接

代码示例

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

  1. protected Database getDatabase() {
  2.  // Added for test purposes
  3.  return new Database( loggingObject, databaseMeta );
  4. }

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

  1. protected Database createDataBase( DatabaseMeta databaseMeta ) {
  2.  return new Database( this, databaseMeta );
  3. }

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

  1. Database getDatabase( DatabaseMeta meta ) {
  2.  return new Database( this, meta );
  3. }

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

  1. Database createDatabaseObject() {
  2.  return new Database( loggingObject, databaseMeta );
  3. }

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

  1. protected Database createDataBase( DatabaseMeta meta ) {
  2.  return new Database( this, meta );
  3. }

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

  1. Database getNewDatabaseFromMeta() {
  2.  return new Database( this, connection );
  3. }

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

  1. Database createDatabaseObject() {
  2.  return new Database( loggingObject, databaseMeta );
  3. }

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

  1. public KettleDatabaseRepositoryConnectionDelegate( KettleDatabaseRepository repository, DatabaseMeta databaseMeta ) {
  2.  super( repository );
  3.  this.databaseMeta = databaseMeta;
  4.  this.database = new Database( loggingObject, databaseMeta );
  5.  sqlMap = new ConcurrentHashMap<>();
  6.  useBatchProcessing = true; // defaults to true;
  7.  psStepAttributesLookup = null;
  8.  psStepAttributesInsert = null;
  9.  psTransAttributesLookup = null;
  10.  pstmt_entry_attributes = null;
  11.  this.majorVersion = REQUIRED_MAJOR_VERSION;
  12.  this.minorVersion = REQUIRED_MINOR_VERSION;
  13. }

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

  1. public void run( IProgressMonitor monitor ) throws InvocationTargetException, InterruptedException {
  2.   db = new Database( Spoon.loggingObject, dbMeta );
  3.   try {
  4.    db.connect();
  5.    result = db.getQueryFields( sql, false );
  6.    if ( monitor.isCanceled() ) {
  7.     throw new InvocationTargetException( new Exception( "This operation was cancelled!" ) );
  8.    }
  9.   } catch ( Exception e ) {
  10.    throw new InvocationTargetException( e, "Problem encountered determining query fields: " + e.toString() );
  11.   } finally {
  12.    db.disconnect();
  13.   }
  14.  }
  15. };

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

  1. private RowMetaInterface getTableFields( LoggingObjectInterface parentLoggingObject ) throws KettleDatabaseException {
  2.  Database database = new Database( parentLoggingObject, databaseMeta );
  3.  try {
  4.   database.connect();
  5.   return database.getTableFields( schemaTable );
  6.  } finally {
  7.   database.disconnect();
  8.  }
  9. }

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

  1. public void run( IProgressMonitor monitor ) throws InvocationTargetException, InterruptedException {
  2.   db = new Database( Spoon.loggingObject, dbMeta );
  3.   try {
  4.    db.connect();
  5.    String sql = dbMeta.getDatabaseInterface().getSelectCountStatement( tableName );
  6.    RowMetaAndData row = db.getOneRow( sql );
  7.    size = row.getRowMeta().getInteger( row.getData(), 0 );
  8.    if ( monitor.isCanceled() ) {
  9.     throw new InvocationTargetException( new Exception( "This operation was cancelled!" ) );
  10.    }
  11.   } catch ( KettleException e ) {
  12.    throw new InvocationTargetException( e, "Couldn't get a result because of an error :" + e.toString() );
  13.   } finally {
  14.    db.disconnect();
  15.   }
  16.  }
  17. };

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

  1. protected void checkConnection() throws KettleDatabaseException {
  2.  // check connection
  3.  // connect and disconnect
  4.  Database dbchecked = null;
  5.  try {
  6.   dbchecked = new Database( this, connection );
  7.   dbchecked.shareVariablesWith( this );
  8.   dbchecked.connect( parentJob.getTransactionId(), null );
  9.  } finally {
  10.   if ( dbchecked != null ) {
  11.    dbchecked.disconnect();
  12.   }
  13.  }
  14. }

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

  1. @VisibleForTesting
  2. Database getDatabase( LoggingObjectInterface parentObject, PGBulkLoaderMeta pgBulkLoaderMeta ) {
  3.  DatabaseMeta dbMeta = pgBulkLoaderMeta.getDatabaseMeta();
  4.  // If dbNameOverride is present, clone the origin db meta and override the DB name
  5.  String dbNameOverride = environmentSubstitute( pgBulkLoaderMeta.getDbNameOverride() );
  6.  if ( !Utils.isEmpty( dbNameOverride ) ) {
  7.   dbMeta = (DatabaseMeta) pgBulkLoaderMeta.getDatabaseMeta().clone();
  8.   dbMeta.setDBName( dbNameOverride.trim() );
  9.   logDebug( "DB name overridden to the value: " + dbNameOverride );
  10.  }
  11.  return new Database( parentObject, dbMeta );
  12. }

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

  1. /**
  2.  * @return the database.
  3.  * @throws KettleException
  4.  *           if an error occurs.
  5.  */
  6. public Database connectToDatabase() throws KettleException {
  7.  if ( this.getDbMeta() != null ) {
  8.   Database db = new Database( loggingObject, this.getDbMeta() );
  9.   db.connect();
  10.   return db;
  11.  }
  12.  throw new KettleException( MESSAGES.getString( "TeraFastMeta.Exception.ConnectionNotDefined" ) );
  13. }

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

  1. private Database createVirtualDb( DatabaseMeta meta ) throws Exception {
  2.  ResultSet rs = mock( ResultSet.class );
  3.  when( rs.getMetaData() ).thenReturn( mock( ResultSetMetaData.class ) );
  4.  PreparedStatement ps = mock( PreparedStatement.class );
  5.  when( ps.executeQuery() ).thenReturn( rs );
  6.  Connection connection = mock( Connection.class );
  7.  when( connection.prepareStatement( anyString() ) ).thenReturn( ps );
  8.  Database db = new Database( mock( LoggingObjectInterface.class ), meta );
  9.  db.setConnection( connection );
  10.  db = spy( db );
  11.  doNothing().when( db ).normalConnect( anyString() );
  12.  ValueMetaInterface binary = new ValueMetaString( BINARY_FIELD );
  13.  binary.setStorageType( ValueMetaInterface.STORAGE_TYPE_BINARY_STRING );
  14.  ValueMetaInterface id = new ValueMetaInteger( ID_FIELD );
  15.  RowMetaInterface metaByQuerying = new RowMeta();
  16.  metaByQuerying.addValueMeta( binary );
  17.  metaByQuerying.addValueMeta( id );
  18.  doReturn( metaByQuerying ).when( db ).getTableFields( anyString() );
  19.  doReturn( metaByQuerying ).when( db ).getTableFieldsMeta( anyString(), anyString() );
  20.  return db;
  21. }

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

  1. public void run( IProgressMonitor monitor ) throws InvocationTargetException, InterruptedException {
  2.   db = new Database( Spoon.loggingObject, dbMeta );
  3.   try {
  4.    db.connect();
  5.    if ( limit > 0 ) {
  6.     db.setQueryLimit( limit );
  7.    }
  8.    rows = db.getFirstRows( tableName, limit, new ProgressMonitorAdapter( monitor ) );
  9.    rowMeta = db.getReturnRowMeta();
  10.   } catch ( KettleException e ) {
  11.    throw new InvocationTargetException( e, "Couldn't find any rows because of an error :" + e.toString() );
  12.   } finally {
  13.    db.disconnect();
  14.   }
  15.  }
  16. };

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

  1. public boolean getInputData() {
  2.  // Get some data...
  3.  RipDatabaseWizardPage1 page1 = (RipDatabaseWizardPage1) getPreviousPage();
  4.  Database sourceDb = new Database( RipDatabaseWizard.loggingObject, page1.getSourceDatabase() );
  5.  try {
  6.   sourceDb.connect();
  7.   input = sourceDb.getTablenames( false ); // Don't include the schema since it can cause invalid syntax
  8.  } catch ( KettleDatabaseException dbe ) {
  9.   new ErrorDialog( shell, "Error getting tables", "Error obtaining table list from database!", dbe );
  10.   input = null;
  11.   return false;
  12.  } finally {
  13.   sourceDb.disconnect();
  14.  }
  15.  return true;
  16. }

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

  1. public boolean getInputData() {
  2.  // Get some data...
  3.  CopyTableWizardPage1 page1 = (CopyTableWizardPage1) getPreviousPage();
  4.  Database sourceDb = new Database( CopyTableWizard.loggingObject, page1.getSourceDatabase() );
  5.  try {
  6.   sourceDb.connect();
  7.   input = sourceDb.getTablenames();
  8.  } catch ( KettleDatabaseException dbe ) {
  9.   new ErrorDialog(
  10.    shell, BaseMessages.getString( PKG, "CopyTableWizardPage2.ErrorGettingTables.DialogTitle" ),
  11.    BaseMessages.getString( PKG, "CopyTableWizardPage2.ErrorGettingTables.DialogMessage" ), dbe );
  12.   input = null;
  13.   return false;
  14.  } finally {
  15.   sourceDb.disconnect();
  16.  }
  17.  return true;
  18. }

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

  1. @Before
  2. public void setUp() {
  3.  Job parentJob = new Job( null, new JobMeta() );
  4.  jobEntry = spy( new JobEntryColumnsExist( "" ) );
  5.  parentJob.getJobMeta().addJobEntry( new JobEntryCopy( jobEntry ) );
  6.  parentJob.setStopped( false );
  7.  jobEntry.setParentJob( parentJob );
  8.  parentJob.setLogLevel( LogLevel.NOTHING );
  9.  DatabaseMeta dbMeta = mock( DatabaseMeta.class );
  10.  jobEntry.setDatabase( dbMeta );
  11.  db = spy( new Database( jobEntry, dbMeta ) );
  12.  jobEntry.setParentJob( parentJob );
  13.  jobEntry.setTablename( TABLENAME );
  14.  jobEntry.setArguments( COLUMNS );
  15.  jobEntry.setSchemaname( SCHEMANAME );
  16. }

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

  1. /**
  2.  * Execute fastload.
  3.  *
  4.  * @throws KettleException
  5.  *           ...
  6.  */
  7. public void execute() throws KettleException {
  8.  if ( this.meta.getTruncateTable().getValue() ) {
  9.   Database db = new Database( this, this.meta.getDbMeta() );
  10.   db.connect();
  11.   db.truncateTable( this.meta.getTargetTable().getValue() );
  12.   db.commit();
  13.   db.disconnect();
  14.  }
  15.  startFastLoad();
  16.  if ( this.meta.getUseControlFile().getValue() ) {
  17.   this.invokeLoadingControlFile();
  18.  } else {
  19.   this.invokeLoadingCommand();
  20.  }
  21. }

内容来源于网络，如有侵权，请联系作者删除！

Database

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Database类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com