在上一篇文章中 ，我展示了如何將java.sql.ResultSet轉(zhuǎn)換為JSON并將其流回調(diào)用方。 這篇文章是關(guān)于以CSV格式流式傳輸?shù)摹?流式傳輸使您可以一點(diǎn)一點(diǎn)地傳輸數(shù)據(jù)，而不必將所有數(shù)據(jù)都加載到服務(wù)器的內(nèi)存中。

例如，考慮以下ResultSet ：

+---------+-----+ | Name | Age | +---------+-----+ | Alice | 20 | | Bob | 35 | | Charles | 50 | +---------+-----+

相應(yīng)的CSV是：

name,age Alice,20 Bob,35 Charles,50

以下類（在我的GitHub Repository中也可用）可用于將ResultSet轉(zhuǎn)換為CSV。 請(qǐng)注意，此類實(shí)現(xiàn)Spring的ResultSetExtractor ， JdbcTemplate可以使用該類從ResultSet提取結(jié)果。

/*** Streams a ResultSet as CSV.*/ public class StreamingCsvResultSetExtractorimplements ResultSetExtractor<Void> {private static char DELIMITER = ',';private final OutputStream os;/*** @param os the OutputStream to stream the CSV to*/public StreamingCsvResultSetExtractor(final OutputStream os) {this.os = os;}@Overridepublic Void extractData(final ResultSet rs) {try (var pw = new PrintWriter(os, true)) {final var rsmd = rs.getMetaData();final var columnCount = rsmd.getColumnCount();writeHeader(rsmd, columnCount, pw);while (rs.next()) {for (var i = 1; i <= columnCount; i++) {final var value = rs.getObject(i);pw.write(value == null ? "" : value.toString());if (i != columnCount) {pw.append(DELIMITER);}}pw.println();}pw.flush();} catch (final SQLException e) {throw new RuntimeException(e);}return null;}private static void writeHeader(final ResultSetMetaData rsmd,final int columnCount, final PrintWriter pw) throws SQLException {for (var i = 1; i <= columnCount; i++) {pw.write(rsmd.getColumnName(i));if (i != columnCount) {pw.append(DELIMITER);}}pw.println();} }

要將其用于帶有JAX-RS的Web服務(wù)中：

import javax.ws.rs.core.StreamingOutput;@GET @Path("runQuery") @Produces("text/csv") public StreamingOutput runQuery() {return new StreamingOutput() {@Overridepublic void write(final OutputStream os)throws IOException, WebApplicationException {jdbcTemplate.query("select name, age from person",new StreamingCsvResultSetExtractor(os));}}; }

相關(guān)文章：

流式傳輸JDBC ResultSet作為JSON

翻譯自: https://www.javacodegeeks.com/2018/12/java-streaming-jdbc-resultset-csv.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎(jiǎng)勵(lì)來(lái)咯，堅(jiān)持創(chuàng)作打卡瓜分現(xiàn)金大獎(jiǎng)

總結(jié)

以上是生活随笔為你收集整理的Java：以CSV格式流式传输JDBC结果集的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。