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

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

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

Database.insertRow介绍

[英]Insert a row into the database using a prepared statement that has all values set.
[中]使用已设置所有值的准备语句将行插入数据库。

代码示例

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

  1. /**
  2.  * Insert a row into the database using a prepared statement that has all values set.
  3.  *
  4.  * @param ps    The prepared statement
  5.  * @param batch True if you want to use batch inserts (size = commit size)
  6.  * @return true if the rows are safe: if batch of rows was sent to the database OR if a commit was done.
  7.  * @throws KettleDatabaseException
  8.  */
  9. public boolean insertRow( PreparedStatement ps, boolean batch ) throws KettleDatabaseException {
  10.  return insertRow( ps, batch, true );
  11. }

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

  1. public void insertRow( String tableName, RowMetaInterface fields, Object[] data ) throws KettleDatabaseException {
  2.  insertRow( null, tableName, fields, data );
  3. }

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

  1. public void insertRow() throws KettleDatabaseException {
  2.  insertRow( prepStatementInsert );
  3. }

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

  1. public void insertRow( boolean batch ) throws KettleDatabaseException {
  2.  insertRow( prepStatementInsert, batch );
  3. }

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

  1. public void updateRow() throws KettleDatabaseException {
  2.  insertRow( prepStatementUpdate );
  3. }

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

  1. public void insertRow( PreparedStatement ps ) throws KettleDatabaseException {
  2.  insertRow( ps, false );
  3. }

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

  1. public void insertRow( String schemaName, String tableName, RowMetaInterface fields, Object[] data )
  2.  throws KettleDatabaseException {
  3.  prepareInsert( fields, schemaName, tableName );
  4.  setValuesInsert( fields, data );
  5.  insertRow();
  6.  closeInsert();
  7. }

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

  1. public synchronized void insertTableRow( String tablename, RowMetaAndData values ) throws KettleException {
  2.  database.prepareInsert( values.getRowMeta(), tablename );
  3.  database.setValuesInsert( values );
  4.  database.insertRow();
  5.  database.closeInsert();
  6. }

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

  1. private void insertDatabaseAttributes( ObjectId idDatabase, Properties properties ) throws KettleException {
  2.   if ( properties.isEmpty() ) {
  3.    return;
  4.   }
  6.   Database db = repository.connectionDelegate.getDatabase();
  7.   boolean firstAttribute = true;
  8.   Enumeration<Object> keys = properties.keys();
  9.   while ( keys.hasMoreElements() ) {
  10.    String code = (String) keys.nextElement();
  11.    String attribute = (String) properties.get( code );
  13.    RowMetaAndData attributeData = createAttributeRow( idDatabase, code, attribute );
  14.    if ( firstAttribute ) {
  15.     db.prepareInsert( attributeData.getRowMeta(), KettleDatabaseRepository.TABLE_R_DATABASE_ATTRIBUTE );
  16.     firstAttribute = false;
  17.    }
  18.    db.setValuesInsert( attributeData );
  19.    db.insertRow( db.getPrepStatementInsert(), true, false );
  20.   }
  21.   db.executeAndClearBatch( db.getPrepStatementInsert() );
  22.   db.closeInsert();
  23.  }
  24. }

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

  1. public synchronized ObjectId insertJobEntryCopy( ObjectId id_job, ObjectId id_jobentry,
  2.  ObjectId id_jobentry_type, int nr, long gui_location_x, long gui_location_y, boolean gui_draw,
  3.  boolean parallel ) throws KettleException {
  4.  ObjectId id = repository.connectionDelegate.getNextJobEntryCopyID();
  5.  RowMetaAndData table = new RowMetaAndData();
  6.  //CHECKSTYLE:LineLength:OFF
  7.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_ID_JOBENTRY_COPY ), id );
  8.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_ID_JOBENTRY ), id_jobentry );
  9.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_ID_JOB ), id_job );
  10.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_ID_JOBENTRY_TYPE ), id_jobentry_type );
  11.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_NR ), new Long( nr ) );
  12.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_GUI_LOCATION_X ), new Long( gui_location_x ) );
  13.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_GUI_LOCATION_Y ), new Long( gui_location_y ) );
  14.  table.addValue( new ValueMetaBoolean( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_GUI_DRAW ), Boolean.valueOf( gui_draw ) );
  15.  table.addValue( new ValueMetaBoolean( KettleDatabaseRepository.FIELD_JOBENTRY_COPY_PARALLEL ), Boolean.valueOf( parallel ) );
  16.  repository.connectionDelegate.getDatabase().prepareInsert( table.getRowMeta(), KettleDatabaseRepository.TABLE_R_JOBENTRY_COPY );
  17.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  18.  repository.connectionDelegate.getDatabase().insertRow();
  19.  repository.connectionDelegate.getDatabase().closeInsert();
  20.  return id;
  21. }

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

  1. private synchronized void deleteValues( RowMetaInterface rowMeta, Object[] row ) throws KettleException {
  2.  // OK, now do the lookup.
  3.  // We need the lookupvalues for that.
  4.  Object[] deleteRow = new Object[data.deleteParameterRowMeta.size()];
  5.  int deleteIndex = 0;
  6.  for ( int i = 0; i < meta.getKeyStream().length; i++ ) {
  7.   if ( data.keynrs[i] >= 0 ) {
  8.    deleteRow[deleteIndex] = row[data.keynrs[i]];
  9.    deleteIndex++;
  10.   }
  11.   if ( data.keynrs2[i] >= 0 ) {
  12.    deleteRow[deleteIndex] = row[data.keynrs2[i]];
  13.    deleteIndex++;
  14.   }
  15.  }
  16.  data.db.setValues( data.deleteParameterRowMeta, deleteRow, data.prepStatementDelete );
  17.  if ( log.isDebug() ) {
  18.   logDebug( BaseMessages.getString( PKG, "Delete.Log.SetValuesForDelete", data.deleteParameterRowMeta
  19.    .getString( deleteRow ), rowMeta.getString( row ) ) );
  20.  }
  21.  data.db.insertRow( data.prepStatementDelete );
  22.  incrementLinesUpdated();
  23. }

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

  1. public synchronized ObjectId insertJobEntryAttribute( ObjectId id_job, ObjectId id_jobentry, long nr,
  2.                            String code, double value_num, String value_str )
  3.  throws KettleException {
  4.  ObjectId id = getNextJobEntryAttributeID();
  5.  RowMetaAndData table = new RowMetaAndData();
  6.  //CHECKSTYLE:LineLength:OFF
  7.  table
  8.   .addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY_ATTRIBUTE ), id );
  9.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOB ), id_job );
  10.  table
  11.   .addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY ), id_jobentry );
  12.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_NR ), new Long( nr ) );
  13.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_CODE ), code );
  14.  table.addValue( new ValueMetaNumber( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_VALUE_NUM ),
  15.   new Double( value_num ) );
  16.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_JOBENTRY_ATTRIBUTE_VALUE_STR ), value_str );
  17.  database.prepareInsert( table.getRowMeta(), KettleDatabaseRepository.TABLE_R_JOBENTRY_ATTRIBUTE );
  18.  database.setValuesInsert( table );
  19.  database.insertRow();
  20.  database.closeInsert();
  21.  return id;
  22. }

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

  1. public synchronized ObjectId insertStep( ObjectId id_transformation, String name, String description,
  2.  String steptype, boolean distribute, long copies, long gui_location_x, long gui_location_y,
  3.  boolean gui_draw, String copiesString ) throws KettleException {
  4.  ObjectId id = repository.connectionDelegate.getNextStepID();
  5.  ObjectId id_step_type = getStepTypeID( steptype );
  6.  RowMetaAndData table = new RowMetaAndData();
  7.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ID_STEP ), id );
  8.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ID_TRANSFORMATION ), id_transformation );
  9.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_STEP_NAME ), name );
  10.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_STEP_DESCRIPTION ), description );
  11.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_ID_STEP_TYPE ), id_step_type );
  12.  table.addValue( new ValueMetaBoolean( KettleDatabaseRepository.FIELD_STEP_DISTRIBUTE ), Boolean.valueOf( distribute ) );
  13.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_COPIES ), new Long( copies ) );
  14.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_GUI_LOCATION_X ), new Long( gui_location_x ) );
  15.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_STEP_GUI_LOCATION_Y ), new Long( gui_location_y ) );
  16.  table.addValue( new ValueMetaBoolean( KettleDatabaseRepository.FIELD_STEP_GUI_DRAW ), Boolean.valueOf( gui_draw ) );
  17.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_STEP_COPIES_STRING ), copiesString );
  18.  repository.connectionDelegate.getDatabase().prepareInsert( table.getRowMeta(), KettleDatabaseRepository.TABLE_R_STEP );
  19.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  20.  repository.connectionDelegate.getDatabase().insertRow();
  21.  repository.connectionDelegate.getDatabase().closeInsert();
  22.  return id;
  23. }

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

  1. private synchronized ObjectId insertTransHop( ObjectId id_transformation, ObjectId id_step_from,
  2.  ObjectId id_step_to, boolean enabled ) throws KettleException {
  3.  ObjectId id = repository.connectionDelegate.getNextTransHopID();
  4.  RowMetaAndData table = new RowMetaAndData();
  5.  table.addValue( new ValueMetaInteger(
  6.   KettleDatabaseRepository.FIELD_TRANS_HOP_ID_TRANS_HOP ), id );
  7.  table
  8.   .addValue(
  9.    new ValueMetaInteger(
  10.     KettleDatabaseRepository.FIELD_TRANS_HOP_ID_TRANSFORMATION ),
  11.    id_transformation );
  12.  table.addValue( new ValueMetaInteger(
  13.   KettleDatabaseRepository.FIELD_TRANS_HOP_ID_STEP_FROM ), id_step_from );
  14.  table.addValue( new ValueMetaInteger(
  15.   KettleDatabaseRepository.FIELD_TRANS_HOP_ID_STEP_TO ), id_step_to );
  16.  table.addValue( new ValueMetaBoolean(
  17.   KettleDatabaseRepository.FIELD_TRANS_HOP_ENABLED ), Boolean
  18.   .valueOf( enabled ) );
  19.  repository.connectionDelegate.getDatabase().prepareInsert(
  20.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_TRANS_HOP );
  21.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  22.  repository.connectionDelegate.getDatabase().insertRow();
  23.  repository.connectionDelegate.getDatabase().closeInsert();
  24.  return id;
  25. }

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

  1. public synchronized ObjectId insertPartition( ObjectId id_partition_schema, String partition_id ) throws KettleException {
  2.  ObjectId id = repository.connectionDelegate.getNextPartitionID();
  3.  RowMetaAndData table = new RowMetaAndData();
  4.  table.addValue( new ValueMetaInteger(
  5.   KettleDatabaseRepository.FIELD_PARTITION_ID_PARTITION ), id );
  6.  table.addValue(
  7.   new ValueMetaInteger(
  8.    KettleDatabaseRepository.FIELD_PARTITION_ID_PARTITION_SCHEMA ),
  9.   id_partition_schema );
  10.  table.addValue( new ValueMetaString(
  11.   KettleDatabaseRepository.FIELD_PARTITION_PARTITION_ID ), partition_id );
  12.  repository.connectionDelegate.getDatabase().prepareInsert(
  13.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_PARTITION );
  14.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  15.  repository.connectionDelegate.getDatabase().insertRow();
  16.  repository.connectionDelegate.getDatabase().closeInsert();
  17.  return id;
  18. }

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

  1. private synchronized ObjectId insertDirectory( ObjectId id_directory_parent, RepositoryDirectoryInterface dir ) throws KettleException {
  2.  ObjectId id = repository.connectionDelegate.getNextDirectoryID();
  3.  String tablename = KettleDatabaseRepository.TABLE_R_DIRECTORY;
  4.  RowMetaAndData table = new RowMetaAndData();
  5.  table.addValue( new ValueMetaInteger(
  6.   KettleDatabaseRepository.FIELD_DIRECTORY_ID_DIRECTORY ), id );
  7.  table.addValue(
  8.   new ValueMetaInteger(
  9.    KettleDatabaseRepository.FIELD_DIRECTORY_ID_DIRECTORY_PARENT ),
  10.   id_directory_parent );
  11.  table.addValue( new ValueMetaString(
  12.   KettleDatabaseRepository.FIELD_DIRECTORY_DIRECTORY_NAME ), dir.getName() );
  13.  repository.connectionDelegate.getDatabase().prepareInsert( table.getRowMeta(), tablename );
  14.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  15.  repository.connectionDelegate.getDatabase().insertRow();
  16.  repository.connectionDelegate.getDatabase().closeInsert();
  17.  return id;
  18. }

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

  1. public ObjectId insertNamespace( String namespace ) throws KettleException {
  2.  ObjectId idNamespace =
  3.   repository.connectionDelegate.getNextID(
  4.    quoteTable( KettleDatabaseRepository.TABLE_R_NAMESPACE ),
  5.    quote( KettleDatabaseRepository.FIELD_NAMESPACE_ID_NAMESPACE ) );
  6.  RowMetaAndData table = new RowMetaAndData();
  7.  table.addValue( new ValueMetaInteger(
  8.   KettleDatabaseRepository.FIELD_NAMESPACE_ID_NAMESPACE ), idNamespace );
  9.  table.addValue(
  10.   new ValueMetaString( KettleDatabaseRepository.FIELD_NAMESPACE_NAME ), namespace );
  11.  repository.connectionDelegate.getDatabase().prepareInsert(
  12.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_NAMESPACE );
  13.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  14.  repository.connectionDelegate.getDatabase().insertRow();
  15.  repository.connectionDelegate.getDatabase().closeInsert();
  16.  if ( log.isDebug() ) {
  17.   log.logDebug( "Saved namespace [" + namespace + "]" );
  18.  }
  19.  return idNamespace;
  20. }

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

  1. private synchronized ObjectId insertDependency( ObjectId id_transformation, ObjectId id_database,
  2.  String tablename, String fieldname ) throws KettleException {
  3.  ObjectId id = repository.connectionDelegate.getNextDepencencyID();
  4.  RowMetaAndData table = new RowMetaAndData();
  5.  table.addValue( new ValueMetaInteger(
  6.   KettleDatabaseRepository.FIELD_DEPENDENCY_ID_DEPENDENCY ), id );
  7.  table.addValue(
  8.   new ValueMetaInteger(
  9.    KettleDatabaseRepository.FIELD_DEPENDENCY_ID_TRANSFORMATION ),
  10.   id_transformation );
  11.  table.addValue( new ValueMetaInteger(
  12.   KettleDatabaseRepository.FIELD_DEPENDENCY_ID_DATABASE ), id_database );
  13.  table.addValue( new ValueMetaString(
  14.   KettleDatabaseRepository.FIELD_DEPENDENCY_TABLE_NAME ), tablename );
  15.  table.addValue( new ValueMetaString(
  16.   KettleDatabaseRepository.FIELD_DEPENDENCY_FIELD_NAME ), fieldname );
  17.  repository.connectionDelegate.getDatabase().prepareInsert(
  18.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_DEPENDENCY );
  19.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  20.  repository.connectionDelegate.getDatabase().insertRow();
  21.  repository.connectionDelegate.getDatabase().closeInsert();
  22.  return id;
  23. }

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

  1. public synchronized ObjectId insertPartitionSchema( PartitionSchema partitionSchema ) throws KettleException {
  2.  if ( getPartitionSchemaID( partitionSchema.getName() ) != null ) {
  3.   // This partition schema name is already in use. Throw an exception.
  4.   throw new KettleObjectExistsException( "Failed to create object in repository. Object ["
  5.    + partitionSchema.getName() + "] already exists." );
  6.  }
  7.  ObjectId id = repository.connectionDelegate.getNextPartitionSchemaID();
  8.  RowMetaAndData table = new RowMetaAndData();
  9.  table.addValue( new ValueMetaInteger( KettleDatabaseRepository.FIELD_PARTITION_SCHEMA_ID_PARTITION_SCHEMA ), id );
  10.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_PARTITION_SCHEMA_NAME ),
  11.   partitionSchema.getName() );
  12.  table.addValue( new ValueMetaBoolean( KettleDatabaseRepository.FIELD_PARTITION_SCHEMA_DYNAMIC_DEFINITION ),
  13.   partitionSchema.isDynamicallyDefined() );
  14.  table.addValue( new ValueMetaString( KettleDatabaseRepository.FIELD_PARTITION_SCHEMA_PARTITIONS_PER_SLAVE ),
  15.   partitionSchema.getNumberOfPartitionsPerSlave() );
  16.  repository.connectionDelegate.getDatabase().prepareInsert(
  17.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_PARTITION_SCHEMA );
  18.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  19.  repository.connectionDelegate.getDatabase().insertRow();
  20.  repository.connectionDelegate.getDatabase().closeInsert();
  21.  return id;
  22. }

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

  1. public ObjectId insertElementType( KDBRMetaStoreElementType type ) throws KettleException {
  2.  ObjectId idType =
  3.   repository.connectionDelegate.getNextID(
  4.    quoteTable( KettleDatabaseRepository.TABLE_R_ELEMENT_TYPE ),
  5.    quote( KettleDatabaseRepository.FIELD_ELEMENT_TYPE_ID_ELEMENT_TYPE ) );
  6.  RowMetaAndData table = new RowMetaAndData();
  7.  table.addValue( new ValueMetaInteger(
  8.   KettleDatabaseRepository.FIELD_ELEMENT_TYPE_ID_ELEMENT_TYPE ), idType );
  9.  table.addValue( new ValueMetaInteger(
  10.   KettleDatabaseRepository.FIELD_ELEMENT_TYPE_ID_NAMESPACE ), type
  11.   .getNamespaceId() );
  12.  table.addValue( new ValueMetaString(
  13.   KettleDatabaseRepository.FIELD_ELEMENT_TYPE_NAME ), type.getName() );
  14.  table.addValue( new ValueMetaString(
  15.   KettleDatabaseRepository.FIELD_ELEMENT_TYPE_DESCRIPTION ), type
  16.   .getDescription() );
  17.  repository.connectionDelegate.getDatabase().prepareInsert(
  18.   table.getRowMeta(), KettleDatabaseRepository.TABLE_R_ELEMENT_TYPE );
  19.  repository.connectionDelegate.getDatabase().setValuesInsert( table );
  20.  repository.connectionDelegate.getDatabase().insertRow();
  21.  repository.connectionDelegate.getDatabase().closeInsert();
  22.  type.setId( new LongObjectId( idType ) );
  23.  if ( log.isDebug() ) {
  24.   log.logDebug( "Saved element type [" + type.getName() + "]" );
  25.  }
  26.  return idType;
  27. }

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

Database

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Database类方法

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