@Service
public class RfdwdServiceImpl extends ServiceImpl<RfdwdMapper, Rfdwd> implements IRfdwdService {

    @Resource
    private RfdwdMapper rfdwdMapper;
    /**
     * 获取全部数据的geojson格式
     * @return
     */
    public String queryGeojson(){
        String result=rfdwdMapper.queryGeojson();
        return result;
    }
}

public Result<JSONObject> queryGeojson() {
    String rfdwd=rfdwdService.queryGeojson();
    JSONObject result=JSONObject.parseObject(rfdwd);
    return Result.OK(result);
}

package com.openmap.disaster.config;

import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.type.MappedTypes;

import org.geotools.geojson.geom.GeometryJSON;
import org.geotools.geometry.jts.WKBReader;
import org.locationtech.jts.geom.Geometry;
import org.locationtech.jts.io.ParseException;
import org.postgis.PGgeography;

import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

@MappedTypes({String.class})
public class GeographyTypeHandler extends BaseTypeHandler<String> {
    //插入数据，转换,geoJson2EWKB
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException {
        PGgeography pGgeography = new PGgeography(parameter);
        ps.setObject(i, pGgeography);
    }

    @Override
    public String getNullableResult(ResultSet rs, String columnName) throws SQLException {
        PGgeography pGgeography = new PGgeography(rs.getString(columnName));
        if (pGgeography == null) {
            return null;
        }
        return pGgeography.toString();
    }

    @Override
    public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        PGgeography pGgeography = new PGgeography(rs.getString(columnIndex));
        if (pGgeography == null) {
            return null;
        }
        return pGgeography.toString();
    }

    @Override
    public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        PGgeography pGgeography = new PGgeography(cs.getString(columnIndex));
        if (pGgeography == null) {
            return null;
        }
        return pGgeography.toString();
    }

    //取出数据转换,WKB->Geojson
    @Override
    public String getResult(ResultSet rs, String columnName) throws SQLException {
        String WKB = rs.getString(columnName);
        if(WKB==null){
            return null;
        }
        WKBReader reader = new WKBReader();
        Geometry geometry = null;
        try {
            geometry = reader.read(WKBReader.hexToBytes(WKB));
        } catch (ParseException e) {
            //转换失败
            return null;
        }
        // 设置保留15位小数，否则GeometryJSON默认保留4位小数
        GeometryJSON geometryJson = new GeometryJSON(16);
        return geometryJson.toString(geometry);
    }
}

package com.openmap.disaster.entity;

import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import java.util.Date;
import java.math.BigDecimal;

import com.baomidou.mybatisplus.annotation.*;
import com.openmap.disaster.config.GeographyTypeHandler;
import lombok.Data;
import com.fasterxml.jackson.annotation.JsonFormat;
import org.springframework.format.annotation.DateTimeFormat;
import org.jeecgframework.poi.excel.annotation.Excel;
import org.jeecg.common.aspect.annotation.Dict;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

/**
 * @Description: rfdws
 * @Author: jeecg-boot
 * @Date:   2023-08-21
 * @Version: V1.0
 */
@Data
@TableName(value = "map_rfdwd",autoResultMap = true)
public class Rfdwd implements Serializable {
    private static final long serialVersionUID = 1L;

	/**shape,指定类型转换器*/
    @TableField(typeHandler = GeographyTypeHandler.class)
    private String shape;
}

@Excel(name = "shape", width = 15)
@ApiModelProperty(value = "shape")
@TableField(typeHandler = GeographyTypeHandler.class)
private String shape;

@MappedTypes({String.class})
public class GeographyTypeHandler extends BaseTypeHandler<String> {
    private static final Logger logger= LoggerFactory.getLogger(GeographyTypeHandler.class);
    //插入数据，转换,geoJson2EWKB
    @Override
    public void setNonNullParameter(@NotNull PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException {
        PGgeography pGgeography = new PGgeography(s1);
        ps.setObject(i, pGgeography);
    }
}

@Override
public void setNonNullParameter(@NotNull PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException {
    try {
        GeometryJSON geometryJson = new GeometryJSON(16);
        Geometry geometry = geometryJson.read(parameter);
        WKBWriter wkbWriter = new WKBWriter();
        byte[] write = wkbWriter.write(geometry);
        String s1 = WKBWriter.toHex(write);
        PGgeometry pGgeometry=new PGgeometry(s1);
        ps.setObject(i, pGgeometry);
    }catch (Exception e){
        logger.error("GeographyTypeHandler",e);
    }
}