java.sql.ResultSet.insertRow()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(148)

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

ResultSet.insertRow介绍

[英]Insert the insert row into the ResultSet and into the underlying database. The cursor must be set to the Insert Row before this method is invoked.
[中]将插入行插入结果集和基础数据库。在调用此方法之前,必须将光标设置为插入行。

代码示例

代码示例来源:origin: querydsl/querydsl

@Override
public void insertRow() throws SQLException {
  rs.insertRow();
}

代码示例来源:origin: codingapi/tx-lcn

@Override
public void insertRow() throws SQLException {
 delegate.insertRow();
}

代码示例来源:origin: alibaba/druid

@Override
public void insertRow() throws SQLException {
  try {
    rs.insertRow();
  } catch (Throwable t) {
    throw checkException(t);
  }
}

代码示例来源:origin: apache/ignite

@Override public void run() throws Exception {
    rs.insertRow();
  }
});

代码示例来源:origin: com.zaxxer/HikariCP

/** {@inheritDoc} */
@Override
public void insertRow() throws SQLException
{
 connection.markCommitStateDirty();
 delegate.insertRow();
}

代码示例来源:origin: alibaba/druid

@Override
public void resultSet_insertRow(ResultSetProxy resultSet) throws SQLException {
  if (this.pos < filterSize) {
    nextFilter().resultSet_insertRow(this, resultSet);
    return;
  }
  resultSet.getResultSetRaw().insertRow();
}

代码示例来源:origin: apache/groovy

/**
 * Adds a new row to the result set
 *
 * @param values a map containing the mappings for column names and values
 * @throws java.sql.SQLException if something goes wrong
 * @see ResultSet#insertRow()
 * @see ResultSet#updateObject(java.lang.String, java.lang.Object)
 * @see ResultSet#moveToInsertRow()
 */
public void add(Map values) throws SQLException {
  getResultSet().moveToInsertRow();
  for (Iterator iter = values.entrySet().iterator(); iter.hasNext();) {
    Map.Entry entry = (Map.Entry) iter.next();
    getResultSet().updateObject(entry.getKey().toString(), entry.getValue());
  }
  getResultSet().insertRow();
}

代码示例来源:origin: com.h2database/h2

rs.insertRow();
} else {
  rs.updateRow();

代码示例来源:origin: p6spy/p6spy

@Override
public void insertRow() throws SQLException {
 delegate.insertRow();
}

代码示例来源:origin: Meituan-Dianping/Zebra

@Override
public void insertRow() throws SQLException {
  innerResultSet.insertRow();
}

代码示例来源:origin: Meituan-Dianping/Zebra

@Override
public void insertRow() throws SQLException {
  innerResultSet.insertRow();
}

代码示例来源:origin: apache/phoenix

@Override
public void insertRow() throws SQLException {
  rs.insertRow();
}

代码示例来源:origin: com.alibaba/druid

@Override
public void insertRow() throws SQLException {
  try {
    rs.insertRow();
  } catch (Throwable t) {
    throw checkException(t);
  }
}

代码示例来源:origin: AxonFramework/AxonFramework

/**
 * Inserts a new token entry via the given updatable {@code resultSet}.
 *
 * @param resultSet     the updatable result set to add the entry to
 * @param token         the token of the entry to insert
 * @param processorName the name of the processor to insert a token for
 * @param segment       the segment of the processor to insert a token for
 * @return the tracking token of the inserted entry
 *
 * @throws SQLException when an exception occurs while inserting a token entry
 */
protected TrackingToken insertTokenEntry(ResultSet resultSet, TrackingToken token, String processorName,
                     int segment) throws SQLException {
  AbstractTokenEntry<?> entry = new GenericTokenEntry<>(token, serializer, contentType, processorName, segment);
  entry.claim(nodeId, claimTimeout);
  resultSet.moveToInsertRow();
  resultSet.updateObject(schema.tokenColumn(), token == null ? null : entry.getSerializedToken().getData());
  resultSet.updateString(schema.tokenTypeColumn(),
              token == null ? null : entry.getSerializedToken().getType().getName());
  resultSet.updateString(schema.timestampColumn(), entry.timestampAsString());
  resultSet.updateString(schema.ownerColum(), entry.getOwner());
  resultSet.updateString(schema.processorNameColumn(), processorName);
  resultSet.updateInt(schema.segmentColumn(), segment);
  resultSet.insertRow();
  return token;
}

代码示例来源:origin: com.alibaba/druid

@Override
public void resultSet_insertRow(ResultSetProxy resultSet) throws SQLException {
  if (this.pos < filterSize) {
    nextFilter().resultSet_insertRow(this, resultSet);
    return;
  }
  resultSet.getResultSetRaw().insertRow();
}

代码示例来源:origin: commons-dbutils/commons-dbutils

/**
 * @throws SQLException
 * @see java.sql.ResultSet#insertRow()
 */
protected final void insertRow() throws SQLException {
  rs.insertRow();
}

代码示例来源:origin: apache/activemq-artemis

@Override
public void insertRow() throws SQLException {
 logger.logf(level, "%s.insertRow()", resultSetID);
 resultSet.insertRow();
}

代码示例来源:origin: org.apache.commons/commons-dbcp2

@Override
public void insertRow() throws SQLException {
  try {
    resultSet.insertRow();
  } catch (final SQLException e) {
    handleException(e);
  }
}

代码示例来源:origin: com.zaxxer/HikariCP-java6

/** {@inheritDoc} */
@Override
public void insertRow() throws SQLException
{
 connection.markCommitStateDirty();
 delegate.insertRow();
}

代码示例来源:origin: org.apache.tomcat/tomcat-dbcp

@Override
public void insertRow() throws SQLException {
  try {
    resultSet.insertRow();
  } catch (final SQLException e) {
    handleException(e);
  }
}

相关文章

微信公众号

最新文章

更多

ResultSet类方法