MyBatisPlus+PostGIS实现Geometry数据的通用读写

本文涉及的产品
云原生数据库 PolarDB MySQL 版,Serverless 5000PCU 100GB
简介: MyBatisPlus+PostGIS实现Geometry数据的通用读写


  1. 引入依赖
<!--连接Postgresql数据库-->
 <dependency>
       <groupId>org.postgresql</groupId>
       <artifactId>postgresql</artifactId>
 </dependency>
  <!--编(解)码postgresql写入(或读取)的Geometry-->
 <dependency>
      <groupId>net.postgis</groupId>
      <artifactId>postgis-jdbc</artifactId>
      <version>2.5.0</version>
 </dependency>
  <!--Geometry工具库-->
 <dependency>
        <groupId>org.locationtech.jts</groupId>
        <artifactId>jts-core</artifactId>
        <version>1.17.0</version>
  </dependency>
  1. Entity编写
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonIgnore;
import com.jd.risk.screen.demo.entity.handler.PointTypeHandler;
import lombok.Data;
import org.locationtech.jts.geom.Point;
/**
 * 基站PO
 *
 * @author wangrubin
 * @date 2022-08-16
 */
@Data
@TableName(value = "t_base_station", autoResultMap = true)
public class StationPO {
    /**
     * 基站ID
     */
    @TableId(type = IdType.AUTO)
    private Long id;
    /**
     * 基站位置
     */
    @JsonIgnore
    @TableField(typeHandler = PointTypeHandler.class)
    private Point location;
}
  1. 实现几何(Geometry)类型转换器
  • 父类转换器逻辑
import lombok.SneakyThrows;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.locationtech.jts.geom.Geometry;
import org.locationtech.jts.io.WKTReader;
import org.locationtech.jts.io.WKTWriter;
import org.postgis.PGgeometry;
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
 * Geometry字段和MyBatis类型转换器
 *
 * @param <T> 具体的几何类型
 * @author wangrubin
 * @date 2022-08-06
 */
public abstract class AbstractGeometryTypeHandler<T extends Geometry> extends BaseTypeHandler<T> {
    /**
     * WKTReader非线程安全
     */
    private static final ThreadLocal<WKTReader> READER_POOL = ThreadLocal.withInitial(WKTReader::new);
    /**
     * WKTWriter非线程安全
     */
    private static final ThreadLocal<WKTWriter> WRITER_POOL = ThreadLocal.withInitial(WKTWriter::new);
    /**
     * 与数据库中几何列的空间坐标系保持一致,要不然写入会报错
     */
    private static final int SRID_IN_DB = 4326;
    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, T parameter, JdbcType jdbcType) throws SQLException {
        PGgeometry pGgeometry = new PGgeometry(WRITER_POOL.get().write(parameter));
        org.postgis.Geometry geometry = pGgeometry.getGeometry();
        geometry.setSrid(SRID_IN_DB);
        ps.setObject(i, pGgeometry);
    }
    @SneakyThrows
    @Override
    public T getNullableResult(ResultSet rs, String columnName) {
        String string = rs.getString(columnName);
        return getResult(string);
    }
    @SneakyThrows
    @Override
    public T getNullableResult(ResultSet rs, int columnIndex) {
        String string = rs.getString(columnIndex);
        return getResult(string);
    }
    @SneakyThrows
    @Override
    public T getNullableResult(CallableStatement cs, int columnIndex) {
        String string = cs.getString(columnIndex);
        return getResult(string);
    }
    private T getResult(String string) throws SQLException {
        if(string == null){  
            return null;
        }
        PGgeometry pGgeometry = new PGgeometry(string);
        String s = pGgeometry.toString();
        String target = String.format("SRID=%s;", SRID_IN_DB);
        String wkt = s.replace(target, "");
        try {
            return (T) READER_POOL.get().read(wkt);
        } catch (Exception e) {
            throw new RuntimeException("解析wkt失败:" + wkt, e);
        }
    }
}
  • 子类转换器逻辑
import org.apache.ibatis.type.MappedTypes;
import org.locationtech.jts.geom.Point;
/**
 * Point的类型转换器
 *
 * @author wangrubin1
 * @date 2022-08-19
 */
