基于Mybatis-Plus实现Geometry字段在PostGis空间数据库中的使用

标签： gdal  gis  java  postgis  空间数据库  mybatis-plus

目录

背景

一、在pom.xml中引入postgis-jdbc相关jar包

二、需要自定义Handler类来扩展字段支持。

三、在数据中创建表，建表语句如下：

四、定义Mybatis-plus实体

五、定义mapper查询器

六、定义service业务类

八、使用pgadmin可以查看到相应的点数据，如下图所示：

背景

        之前的一些个人文章介绍了空间数据库，以及Mybatis-Plus快速操作数据库组件，以及空间数据库PostGis的相关介绍。现在基于在空间数据库中已经定义了一张空间表，需要在应用程序中使用Mybatis-Plus来进行空间数据的查询、插入等常规操作。

        在OGC标准中，通常空间字段是由Geometry类型来表示。而一般编程语言中是没有这种数据类型的。以java为例，怎么操作这些数据，满足业务需求呢？跟着本文一起来学习吧。

今天介绍基于postgis-jdbc的geometry属性的操作。

一、在pom.xml中引入postgis-jdbc相关jar包

<!-- PostgreSql 驱动包 add by wuzuhu on 2022-08-16 -->
<dependency>
    <groupId>net.postgis</groupId>
	<artifactId>postgis-jdbc</artifactId>
	<version>2.5.0</version>
</dependency>

二、需要自定义Handler类来扩展字段支持。

package com.hngtghy.framework.handler;

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

import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.type.MappedTypes;
import org.postgis.Geometry;
import org.postgis.PGgeometry;

@MappedTypes({String.class})
public class PgGeometryTypeHandler extends BaseTypeHandler<String> {

    @Override
    public void setNonNullParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType) throws SQLException {
        PGgeometry pGgeometry = new PGgeometry(parameter);
        Geometry geometry = pGgeometry.getGeometry();
        geometry.setSrid(4326);
        ps.setObject(i, pGgeometry);
    }

    @Override
    public String getNullableResult(ResultSet rs, String columnName) throws SQLException {
        String string = rs.getString(columnName);
        return getResult(string);
    }

    @Override
    public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
        String string = rs.getString(columnIndex);
        return getResult(string);
    }

    @Override
    public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
        String string = cs.getString(columnIndex);
        return getResult(string);
    }


    private String getResult(String string) throws SQLException {
        PGgeometry pGgeometry = new PGgeometry(string);
        String s = pGgeometry.toString();
        return s.replace("SRID=4326;", "");
    }
}

        注意，在getResult()中关于4326坐标系的定义，可以根据需要进行废弃。这里写上为了统一投影坐标系。

三、在数据中创建表，建表语句如下：

create table biz_point_test(
	id int8 primary key,
	name varchar(100),
	geom geometry(Point,4326)
);

四、定义Mybatis-plus实体

package com.hngtghy.project.extend.student.domain;

import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.hngtghy.framework.handler.PgGeometryTypeHandler;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;
import lombok.ToString;

@TableName(value ="biz_point_test",autoResultMap = true)
@NoArgsConstructor
@AllArgsConstructor
@Setter
@Getter
@ToString
public class PointTest {

	@TableId
	private Long id;
	
	private String name;
	
	@TableField(typeHandler = PgGeometryTypeHandler.class)
	private String geom;
	
	@TableField(exist=false)
	private String geomJson;
}

       提醒：1、在属性上使用@TableField(typeHandler=xxx)来指定对应的类型转换器。2、需要在实体上定义autoResultMap=true。否则配置不一定生效。

五、定义mapper查询器

package com.hngtghy.project.extend.student.mapper;

import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.hngtghy.project.extend.student.domain.PointTest;

public interface PointTestMapper extends BaseMapper<PointTest>{

