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

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

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

Database.normalConnect介绍

[英]Open the database connection. The algorithm is:

  1. If databaseMeta.getAccessType() returns DatabaseMeta.TYPE_ACCESS_JNDI, then the connection's datasource is looked up in JNDI
  2. If databaseMeta.isUsingConnectionPool(), then the connection's datasource is looked up in the pool
  3. otherwise, the connection is established via java.sql.DriverManager
    [中]打开数据库连接。算法是:
    1.如果databaseMeta.getAccessType()返回DatabaseMeta.TYPE_ACCESS_JNDI,则在JNDI中查找连接的数据源
    1.如果databaseMeta.isUsingConnectionPool(),则在池中查找连接的数据源
    1.否则,通过java建立连接。sql。驱动管理器

代码示例

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

  1. private synchronized void shareConnectionWith( String partitionId, Database anotherDb )
  2. throws KettleDatabaseException {
  3. // inside synchronized block we can increment 'opened' directly
  4. this.opened++;
  5. if ( this.connection == null ) {
  6. normalConnect( partitionId );
  7. this.copy = this.opened;
  8. // If we have a connection group or transaction ID, disable auto commit!
  9. //
  10. setAutoCommit( false );
  11. }
  12. anotherDb.connection = this.connection;
  13. anotherDb.copy = this.opened;
  14. }

代码示例来源: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. } else {
  2. normalConnect( partitionId );

相关文章