@MappedTypes({Point.class})
public class PointTypeHandler extends AbstractGeometryTypeHandler<Point> {
}
  1. 建表语句
CREATE TABLE public.t_base_station
(
    id bigserial primary key,
    location geometry(Point,4326)  -- 坐标系是4326
)
  1. 测试
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.jd.risk.screen.demo.entity.StationPO;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface StationMapper extends BaseMapper<StationPO> {
}
@SpringBootTest(classes = DemoApplication.class)
@ExtendWith(SpringExtension.class)
@WebAppConfiguration
class GeometryTests {
    @Autowired
    private StationMapper stationMapper;
    @Test
    public void insert() {
        GeometryFactory factory = new GeometryFactory();
        StationPO stationPo = new StationPO();
        stationPo.setLocation(factory.createPoint(new Coordinate(115.3, 24.7)));
        stationMapper.insert(stationPo);
    }
    @Test
    public void select() {
        StationPO stationPo = stationMapper.selectById(1L);
        System.out.println(stationPo);
    }
}

控制台输出:StationPO(id=1, location=POINT (115.3 24.7))


相关实践学习
使用PolarDB和ECS搭建门户网站
本场景主要介绍基于PolarDB和ECS实现搭建门户网站。
阿里云数据库产品家族及特性
阿里云智能数据库产品团队一直致力于不断健全产品体系,提升产品性能,打磨产品功能,从而帮助客户实现更加极致的弹性能力、具备更强的扩展能力、并利用云设施进一步降低企业成本。以云原生+分布式为核心技术抓手,打造以自研的在线事务型(OLTP)数据库Polar DB和在线分析型(OLAP)数据库Analytic DB为代表的新一代企业级云原生数据库产品体系, 结合NoSQL数据库、数据库生态工具、云原生智能化数据库管控平台,为阿里巴巴经济体以及各个行业的企业客户和开发者提供从公共云到混合云再到私有云的完整解决方案,提供基于云基础设施进行数据从处理、到存储、再到计算与分析的一体化解决方案。本节课带你了解阿里云数据库产品家族及特性。
相关文章
|
1月前
|
Java 数据库连接 mybatis
Mybatis Plus保存数据返回主键id
Mybatis Plus保存数据返回主键id
63 1
|
1月前
Mybatis+mysql动态分页查询数据案例——测试类HouseDaoMybatisImplTest)
Mybatis+mysql动态分页查询数据案例——测试类HouseDaoMybatisImplTest)
39 1
|
1月前
|
Java 关系型数据库 数据库连接
Mybatis+MySQL动态分页查询数据经典案例(含代码以及测试)
Mybatis+MySQL动态分页查询数据经典案例(含代码以及测试)
59 1
|
1月前
Mybatis+mysql动态分页查询数据案例——条件类(HouseCondition)
Mybatis+mysql动态分页查询数据案例——条件类(HouseCondition)
30 1
|
1月前
Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
Mybatis+mysql动态分页查询数据案例——分页工具类(Page.java)
37 1
|
1月前
Mybatis+mysql动态分页查询数据案例——房屋信息的实现类(HouseDaoMybatisImpl)
Mybatis+mysql动态分页查询数据案例——房屋信息的实现类(HouseDaoMybatisImpl)
37 2
|
1月前
Mybatis+mysql动态分页查询数据案例——工具类(MybatisUtil.java)
Mybatis+mysql动态分页查询数据案例——工具类(MybatisUtil.java)
38 1
|
13天前
|
Java 数据库连接 数据库
mybatis自制插件+注解实现数据脱敏
mybatis自制插件+注解实现数据脱敏
13 1
|
13天前
|
存储 Java 关系型数据库
留言板——增添功能(持久化存储数据,使用MyBatis)
留言板——增添功能(持久化存储数据,使用MyBatis)
22 4
|
24天前
|
算法 BI 数据库
MyBatisPlus查询条件设置、映射匹配兼容性、id生成策略、多数据操作
MyBatisPlus查询条件设置、映射匹配兼容性、id生成策略、多数据操作
33 3