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

ResultSet.getCharacterStream介绍

[英]Gets the value of a column specified by column index as a java.io.Reader object.
[中]获取列索引指定为java的列的值。伊奥。读卡器对象。

代码示例

代码示例来源：origin: spring-projects/spring-framework

@Override
public Reader getClobAsCharacterStream(ResultSet rs, int columnIndex) throws SQLException {
  logger.debug("Returning CLOB as character stream");
  if (this.wrapAsLob) {
    Clob clob = rs.getClob(columnIndex);
    return clob.getCharacterStream();
  }
  else {
    return rs.getCharacterStream(columnIndex);
  }
}

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

@Override
public Reader getCharacterStream(String columnLabel) throws SQLException {
  return rs.getCharacterStream(columnLabel);
}

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

@Override
public Reader getCharacterStream(int columnIndex) throws SQLException {
  return rs.getCharacterStream(columnIndex);
}

代码示例来源：origin: nutzam/nutz

public Object get(ResultSet rs, String colName) throws SQLException {
  return rs.getCharacterStream(colName);
}

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

@Override
public java.io.Reader getCharacterStream(String columnLabel) throws SQLException {
  try {
    return rs.getCharacterStream(columnLabel);
  } catch (Throwable t) {
    throw checkException(t);
  }
}

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

@Override
public java.io.Reader getCharacterStream(int columnIndex) throws SQLException {
  try {
    return rs.getCharacterStream(columnIndex);
  } catch (Throwable t) {
    throw checkException(t);
  }
}

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

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

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

@Override public void run() throws Exception {
    rs.getCharacterStream("id");
  }
});

代码示例来源：origin: SonarSource/sonarqube

public void readLineHashesStream(DbSession dbSession, String fileUuid, Consumer<Reader> consumer) {
 Connection connection = dbSession.getConnection();
 PreparedStatement pstmt = null;
 ResultSet rs = null;
 Reader reader = null;
 try {
  pstmt = connection.prepareStatement("SELECT line_hashes FROM file_sources WHERE file_uuid=? AND data_type='SOURCE'");
  pstmt.setString(1, fileUuid);
  rs = pstmt.executeQuery();
  if (rs.next()) {
   reader = rs.getCharacterStream(1);
   if (reader != null) {
    consumer.accept(reader);
   }
  }
 } catch (SQLException e) {
  throw new IllegalStateException("Fail to read FILE_SOURCES.LINE_HASHES of file " + fileUuid, e);
 } finally {
  IOUtils.closeQuietly(reader);
  DbUtils.closeQuietly(connection, pstmt, rs);
 }
}

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

@Override
public java.io.Reader resultSet_getCharacterStream(ResultSetProxy rs, int columnIndex) throws SQLException {
  if (this.pos < filterSize) {
    return nextFilter()
        .resultSet_getCharacterStream(this, rs, columnIndex);
  }
  return rs.getResultSetRaw()
      .getCharacterStream(columnIndex);
}

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

@Override
public java.io.Reader resultSet_getCharacterStream(ResultSetProxy rs, String columnLabel) throws SQLException {
  if (this.pos < filterSize) {
    return nextFilter()
        .resultSet_getCharacterStream(this, rs, columnLabel);
  }
  return rs.getResultSetRaw()
      .getCharacterStream(columnLabel);
}

代码示例来源：origin: apache/incubator-shardingsphere

result = resultSet.getSQLXML(columnLabel);
} else if (Reader.class == type) {
  result = resultSet.getCharacterStream(columnLabel);
} else {
  result = resultSet.getObject(columnLabel);

代码示例来源：origin: apache/incubator-shardingsphere

result = resultSet.getSQLXML(columnIndex);
} else if (Reader.class == type) {
  result = resultSet.getCharacterStream(columnIndex);
} else {
  result = resultSet.getObject(columnIndex);

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

@Override
public int read() throws IOException {
  while (true) {
    try {
      if (current == null) {
        if (closed) {
          return -1;
        }
        if (!rs.next()) {
          close();
          return -1;
        }
        current = rs.getCharacterStream(1);
        current = new BufferedReader(current);
      }
      int x = current.read();
      if (x >= 0) {
        return x;
      }
      current = null;
    } catch (SQLException e) {
      throw DbException.convertToIOException(e);
    }
  }
}
@Override

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

@Override
public Reader getCharacterStream(int columnIndex) throws SQLException {
 SQLException e = null;
 try {
  Reader value = delegate.getCharacterStream(columnIndex);
  eventListener.onAfterResultSetGet(resultSetInformation, columnIndex, value, null);
  return value;
 } catch (SQLException sqle) {
  e = sqle;
  eventListener.onAfterResultSetGet(resultSetInformation, columnIndex, null, e);
  throw e;
 }
}

代码示例来源：origin: igniterealtime/Openfire

if (isStreamTextRequired()) {
  String value;
  try (Reader bodyReader = rs.getCharacterStream(columnIndex)) {
    if (bodyReader == null) {
      return null;

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

@Override
public Reader getCharacterStream(String columnLabel) throws SQLException {
 SQLException e = null;
 try {
  Reader value = delegate.getCharacterStream(columnLabel);
  eventListener.onAfterResultSetGet(resultSetInformation, columnLabel, value, null);
  return value;
 } catch (SQLException sqle) {
  e = sqle;
  eventListener.onAfterResultSetGet(resultSetInformation, columnLabel, null, e);
  throw e;
 }
}

代码示例来源：origin: lealone/Lealone

@Override
public int read() throws IOException {
  while (true) {
    try {
      if (current == null) {
        if (closed) {
          return -1;
        }
        if (!rs.next()) {
          close();
          return -1;
        }
        current = rs.getCharacterStream(1);
        current = new BufferedReader(current);
      }
      int x = current.read();
      if (x >= 0) {
        return x;
      }
      current = null;
    } catch (SQLException e) {
      throw DbException.convertToIOException(e);
    }
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void testGetClobAsCharacterStream() throws SQLException {
  lobHandler.getClobAsCharacterStream(rs, 1);
  verify(rs).getCharacterStream(1);
}

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

ValueLobDb.createSmallLob(Value.CLOB, s.getBytes(StandardCharsets.UTF_8));
} else {
  Reader in = rs.getCharacterStream(columnIndex);
  if (in == null) {
    v = ValueNull.INSTANCE;