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

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

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

Database.getConnection介绍

暂无

代码示例

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

  1. void checkClientEncoding() throws Exception {
  2.  Connection connection = data.db.getConnection();
  3.  Statement statement = connection.createStatement();
  4.  try {
  5.   try ( ResultSet rs = statement.executeQuery( "show client_encoding" ) ) {
  6.    if ( !rs.next() || rs.getMetaData().getColumnCount() != 1 ) {
  7.     logBasic( "Cannot detect client_encoding, using system default encoding" );
  8.     return;
  9.    }
  10.    String clientEncodingStr = rs.getString( 1 );
  11.    logBasic( "Detect client_encoding: " + clientEncodingStr );
  12.    clientEncoding = Charset.forName( clientEncodingStr );
  13.   }
  14.  } catch ( SQLException | IllegalArgumentException ex ) {
  15.   logError( "Cannot detect PostgreSQL client_encoding, using system default encoding", ex );
  16.  } finally {
  17.   statement.close();
  18.  }
  19. }

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

  1. void processTruncate() throws Exception {
  2.  Connection connection = data.db.getConnection();
  3.  String loadAction = environmentSubstitute( meta.getLoadAction() );
  4.  if ( loadAction.equalsIgnoreCase( "truncate" ) ) {
  5.   DatabaseMeta dm = meta.getDatabaseMeta();
  6.   String tableName =
  7.    dm.getQuotedSchemaTableCombination( environmentSubstitute( meta.getSchemaName() ),
  8.     environmentSubstitute( meta.getTableName() ) );
  9.   logBasic( "Launching command: " + "TRUNCATE " + tableName );
  10.   Statement statement = connection.createStatement();
  11.   try {
  12.    statement.executeUpdate( "TRUNCATE " + tableName );
  13.   } catch ( Exception ex ) {
  14.    throw new KettleException( "Error while truncating " + tableName, ex );
  15.   } finally {
  16.    statement.close();
  17.   }
  18.  }
  19. }

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

  1. @Before
  2. public void setUp() throws Exception {
  3.  databaseMeta = mock( DatabaseMeta.class );
  4.  doReturn( "" ).when( databaseMeta ).quoteField( anyString() );
  5.  tableOutputMeta = mock( TableOutputMeta.class );
  6.  doReturn( databaseMeta ).when( tableOutputMeta ).getDatabaseMeta();
  7.  stepMeta = mock( StepMeta.class );
  8.  doReturn( "step" ).when( stepMeta ).getName();
  9.  doReturn( mock( StepPartitioningMeta.class ) ).when( stepMeta ).getTargetStepPartitioningMeta();
  10.  doReturn( tableOutputMeta ).when( stepMeta ).getStepMetaInterface();
  11.  db = mock( Database.class );
  12.  doReturn( mock( Connection.class ) ).when( db ).getConnection();
  13.  tableOutputData = mock( TableOutputData.class );
  14.  tableOutputData.db = db;
  15.  tableOutputData.tableName = "sas";
  16.  tableOutputData.preparedStatements = mock( Map.class );
  17.  tableOutputData.commitCounterMap = mock( Map.class );
  18.  TransMeta transMeta = mock( TransMeta.class );
  19.  doReturn( stepMeta ).when( transMeta ).findStep( anyString() );
  20.  tableOutput = new TableOutput( stepMeta, tableOutputData, 1, transMeta, mock( Trans.class ) );
  21.  tableOutput.setData( tableOutputData );
  22.  tableOutput.setMeta( tableOutputMeta );
  23.  tableOutputSpy = spy( tableOutput );
  24.  doReturn( stepMeta ).when( tableOutputSpy ).getStepMeta();
  25.  doReturn( false ).when( tableOutputSpy ).isRowLevel();
  26.  doReturn( false ).when( tableOutputSpy ).isDebug();
  27.  doNothing().when( tableOutputSpy ).logDetailed( anyString() );
  28. }

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

  1. doReturn( mock( Connection.class ) ).when( db ).getConnection();

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

  1. private void do_copy( PGBulkLoaderMeta meta, boolean wait ) throws KettleException {
  2.  data.db = getDatabase( this, meta );
  3.  String copyCmd = getCopyCommand();
  4.  try {
  5.   connect();
  6.   checkClientEncoding();
  7.   processTruncate();
  8.   logBasic( "Launching command: " + copyCmd );
  9.   pgCopyOut = new PGCopyOutputStream( (PGConnection) data.db.getConnection(), copyCmd );
  10.  } catch ( Exception ex ) {
  11.   throw new KettleException( "Error while preparing the COPY " + copyCmd, ex );
  12.  }
  13. }

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

  1. private void finishStep() {
  2.  if ( data.db != null && data.db.getConnection() != null ) {
  3.   try {
  4.    if ( !data.db.getConnection().isClosed() ) {
  5.     for ( String schemaTable : data.preparedStatements.keySet() ) {

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

  1. @Test
  2.  public void keyStream2ProcessRow() throws KettleException {
  3.   InsertUpdate insertUpdateStep =
  4.    new InsertUpdate( mockHelper.stepMeta, mockHelper.stepDataInterface, 0, mockHelper.transMeta, mockHelper.trans );
  5.   insertUpdateStep.setInputRowMeta( Mockito.mock( RowMetaInterface.class ) );
  6.   insertUpdateStep = Mockito.spy( insertUpdateStep );
  8.   InsertUpdateMeta insertUpdateMeta = new InsertUpdateMeta();
  9.   insertUpdateMeta.setKeyStream( new String[] { "test_field" } );
  10.   insertUpdateMeta.setKeyCondition( new String[] { "test_condition" } );
  11.   insertUpdateMeta.setKeyStream2( new String[] {} );
  12.   insertUpdateMeta.setUpdateLookup( new String[] {} );
  13.   insertUpdateMeta.setKeyLookup( new String[] {} );
  14.   insertUpdateMeta.setUpdateBypassed( true );
  15.   insertUpdateMeta.setDatabaseMeta( Mockito.mock( DatabaseMeta.class ) );
  16.   Database database = Mockito.mock( Database.class );
  17.   mockHelper.processRowsStepDataInterface.db = database;
  18.   Mockito.doReturn( Mockito.mock( Connection.class ) ).when( database ).getConnection();
  19.   Mockito.doNothing().when( insertUpdateStep ).lookupValues( Mockito.any(), Mockito.any() );
  20.   Mockito.doNothing().when( insertUpdateStep ).putRow( Mockito.any(), Mockito.any() );
  21.   Mockito.doReturn( new Object[] {} ).when( insertUpdateStep ).getRow();
  22.   insertUpdateStep.first = true;
  24.   insertUpdateMeta.afterInjectionSynchronization();
  25.   //run without a exception
  26.   insertUpdateStep.processRow( insertUpdateMeta, mockHelper.processRowsStepDataInterface );
  28.   Assert.assertEquals( insertUpdateMeta.getKeyStream().length, insertUpdateMeta.getKeyStream2().length );
  29.  }
  30. }

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

  1. logDetailed( "Setting delete preparedStatement to [" + sql + "]" );
  2.  data.prepStatementDelete = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. } catch ( SQLException ex ) {
  4.  throw new KettleDatabaseException( "Unable to prepare statement for SQL statement [" + sql + "]", ex );

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

  1. if ( getConnection().getAutoCommit() != isAutoCommit() ) {
  2.  setAutoCommit( isAutoCommit() );

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

  1. logDetailed( "Setting update preparedStatement to [" + sql + "]" );
  2.  data.prepStatementUpdate = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. } catch ( SQLException ex ) {
  4.  throw new KettleDatabaseException( "Unable to prepare statement for SQL statement [" + sql + "]", ex );

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

  1. logDetailed( "Setting preparedStatement to [" + sql + "]" );
  2.  data.prepStatementLookup = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. } catch ( SQLException ex ) {
  4.  throw new KettleDatabaseException( "Unable to prepare statement for SQL statement [" + sql + "]", ex );

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

  1. logDetailed( "Setting update preparedStatement to [" + sql + "]" );
  2.  data.prepStatementUpdate = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. } catch ( SQLException ex ) {
  4.  throw new KettleDatabaseException( "Unable to prepare statement for SQL statement [" + sql + "]", ex );

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

  1. logDetailed( "Setting preparedStatement to [" + sql + "]" );
  2.  data.prepStatementLookup = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. } catch ( SQLException ex ) {
  4.  throw new KettleDatabaseException( "Unable to prepare statement for SQL statement [" + sql + "]", ex );

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

  1. logDetailed( "SQL with return keys: " + sqlStatement );
  2.  data.prepStatementInsert =
  3.   data.db.getConnection().prepareStatement(
  4.    databaseMeta.stripCR( sqlStatement ), Statement.RETURN_GENERATED_KEYS );
  5. } else {
  6.  logDetailed( "SQL without return keys: " + sqlStatement );
  7.  data.prepStatementInsert =
  8.   data.db.getConnection().prepareStatement( databaseMeta.stripCR( sqlStatement ) );

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

  1. data.db.getConnection().prepareStatement( meta.getDatabaseMeta().stripCR( sql_upd ) );
  2. } catch ( SQLException ex ) {
  3.  throw new KettleDatabaseException( "Unable to prepare dimension punchThrough update statement : "

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

  1. int agentPort = meta.getAgentPort();
  2. Charset charset = meta.getCharset();
  3. Connection conn = db.getConnection();
  4. String tableName =
  5.  meta

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

  1. logDebug( "preparing combi-lookup statement:" + Const.CR + sql );
  2. data.prepStatementLookup = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  3. if ( databaseMeta.supportsSetMaxRows() ) {
  4.  data.prepStatementLookup.setMaxRows( 1 ); // alywas get only 1 line back!

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

  1. logDetailed( "SQL w/ return keys=[" + sql + "]" );
  2.   data.prepStatementInsert =
  3.    data.db.getConnection().prepareStatement(
  4.     databaseMeta.stripCR( sql ), Statement.RETURN_GENERATED_KEYS );
  5.  } else {
  6.   logDetailed( "SQL=[" + sql + "]" );
  7.   data.prepStatementInsert = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  8.  data.prepStatementUpdate = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql_upd ) );
  9. } catch ( SQLException ex ) {
  10.  throw new KettleDatabaseException( "Unable to prepare dimension update :" + Const.CR + sql_upd, ex );

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

  1. data.db.getConnection().prepareStatement( meta.getDatabaseMeta().stripCR( sql ) );
  2. } catch ( SQLException ex ) {
  3.  throw new KettleDatabaseException( "Couldn't prepare statement :" + Const.CR + sql, ex );

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

  1. data.prepStatementLookup = data.db.getConnection().prepareStatement( databaseMeta.stripCR( sql ) );
  2. if ( databaseMeta.supportsSetMaxRows() ) {
  3.  data.prepStatementLookup.setMaxRows( 1 ); // alywas get only 1 line back!

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

Database

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Database类方法

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