	static final String FIND_GEOJSON_SQL="<script>"
			+ "select st_asgeojson(geom) as geomJson from biz_point_test "
			+ "where id = #{id} "
			+ "<if test='null != name'>and p.name like concat('%', #{name}, '%')</if>"
			+ "</script>";
	@Select(FIND_GEOJSON_SQL)
	PointTest findGeoJsonById(@Param("id")Long id,@Param("name")String name);
	
}

六、定义service业务类

package com.hngtghy.project.extend.student.service.impl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.hngtghy.project.extend.student.domain.PointTest;
import com.hngtghy.project.extend.student.mapper.PointTestMapper;
import com.hngtghy.project.extend.student.service.IPointTestService;

@Service
public class PointTestServcieImpl extends ServiceImpl<PointTestMapper, PointTest> implements IPointTestService{

	@Autowired
	private PointTestMapper pointMapper;
	
	@Override
	public PointTest selectById(Long id) {
		return pointMapper.selectById(id);
	}

	@Override
	public List<PointTest> selectList(PointTest point) {
		QueryWrapper<PointTest> queryWrapper = new QueryWrapper<PointTest>();
		queryWrapper.select("id,name");
        return this.getBaseMapper().selectList(queryWrapper);
	}

	@Override
	public int insertPointTest(PointTest point) {
		return pointMapper.insert(point);
	}

	@Override
	public int updatePoint(PointTest point) {
		return pointMapper.updateById(point);
	}

	@Override
	public PointTest selectGeomById(Long id) {
		QueryWrapper<PointTest> queryWrapper = new QueryWrapper<PointTest>();
		queryWrapper.select("geom","st_asgeojson(geom) as geomJson");
		queryWrapper.eq("id", id);
        return this.getBaseMapper().selectOne(queryWrapper);
	}

	@Override
	public PointTest findGeoJsonById(Long id) {
		return pointMapper.findGeoJsonById(id, null);
	}

}

       这里添加了一个数据库不存在的字段geomJson,会将空间属性转变成geojson字段，方便于前台的如leaflet、openlayers、cesium等组件进行展示。所以使用postgis的st_asgeojson（xxx）进行函数转换。

七、相关方法调用

//1、列表查询List<PointTest> pointList = pointService.selectList(null);System.out.println(pointList);
[PointTest(id=1559371184090423297, name=中寨居委会, geom=null, geomJson=null), PointTest(id=2, name=禾滩村, geom=null, geomJson=null), PointTest(id=1559403683801796610, name=中寨居委会, geom=null, geomJson=null)]
//2、插入PointTest point = new PointTest();point.setName("中寨居委会");point.setGeom("POINT(109.262605 27.200669)");//POINT(lng,lat) 经度,纬度pointService.insertPointTest(point);
//3、查询数据 PointTest point = pointService.selectGeomById(1559371184090423297L); PointTest json = pointService.findGeoJsonById(1559371184090423297L);
PointTest(id=null, name=null, geom=POINT(109.262605 27.200669), geomJson={"type":"Point","coordinates":[109.262605,27.200669]})PointTest(id=null, name=null, geom=null, geomJson={"type":"Point","coordinates":[109.262605,27.200669]})

八、使用pgadmin可以查看到相应的点数据，如下图所示：

        总结：通过以上步骤可以实现在mybatis-plus中操作geometry空间字段，同时实现查询和插入操作。通过geojson，结合前端可视化组件即可完成矢量数据的空间可视化。希望本文可以帮到你，欢迎交流。

版权声明：本文为yelangkingwuzuhu原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/yelangkingwuzuhu/article/details/126364080

智能推荐

10. 查询小米Note2共有几次订单，显示产品名称，订单数量

...

新发的日常小实验——使用IETester测试不同IE版本的浏览器，测试网页JS的兼容性（console未定义兼容测试）

文章目录 一、痛点：IE兼容测试 二、关于IETester 三、IETester下载 四、写个html测试js的console接口 五、测试结果 六、js兼容处理 一、痛点：IE兼容测试 之前使用.Net的Winform桌面应用框架做了一个PC版的迷你浏览器（使用IE内核），方便拉起网页支付。 有用户反馈打开支付页面报了如下的错：“console”未定义 到底是多么老旧的I...

