gemo处理器（点，线，面）

Dear 丶 2022-10-06 04:55 148阅读 0赞

@Data  
@Builder  
@NoArgsConstructor  
@AllArgsConstructor  
@TableName(value = "g", autoResultMap = true)  
public class IssueRecord implements Serializable \{  
    private static final long serialVersionUID = -2178894779068406929L;

@ApiModelProperty("空间坐标")  
    @TableField(value = "geom", typeHandler = GeometryTypeHandler.class)  
    private String geom;  
\}

package com.t.collect.handle;

import com.t.collect.enums.ResultCode;  
import com.t.collect.exception.BizException;  
import org.apache.ibatis.type.BaseTypeHandler;  
import org.apache.ibatis.type.JdbcType;  
import org.apache.ibatis.type.MappedJdbcTypes;  
import org.apache.ibatis.type.MappedTypes;  
import org.postgis.\*;

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

@MappedJdbcTypes(JdbcType.OTHER)  
@MappedTypes(\{String.class\})  
public class GeometryTypeHandler extends BaseTypeHandler<String> \{  
    private final static String POLYGON = "POLYGON";  
    private final static String MULTIPOLYGON = "MULTIPOLYGON";  
    private final static String LINESTRING = "LINESTRING";  
    private final static String POINT = "POINT";

/\*\*  
     \*  
     \* @param ps  
     \* @param i  
     \* @param parameter  
     \* @param jdbcType  
     \* @throws SQLException  
     \* @return void  
     \*/  
    @Override  
    public void setNonNullParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException \{  
        if (parameter.startsWith(POLYGON)) \{  
            PGgeometry pGgeometry = new PGgeometry();  
            Polygon polygon = new Polygon(parameter);  
            polygon.setSrid(4326);  
            pGgeometry.setGeometry(polygon);  
            ps.setObject(i, pGgeometry);  
        \} else if (parameter.startsWith(MULTIPOLYGON)) \{  
            PGgeometry pGgeometry = new PGgeometry();  
            MultiPolygon multiPolygon = new MultiPolygon(parameter);  
            multiPolygon.setSrid(4326);  
            pGgeometry.setGeometry(multiPolygon);  
            ps.setObject(i, pGgeometry);  
        \} else if (parameter.startsWith(LINESTRING)) \{  
            PGgeometry pGgeometry = new PGgeometry();  
            LineString lineString = new LineString(parameter);  
            lineString.setSrid(4326);  
            pGgeometry.setGeometry(lineString);  
            ps.setObject(i, pGgeometry);  
        \} else if (parameter.startsWith(POINT)) \{  
            PGgeometry pGgeometry = new PGgeometry();  
            Point pointString = new Point(parameter);  
            pointString.setSrid(4326);  
            pGgeometry.setGeometry(pointString);  
            ps.setObject(i, pGgeometry);  
        \} else \{  
            throw new BizException(ResultCode.INVALID\_FORMAT\_ERROR);  
        \}  
    \}

/\*\*  
     \*  
     \* @param rs  
     \* @param columnName  
     \* @throws SQLException  
     \* @return String  
     \*/  
    @Override  
    public String getNullableResult(ResultSet rs, String columnName) throws SQLException \{  
        String geo = rs.getString(columnName);  
        PGgeometry pGgeometry = new PGgeometry(geo);  
        if (pGgeometry.getGeometry() instanceof LineString) \{  
            LineString lineString = (LineString) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Polygon) \{  
            Polygon polygon = (Polygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            polygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof MultiPolygon) \{  
            MultiPolygon multiPolygon = (MultiPolygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            multiPolygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Point) \{  
            Point lineString = (Point) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else \{  
            throw new BizException(ResultCode.INTERNAL\_ERROR);  
        \}  
    \}

/\*\*  
     \*  
     \* @param rs  
     \* @param columnIndex  
     \* @throws SQLException  
     \* @return String  
     \*/  
    @Override  
    public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException \{  
        String geo = rs.getString(columnIndex);  
        PGgeometry pGgeometry = new PGgeometry(geo);  
        if (pGgeometry.getGeometry() instanceof LineString) \{  
            LineString lineString = (LineString) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Polygon) \{  
            Polygon polygon = (Polygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            polygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof MultiPolygon) \{  
            MultiPolygon multiPolygon = (MultiPolygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            multiPolygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Point) \{  
            Point lineString = (Point) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else \{  
            throw new BizException(ResultCode.INTERNAL\_ERROR);  
        \}  
    \}

/\*\*  
     \*  
     \* @param cs  
     \* @param columnIndex  
     \* @throws SQLException  
     \* @return String  
     \*/  
    @Override  
    public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException \{  
        String geo = cs.getString(columnIndex);  
        PGgeometry pGgeometry = new PGgeometry(geo);  
        if (pGgeometry.getGeometry() instanceof LineString) \{  
            LineString lineString = (LineString) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Polygon) \{  
            Polygon polygon = (Polygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            polygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof MultiPolygon) \{  
            MultiPolygon multiPolygon = (MultiPolygon) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            multiPolygon.outerWKT(sb);  
            return sb.toString();  
        \} else if (pGgeometry.getGeometry() instanceof Point) \{  
            Point lineString = (Point) pGgeometry.getGeometry();  
            StringBuffer sb = new StringBuffer();  
            lineString.outerWKT(sb);  
            return sb.toString();  
        \} else \{  
            throw new BizException(ResultCode.INTERNAL\_ERROR);  
        \}  
    \}  
\}