怎么把resultset转换成json

如何将ResultSet转换为JSON：实用指南与代码示例

在Java开发中，尤其是在处理数据库操作时，我们经常需要将从数据库查询得到的ResultSet对象转换为JSON格式，以便于前端API调用或数据交换，本文将详细介绍几种常见的ResultSet转JSON的方法,并提供实用的代码示例。

使用手动遍历转换

最基本的方法是手动遍历ResultSet并将其转换为JSON格式，这种方法简单直观,适合小型项目或简单的数据结构转换。

import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import org.json.JSONArray;
import org.json.JSONObject;
public class ResultSetToJsonConverter {
    public static JSONArray convert(ResultSet rs) throws SQLException {
        JSONArray jsonArray = new JSONArray();
        ResultSetMetaData metaData = rs.getMetaData();
        int columnCount = metaData.getColumnCount();
        while (rs.next()) {
            JSONObject jsonObject = new JSONObject();
            for (int i = 1; i <= columnCount; i++) {
                String columnName = metaData.getColumnLabel(i);
                Object value = rs.getObject(i);
                jsonObject.put(columnName, value);
            }
            jsonArray.put(jsonObject);
        }
        return jsonArray;
    }
}

使用Jackson库

Jackson是一个流行的Java JSON处理库,提供了更高效和灵活的转换方式。

添加Jackson依赖到项目中：

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.13.0</version>
</dependency>

使用ObjectMapper进行转换：

import com.fasterxml.jackson.databind.ObjectMapper;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class ResultSetToJsonWithJackson {
    public static List<Map<String, Object>> convert(ResultSet rs) throws SQLException {
        List<Map<String, Object>> list = new ArrayList<>();
        ResultSetMetaData metaData = rs.getMetaData();
        int columnCount = metaData.getColumnCount();
        while (rs.next()) {
            Map<String, Object> row = new HashMap<>();
            for (int i = 1; i <= columnCount; i++) {
                row.put(metaData.getColumnLabel(i), rs.getObject(i));
            }
            list.add(row);
        }
        return list;
    }
    // 使用Jackson进一步转换为JSON字符串
    public static String convertToJsonString(ResultSet rs) throws SQLException {
        List<Map<String, Object>> list = convert(rs);
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            return objectMapper.writeValueAsString(list);
        } catch (Exception e) {
            throw new SQLException("Failed to convert ResultSet to JSON", e);
        }
    }
}

使用Gson库

Gson是Google提供的另一个流行的Java JSON处理库。

添加Gson依赖：

<dependency>
    <groupId>com.google.code.gson</groupId>
    <artifactId>gson</artifactId>
    <version>2.8.9</version>
</dependency>

使用Gson进行转换：

import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
public class ResultSetToJsonWithGson {
    public static JsonArray convert(ResultSet rs) throws SQLException {
        JsonArray jsonArray = new JsonArray();
        ResultSetMetaData metaData = rs.getMetaData();
        int columnCount = metaData.getColumnCount();
        while (rs.next()) {
            JsonObject jsonObject = new JsonObject();
            for (int i = 1; i <= columnCount; i++) {
                String columnName = metaData.getColumnLabel(i);
                Object value = rs.getObject(i);
                if (value instanceof String) {
                    jsonObject.addProperty(columnName, (String) value);
                } else if (value instanceof Number) {
                    jsonObject.addProperty(columnName, (Number) value);
                } else if (value instanceof Boolean) {
                    jsonObject.addProperty(columnName, (Boolean) value);
                } else {
                    jsonObject.addProperty(columnName, value.toString());
                }
            }
            jsonArray.add(jsonObject);
        }
        return jsonArray;
    }
    // 转换为JSON字符串
    public static String convertToJsonString(ResultSet rs) throws SQLException {
        JsonArray jsonArray = convert(rs);
        return jsonArray.toString();
    }
}

使用第三方库（如JDBI或Spring JDBC）

如果项目已经使用了JDBI或Spring JDBC等框架,可以利用它们提供的功能简化转换过程。

使用JDBI

import org.jdbi.v3.core.mapper.reflect.BeanMapper;
import org.jdbi.v3.core.result.ResultSetIterable;
import org.jdbi.v3.core.result.UnableToProduceResultException;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.util.List;
public class JdbiJsonConverter {
    public static String convertToJson(ResultSetIterable<?> iterable, Class<?> beanType) {
        try {
            ObjectMapper objectMapper = new ObjectMapper();
            List<?> list = iterable.list(BeanMapper.of(beanType));
            return objectMapper.writeValueAsString(list);
        } catch (Exception e) {
            throw new UnableToProduceResultException("Failed to convert to JSON", e);
        }
    }
}

最佳实践与注意事项

资源管理：确保在使用完ResultSet后关闭它，可以使用try-with-resources语句。
性能考虑：对于大型结果集,考虑分页处理或使用流式API。
数据类型处理：注意处理数据库特殊类型（如BLOB、CLOB）的转换。
异常处理：妥善处理可能出现的SQLException和其他异常。
日期时间处理：确保日期时间字段正确转换为JSON格式。

示例使用

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class Main {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/testdb";
        String user = "username";
        String password = "password";
        try (Connection conn = DriverManager.getConnection(url, user, password);
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery("SELECT * FROM users")) {
            // 使用Jackson转换
            String jsonString = ResultSetToJsonWithJackson.convertToJsonString(rs);
            System.out.println(jsonString);
            // 使用Gson转换
            JsonArray jsonArray = ResultSetToJsonWithGson.convert(rs);
            System.out.println(jsonArray.toString());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

将ResultSet转换为JSON是Java开发中的常见需求，本文介绍了多种实现方法，从基本的手动遍历到使用Jackson、Gson等流行库，选择哪种方法取决于项目需求、性能考虑以及团队的技术栈，对于大多数现代Java项目，推荐使用Jackson或Gson等成熟的库，因为它们提供了更好的性能、更丰富的功能和更简洁的代码。

企鹅直播企鹅直播足球直播爱奇艺直播爱奇艺足球直播足球直播足球直播