linux下搭建nginx及配置

文章目录 下载nginx 解压nginx资源包 准备编译环境 安装编译 查找安装路径并启动nginx 浏览器访问 下载nginx 下载地址：https://nginx.org/en/download.html 这里用的是nginx-1.16.1版本 解压nginx资源包 准备编译环境 安装编译 查找安装路径并启动nginx 浏览器访问 http://IP...

腾讯云+tipask快速搭建基于laravel的CMS网站

一、购买腾讯云服务器，服务市场->基础环境->选择WordPress平台镜像 二、按照tipask教程安装 tipask官方教程地址https://wenda.tipask.com/article/22 官方教程对新手不太友好，我整理如下： 1.ftp上传文件 云服务器镜像装载完毕后，浏览器访问服务器公网ip，点击获取权限后会下载服务器相关的文件 浏览器访问host url，根据所给的...

ElasticSearch入门教程

什么是ElasticSearch 基于Apache Lucene构建的开源搜索引擎 采用Java编写,提供简单易用的RESTFul API 轻松的横向扩展，可支持BP级的结构化和非结构化的数据处理 可应用场景 海量数据分析引擎 站内搜索引擎 数据仓库 一线公司实际应用场景 英国卫报 - 实时分析公众对文章的回应 维基百科、GitHub-站内实时搜索 百度 - 实时日志监控平台 安装 Windows...

猜你喜欢

小程序明明已经分包了，为啥没有大小没有变？？？

为什么要分包 真机预览时出现大于2M，无法预览。 对项目进行规整划分 如何分包 实际操作 先将需要分包的文件拷贝到小程序根目录下 在app.json中配置分包结构(如图) 修改被分包中的引用路径，如图片资源、导航URL 可以设置分包的在哪个页面加载 图中表示在进入login页面进行下载设置的分包，all表示在所有网络下。 失败解决！分包了为啥还是提示大小超过2M 分包的文件内所引用的外部文件也必须...

js pixi框架 极其详细到位(入门)-----转载

pixi是一个js 的轻量级的游戏类库框架，很适用于做H5的一些canvas动画特效。 这篇文章是关于pixi的入门教程 ，里面的讲解非常的到位细致，是我看到过的文章里讲解的算是最好的了。  去年快过年看的教程 ，今天再想看的时候发现没找到，不过经过不懈的搜索还是找到 ，那就赶紧给转过来吧。   pixi(入门) Pixi教程 基于官方教程翻译；水平有限，如有错误欢迎提PR，转...

sklearn支持向量机（SVM）多分类问题

模型 sklearn.svm中的支持向量机： Classify：SVC、nuSVC、LinearSVC Regression：SVR、nuSVR、LinearSVR OneClassSVM 本文采用Classify系列，classify三个模型的区别；参数详解 预处理 建模 训练 多种SVC、核函数对比 对比的结果： 优化linear核函数的SVC的惩罚系数 惩罚系数（C=）越高，对错误分类的惩罚...

第一阶段：CSS初步探讨

传统盒子和怪异盒子的初接触 作为一个小白，第一次碰到这种盒子，总算能对盒子变形有一点粗浅认识了，不多说，直接上代码观察 传统盒子的宽高等于内容区域的宽高，如果padding改变则会导致整个盒子变形，撑开来，如box1和box1-1所示 怪异盒子的宽高=内容的宽高+padding2+border2,所以改变padding时不会改变整个盒子的大小，不会变形...

Etherlab源码解析--ecdev_offer()

在linux系统中，网卡及对应的net_device结构体实例是由上层的网络子系统操作的，ecdev_offer()的作用是将网卡转交给ehterlab master操作。 一、预备知识net_device结构体 linux系统中，每一个网卡对应一个net_device结构体的实例，一个网卡要能够被内核识别并收发数据，一般需要经过net_device结构体的创建、初始化、注册到内核、打开设备等步骤...


http://www.vxiaotou.com