springboot+mybatisplus+postgis实现几何点和线串增删改查分页

postgis类型介绍

对象分类	描述
POINT	点
MULTIPOINT	多点
LINESTRING	线
LINEARRING	线环
MULTILINESTRING	点串
POLYGON	面
MULTIPOLYGON	多面
POLYHEDRALSURFACE	多面体表面
TRIANGLE	三角形
TIN	不规则三角网
CIRCULARSTRING	曲线串
MULTICURVE	多(曲)线
MULTISURFACE	多面
GEOMETRYCOLLECTION	复合对象

实现点、线环的增删改查分页

1.添加pom依赖

 <!-- postgresql --><dependency><groupId>org.postgresql</groupId><artifactId>postgresql</artifactId></dependency><!-- PostGis --><dependency><groupId>net.postgis</groupId><artifactId>postgis-jdbc</artifactId><version>2.5.0</version></dependency><!-- 分页插件 --><dependency><groupId>com.github.pagehelper</groupId><artifactId>pagehelper-spring-boot-starter</artifactId><version>1.2.12</version><exclusions><exclusion><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></exclusion></exclusions></dependency>

2.yml配置文件

spring:datasource:username: rootpassword: 1234url: jdbc:postgresql://127.0.0.1:5432/db?useUnicode=true&characterEncoding=utf8&currentSchema=public&stringtype=unspecifieddriver-class-name: org.postgresql.Drivertype: com.alibaba.druid.pool.DruidDataSource  #数据源类型initial-size: 5min-idle: 5max-active: 50max-wait: 60000
mybatis:type-aliases-package: com.cherry.manager.entity # 所有POJO类所在包路径mapper-locations: classpath:mapper/*.xml # mapper映射文件 logImplconfiguration:log-impl: org.apache.ibatis.logging.stdout.StdOutImplcache-enabled: truemap-underscore-to-camel-case: true
swagger:enable: true
pagehelper:helper-dialect: postgresqlreasonable: truesupport-methods-arguments: trueparams: count=countSql

响应结果类：
JSONFormatter.class

import com.google.gson.FieldNamingPolicy;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.JsonElement;import java.lang.reflect.Type;
import java.util.List;/*** JSONFormatter converts objects to JSON representation and vice-versa. This* class depends on Google's GSON library to do the transformation. This class* is not thread-safe.*/
public final class JSONFormatter {/*** FieldNamingPolicy used by the underlying Gson library. Alter this* property to set a fieldnamingpolicy other than* LOWER_CASE_WITH_UNDERSCORES used by PayPal REST APIs*/private static FieldNamingPolicy FIELD_NAMING_POLICY = FieldNamingPolicy.IDENTITY;/*** Gson*/public static Gson GSON = new GsonBuilder().setDateFormat("yyyy-MM-dd HH:mm:ss")
//          .setPrettyPrinting() // beautify format.setFieldNamingPolicy(FIELD_NAMING_POLICY).create();/** JSONFormatter is coupled to the stubs generated using the SDK generator.* Since PayPal REST APIs support only JSON, this class is bound to the* stubs for their json representation.*/private JSONFormatter() {}/*** Set a format for gson FIELD_NAMING_POLICY. See {@link FieldNamingPolicy}** @param FIELD_NAMING_POLICY*/public static final void setFIELD_NAMING_POLICY(FieldNamingPolicy FIELD_NAMING_POLICY) {GSON = new GsonBuilder().setPrettyPrinting().setFieldNamingPolicy(FIELD_NAMING_POLICY).create();}/*** Converts a Raw Type to JSON String** @param <T> Type to be converted* @param t   Object of the type* @return JSON representation*/public static <T> String toJSON(T t) {return GSON.toJson(t);}/*** Converts a Raw Type to JSON String** @param <T> Type to be converted* @param t   Object of the type* @param e   Type typeOfSrc = new TypeToken&lt;Collection&lt;Foo&gt;&gt;(){}.getType();* @return JSON representation*/public static <T> String toJSON(T t, Type e) {return GSON.toJson(t, e);}/*** Converts a JSON String to object representation** @param <T>            Type to be converted* @param responseString JSON representation* @param clazz          Target class* @return Object of the target type*/public static <T> T fromJSON(String responseString, Class<T> clazz) {T t = null;if (clazz.isAssignableFrom(responseString.getClass())) {t = clazz.cast(responseString);} else {t = GSON.fromJson(responseString, clazz);}return t;}/*** Converts a JSON String to object representation** @param <T>            Type to be converted* @param responseString String of the type* @param e              Type typeOfSrc = new TypeToken&lt;Collection&lt;Foo&gt;&gt;(){}.getType();* @return JSON representation*/public static <T> T fromJSON(String responseString, Type clazz) {return GSON.fromJson(responseString, clazz);}/*** Converts a JSON Element to object representation** @param <T>      Type to be converted* @param response JSON element* @param clazz    Target class* @return Object of the target type*/public static <T> T fromJSON(JsonElement response, Class<T> clazz) {return GSON.fromJson(response, clazz);}/*** Converts a JSON Element to list representation** @param <T>      Type to be converted* @param response JSON element* @param clazz    Target class* @return Object of the target type*/public static <T> List<T> fromList(JsonElement response, Class<T> clazz) {return GSON.fromJson(response, new JSONList<T>(clazz));}/*** Converts a JSON String to list representation** @param <T>      Type to be converted* @param response JSON element* @param clazz    Target class* @return Object of the target type*/public static <T> List<T> fromList(String response, Class<T> clazz) {return GSON.fromJson(response, new JSONList<T>(clazz));}
}

JSONList.class

import com.google.gson.internal.$Gson$Types;import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.util.List;public class JSONList<T> implements ParameterizedType {final Type type;private Class<? super T> wrapped;public JSONList(Class<T> cls) {this.wrapped = cls;this.type = null; //getSuperclassTypeParameter(cls);}/*** Returns the type from super class's type parameter in*/static Type getSuperclassTypeParameter(Class<?> subclass) {Type superclass = subclass.getGenericSuperclass();if (superclass instanceof Class) {throw new RuntimeException("Missing type parameter.");}ParameterizedType parameterized = (ParameterizedType) superclass;return $Gson$Types.canonicalize(parameterized.getActualTypeArguments()[0]);}@Overridepublic Type[] getActualTypeArguments() {return new Type[]{wrapped};}@Overridepublic Type getOwnerType() {return type;}@Overridepublic Type getRawType() {return List.class;}}

ServiceCodeEnum.class

import org.slf4j.helpers.MessageFormatter;
import org.springframework.http.HttpStatus;public enum ServiceCodeEnum implements ServiceCodeInterface {/*** 执行成功 200*/SUCCESS(HttpStatus.OK.value(), "执行成功"),/*** 参数异常 400*/PARAM_ERROR(HttpStatus.BAD_REQUEST.value(), "参数异常"),/*** 数据校验错误 400*/VALIDATOR_ERROR(HttpStatus.BAD_REQUEST.value(), "<strong>请求数据不合法：</strong><br>{}"),//    /**
//     * 非法请求/Token超时 401
//     */
//    AUTH_CHECK_FIAL(HttpStatus.UNAUTHORIZED.value(), "Illegal request/link invalid"),/*** token 为空 401*/TOKEN_IS_NULL(HttpStatus.UNAUTHORIZED.value(), "身份令牌（token）不能为空"),/*** token 身份令牌（token）有误 401*/TOKEN_IS_ERROR(HttpStatus.UNAUTHORIZED.value(), "身份令牌（token）有误"),/*** 登录超时 401*/LOGIN_TIME_OUT(HttpStatus.UNAUTHORIZED.value(), "登录超时，请重新登录"),/*** 当前账号在其他设备上登录 401*/OTHER_LOGIN(HttpStatus.UNAUTHORIZED.value(), "当前账号在其他设备上登录"),/*** 无权限 403*/FORBIDDEN(HttpStatus.FORBIDDEN.value(), "暂无权限，请联系管理员授权"),/*** 资源不存在 404*/NOT_FOUND(HttpStatus.NOT_FOUND.value(), "您请求的资源不存在"),/*** 处理请求方式非法 405*/ILLEGAL_WAY_ERROR(HttpStatus.METHOD_NOT_ALLOWED.value(), "请求方式非法"),/*** 数据已存在，数据库唯一索引抛出 409*/DATA_IS_EXISTS(HttpStatus.CONFLICT.value(), "数据库数据已存在，请检查参数"),/*** 处理自定义异常 412*/HANDLING_ERROR(HttpStatus.PRECONDITION_FAILED.value(), "请求业务异常"),/*** 系统异常 - 后台报错 500*/SYS_ERROR(HttpStatus.INTERNAL_SERVER_ERROR.value(), "未知异常，请联系管理员"),/*** 远程接口调用失败 500*/HTTP_ERROR(HttpStatus.INTERNAL_SERVER_ERROR.value(), "远程接口调用失败"),/*** 数据保存失败*/DATA_SAVE_FAIL(1002, "Failed to save data"),/*** 上传文件异常*/FILE_UPLOAD_SIZE(1003, "MaxUploadSize:Please contact the administrator!"),DATA_IS_NULL(1004, "数据不存在"),DATA_NOT_NULL(1005, "子级存在数据,请先删除子级数据！"),CLASSIFICATION_NAME_IS_EXISTS(1006, "类别名称已经存在！"),ROUTE_NAME_IS_EXISTS(1007, "路由名称或路径已经存在！"),INTERFACE_PATH_IS_EXISTS(1008, "接口路径已经存在！"),/*** ---------------------------------------------------- 数据库 ----------------------------------------------------*/TREE_FIRST_NODE_IS_ZERO(1003, "树形结构的第一级节点数据不能为‘0’"),/*** ---------------------------------------------------- 用户相关 ----------------------------------------------------*/FILE_IS_EMPTY(1000001, "您上传的文件为空，路径：{}"),ONLY_ZIP(1000002, "仅支持Zip上传"),FILE_IS_LONG(1000003, "文件超过{}M"),CHECK_FILE_MD5(1000004, "文件MD5无效"),PASSWORD_MODIFY(11003, "密码已修改，请重新登录"),NO_PROJECT_MANAGER_AUTHORITY(11000, "您没有权限管理当前项目数据"),USER_NOT_HAS_ROLE(11009, "您暂无角色信息，请联系管理员分配"),USER_NOT_FOUND(11001, "用户不存在"),ORI_PASSWORD_ERROR(11002, "旧密码输入有误"),PASSWORD_ERROR(11003, "密码输入有误"),SMS_CODE_ERROR(11005, "验证码输入有误，请重新输入"),USER_NOT_USED(11006, "用户未启用或者被锁定"),PASSWORD_IS_NULL(11007, "密码为空"),USERNAME_CANNOT_IS_MOBILE_OR_EMAIL(11008, "用户名不可为手机号或邮箱"),MOBILE_MISMATCH(11009, "手机号不匹配"),USER_IS_USERD(11010, "该账户已经激活，请勿重复操作"),CHECK_PASSWORD_ERROR(11011, "密码校验失败"),FILE_EXISTS(11000, "文件已存在，请检查版本号"),/*** ---------------------------------------------------- 用户相关 ----------------------------------------------------*/PARENT_ID_CANNOT_SELF_OR_CHILD(12001, "父节点不能为自身或子节点"),/*** ---------------------------------------------------- minio相关 ----------------------------------------------------*/MINIO_BUCKET_NOT_EXISTS(1600, "文件服务器存储空间不存在"),MINIO_DOWNLOAD_ERROR(1601, "文件服务器下载文件失败"),MINIO_DELETE_ERROR(1602, "文件服务器删除文件失败"),/*** ---------------------------------------------------- 视频相关 ----------------------------------------------------*/VIDEO_NOT_FOUND(18001, "视频不存在"),/*** ---------------------------------------------------- 华丽的分割线 ----------------------------------------------------*/INVALID_OPERATION(9999, "illegal operation"),/*** 项目授权码 失效 98401*/AUTHORIZATION_CODE_OUT(98401, "项目授权码无效，请联系管理员授权"),/*** 项目授权码 为空 98401*/AUTHORIZATION_CODE_IS_NULL(98401, "项目暂未授权，请联系管理员授权"),/*** 项目授权码 无效*/AUTHORIZATION_CODE_ERROR(98500, "项目授权码无效，请联系管理员授权"),;/*** 错误码*/private final int code;/*** 错误信息*/private final String message;/*** 重写构造方法** @param code    异常码* @param message 异常消息*/ServiceCodeEnum(int code, String message) {this.code = code;this.message = message;}@Overridepublic int getCode() {return code;}@Overridepublic String getMessage() {return message;}@Overridepublic String getMessage(String... args) {if (args != null && args.length > 0) {return MessageFormatter.arrayFormat(message, args).getMessage();}return message;}}

ServiceCodeInterface.class

package com.cherry.common.result;/*** 错误码枚举*/
public interface ServiceCodeInterface {public int getCode();public String getMessage(String... args);public String getMessage();}

ServiceResponse.class

package com.cherry.common.result;import com.cherry.common.gosn.JSONFormatter;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;@Data
@ApiModel(description = "响应结果公共格式")
public class ServiceResponse<R> {/*** 状态码*/@ApiModelProperty("状态码")protected Integer status;/*** 结果载体*/@ApiModelProperty("结果载体")protected R data;/*** 描述*/@ApiModelProperty("结果描述")protected String message;public ServiceResponse() {this(null);}public ServiceResponse(R result) {this(result, ServiceCodeEnum.SUCCESS);}public ServiceResponse(R result, Integer status, String message) {this.status = status;this.data = result;this.message = message;}public ServiceResponse(R result, ServiceCodeInterface code) {this.status = code.getCode();this.data = result;this.message = code.getMessage();}/*** Construct a successful response with given object.** @return constructed server response*/public static <T> ServiceResponse<T> ofSuccess() {return new ServiceResponse<T>();}/*** Construct a successful response with given object.** @param result result object* @param <T>    type of the result* @return constructed server response*/public static <T> ServiceResponse<T> ofSuccess(T result) {return new ServiceResponse<T>(result);}/*** Construct a failed response with given exception.** @return constructed server response*/public static <T> ServiceResponse<T> ofFailure() {return new ServiceResponse<T>(null, ServiceCodeEnum.PARAM_ERROR);}/*** Construct a failed response with given exception.** @param code additional message of the failure* @return constructed server response*/public static <T> ServiceResponse<T> ofFailure(Integer code, String desc) {return new ServiceResponse<T>(null, code, desc);}/*** 重载** @param code* @param <T>* @return*/public static <T> ServiceResponse<T> ofFailure(ServiceCodeInterface code) {return new ServiceResponse<T>(null, code);}/*** Construct a failed response with given exception.** @param code cause of the failure* @param desc cause of the failure* @return constructed server response*/public static <T> ServiceResponse<T> ofFailure(T result, Integer code, String desc) {return new ServiceResponse<T>(result, code, desc);}/*** 重载** @param result* @param code* @param <T>* @return*/public static <T> ServiceResponse<T> ofFailure(T result, ServiceCodeInterface code) {return new ServiceResponse<T>(result, code);}@Overridepublic String toString() {return JSONFormatter.toJSON(this);}}

创建数据库

CREATE TABLE public.ftest (id int4 NOT NULL,geom postgis.geometry NULL,CONSTRAINT ftest_pkey PRIMARY KEY (id)
);

控制层:

import com.cherry.common.result.ServiceResponse;
import com.github.pagehelper.PageInfo;
import com.cherry.manager.entity.Ftest;
import com.cherry.manager.service.FtestService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.*;import java.util.Arrays;
import java.util.List;/*** (Ftest)表控制层** @since 2022-09-22 15:39:05*/
@Api(tags = "")
@RestController
@RequestMapping("ftest")
@CrossOrigin
public class FtestController {@AutowiredFtestService service;/*** 新增记录** @param entity 数据实体* @return 新增记录*/@ApiOperation(value = "新增记录", notes = "新增记录")@PostMapping(value = "/point", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Ftest> addPoint(@RequestBody @ApiParam("json格式对象") Ftest entity) {service.savePoint(entity);return ServiceResponse.ofSuccess(entity);}@ApiOperation(value = "新增记录", notes = "新增记录")@PostMapping(value = "/points", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Ftest> addPoints(@RequestBody @ApiParam("json格式对象") Ftest entity) {service.savePoints(entity);return ServiceResponse.ofSuccess(entity);}/*** 删除记录** @param ids ids* @return 删除结果*/@ApiOperation(value = "删除记录", notes = "删除记录")@DeleteMapping(value = "/{ids}", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Boolean> delete(@PathVariable("ids") @ApiParam(value = "删除的id", required = true) String... ids) {return ServiceResponse.ofSuccess(service.removeByIds(Arrays.asList(ids)));}/*** 修改记录** @param entity 数据实体* @return 新增结果*/@ApiOperation(value = "修改记录", notes = "修改记录")@PutMapping(value = "", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Boolean> update(@RequestBody @ApiParam(value = "json格式对象", required = true) Ftest entity) {return ServiceResponse.ofSuccess(service.updateEntityById(entity));}/*** 分页查询** @return*/@ApiOperation(value = "分页查询", notes = "分页查询")@GetMapping(value = "page/{current}/{pageSize}", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<PageInfo<Ftest>> page(@PathVariable("current") int current,@PathVariable("pageSize") int pageSize) {return ServiceResponse.ofSuccess( service.getPageInfo(current, pageSize));}/*** 查询列表** @return 搜索结果集*/@ApiOperation(value = "查询列表", notes = "查询列表")@GetMapping(value = "/list", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<List<Ftest>> list() {return ServiceResponse.ofSuccess(service.listEntity());}/*** 查询详情** @param id id* @return 查询结果*/@ApiOperation(value = "查询详情", notes = "查询详情")@GetMapping(value = "/info/{id}", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Ftest> info(@PathVariable("id") @ApiParam(value = "查询的ID", required = true) Integer id) {return ServiceResponse.ofSuccess(service.getEntityById(id));}/*** 根据id集合查询** @param ids* @return*/@ApiOperation(value = "根据id集合查询", notes = "根据id集合查询")@GetMapping(value = "/listByIds/{ids}", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<List<Ftest>> listByIds(@PathVariable("ids") @ApiParam(value = "查询的ID", required = true) String... ids) {return ServiceResponse.ofSuccess(service.listEntityByIds(Arrays.asList(ids)));}/*** 查找最近点位* @param lng* @param lat* @return*/@ApiOperation(value = "查找最近的点", notes = "查找最近的点")@GetMapping(value = "/getRecent/{lng}/{lat}", produces = MediaType.APPLICATION_JSON_VALUE)public ServiceResponse<Ftest> getRecent(@PathVariable("lng") @ApiParam(value = "经度", required = true) Double lng,@PathVariable("lat") @ApiParam(value = "纬度", required = true) Double lat) {return ServiceResponse.ofSuccess(service.selectRecentOne(lng,lat));}}

entity实体类

package com.cherry.manager.entity;import java.io.Serializable;import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.annotations.ApiModelProperty;
import lombok.*;
import lombok.experimental.Accessors;/*** (Ftest)实体类** @since 2022-09-22 15:50:00*/
@Data
@EqualsAndHashCode
@ToString(callSuper = true)
@Accessors(chain = true)
@AllArgsConstructor
@NoArgsConstructor
@TableName("ftest")
public class Ftest implements Serializable {private static final long serialVersionUID = 286631027980693537L;@ApiModelProperty(value = "${column.comment}")@TableField(value = "id")private Integer id;@ApiModelProperty(value = "${column.comment}")@TableField(value = "geom")private String geom;@ApiModelProperty(value = "点集合")@TableField(exist = false)private Point[] points;@ApiModelProperty(value = "点集合")@TableField(exist = false)private Point[][] linePoints;@ApiModelProperty(value = "geomObject")@TableField(value = "geomObject")private JSONObject geomObject;@ApiModelProperty("距离")@TableField(exist = false)private Double distance}

dao层

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.cherry.manager.entity.Ftest;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;import java.util.List;/*** (Ftest)表数据库访问层** @since 2022-09-22 15:39:05*/
@Mapper
public interface FtestDao extends BaseMapper<Ftest> {void savePoint(@Param("id") Integer id, @Param("points") String points);Boolean updateEntityById(@Param("id") Integer id, @Param("pointStr") String pointStr);List<Ftest> selectAll();Ftest getEntityById(@Param("id") Integer id);List<Ftest> listEntityByIds(@Param("ids") List<String> ids);IPage<Ftest> pageEntity(Page<Ftest> pageQuery);Ftest selectRecentOne(@Param("point") String point);
}

service接口层：

import com.baomidou.mybatisplus.extension.service.IService;
import com.cherry.manager.entity.Ftest;
import com.github.pagehelper.PageInfo;import java.util.List;/*** (Ftest)表服务接口** @since 2022-09-22 15:39:06*/
public interface FtestService extends IService<Ftest> {void savePoint(Ftest entity);void savePoints(Ftest entity);Boolean updateEntityById(Ftest entity);List<Ftest> listEntity();Ftest getEntityById(Integer id);List<Ftest> listEntityByIds(List<String> asList);PageInfo<Ftest> getPageInfo(int current, int pageSize);Ftest selectRecentOne(Double lng,Double lat);
}

serviceImpl层：

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cherry.manager.entity.Ftest;
import com.cherry.manager.dao.FtestDao;
import com.cherry.manager.entity.Point;
import com.cherry.manager.service.FtestService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;import java.util.Arrays;
import java.util.List;/*** (Ftest)表服务实现类** @since 2022-09-22 15:39:06*/
@Slf4j
@Service
public class FtestServiceImpl extends ServiceImpl<FtestDao, Ftest> implements FtestService {public String getPostgisPoint( Point[][] point){StringBuilder pointStr = new StringBuilder("SRID=4326;MULTILINESTRING(");Arrays.stream(point).forEach(e->{pointStr.append("(");for (int i=0;i<e.length;i++){pointStr.append(e[i].getLat()+" ");pointStr.append(e[i].getLng());if (i!=e.length-1){pointStr.append(",");}}pointStr.append("),");});pointStr.deleteCharAt(pointStr.length()-1);pointStr.append(")");return pointStr.toString();}@Overridepublic void savePoint(Ftest entity) {Point[] point = entity.getPoints();String pointStr = "SRID=4326;Point("+point[0].getLat()+" "+point[0].getLng()+")";this.baseMapper.savePoint(entity.getId(),pointStr);}@Overridepublic void savePoints(Ftest entity) {String pointStr = getPostgisPoint(entity.getLinePoints());log.info("-----------------"+pointStr+"----------------");this.baseMapper.savePoint(entity.getId(),pointStr);}@Overridepublic Boolean updateEntityById(Ftest entity) {String pointStr = getPostgisPoint(entity.getLinePoints());return this.baseMapper.updateEntityById(entity.getId(),pointStr);}@Overridepublic List<Ftest> listEntity() {List<Ftest> list = this.baseMapper.selectAll();list.stream().forEach(e->{e.setGeomObject(JSONObject.parseObject(e.getGeom()));});return list;}@Overridepublic Ftest getEntityById(Integer id) {Ftest ftest =  this.baseMapper.getEntityById(id);ftest.setGeomObject(JSONObject.parseObject(ftest.getGeom()));return ftest;}@Overridepublic List<Ftest> listEntityByIds(List<String> asList) {List<Ftest> list = this.baseMapper.listEntityByIds(asList);list.stream().forEach(e->{e.setGeomObject(JSONObject.parseObject(e.getGeom()));});return list;}@Overridepublic PageInfo<Ftest> getPageInfo(int current, int pageSize) {PageHelper.startPage(current,pageSize);List<Ftest> list = this.baseMapper.selectAll();list.stream().forEach(e->{e.setGeomObject(JSONObject.parseObject(e.getGeom()));});return new PageInfo<>(list);}@Overridepublic Ftest selectRecentOne(Double lng, Double lat) {String point = "Point("+lng+" "+lat+")";Ftest ftest = this.baseMapper.selectRecentOne(point);ftest.setGeomObject(JSONObject.parseObject(ftest.getGeom()));return ftest;}}

xml文件:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.cherry.manager.dao.FtestDao"><resultMap id="ftestMap" type="com.cherry.manager.entity.Ftest"><result property="id" column="id"/><result property="geom" column="geom"/></resultMap><insert id="savePoint">insert into ftest(id,geom) values(#{id},#{points})</insert><update id="updateEntityById">update ftest set geom = #{pointStr} where id = #{id};</update><select id="selectAll" resultType="com.cherry.manager.entity.Ftest">select id, postgis.st_asgeojson(geom) as geom  from ftest</select><select id="getEntityById" parameterType="integer" resultMap="ftestMap">select id, postgis.st_asgeojson(geom) as geom  from ftest where id = #{id}</select><select id="listEntityByIds" parameterType="integer" resultMap="ftestMap">select id, postgis.st_asgeojson(geom) as geom from ftest<if test=" ids!=null "><foreach collection="ids" open="where id in (" close=")" separator="," item="item">#{item}</foreach></if>order by id</select><select id="pageEntity" resultMap="ftestMap">select id, postgis.st_asgeojson(geom) as geom  from ftest</select><select id="selectRecentOne" resultType="com.cherry.manager.entity.Ftest">SELECT ID, postgis.st_asgeojson ( geom ) geom,postgis.ST_Distance ( postgis.st_geomfromtext ( #{point}, 4326 ), geom ) distanceFROM "ftest"ORDER BY distance ASC LIMIT 1</select>
</mapper>

springboot+mybatisplus+postgis实现几何点和线串增删改查分页相关推荐

springBoot加layui和mybatis后台管理系统增删改查分页登录注销修改密码功能
超市订单管理系统 1 登录页面 1.1 登录点击提交按钮提交form表单使用post请求把(String name, String password)数据传到后台loginController 路径 ...
SpringBoot+vue+jpa+mysql前后台分离实现增删改查分页和三级联动（附源码）（一）
数据库命名为:demo demo.sql内容如下: (可以直接运行demo.sql文件) /*Navicat Premium Data TransferSource Server : MysqlSou ...
springboot使用JdbcTemplate完成对数据库的增删改查
上一篇对springboot有一个简单的介绍以及使用一个简单的例子熟悉了一下springboot写法的简单流程.这一篇介绍springboot使用JdbcTemplate完成对数据库的增删改查. 首先 ...
servlet增删改查实例_SpringMVC4+MyBatis3+SQLServer 2014 整合（包括增删改查分页）
前言说起整合自然离不开ssm,我本身并不太喜欢ORM,尤其是MyBatis,把SQL语句写在xml里,尤其是大SQL,可读性不高,出错也不容易排查. 开发环境 idea2016.SpringMVC4 ...
复习JavaWeb的小项目书籍信息的增删改查分页功能实现Java面试题Session和Cookie的基础概念生活【记录一个咸鱼大学生三个月的奋进生活】034
记录一个咸鱼大学生三个月的奋进生活034 JavaWeb的增删改查分页功能实现前期准备工作(数据库连接类和实体类) 数据库建立数据库连接类(DBManager) 书籍信息的实体类(Book) 操作 ...
MyBatisPlus：实现DAO的增删改查分页+属性设置，代码生成器（代码模板）
1,MyBatisPlus入门案例与简介这一节我们来学习下MyBatisPlus的入门案例与简介,这个和其他课程都不太一样,其他的课程都是先介绍概念,然后再写入门案例.而对于MyBatisPlus的 ...
springboot/vue前后端分离后台管理系统增删改查
1.需求分析一个音乐管理系统包括: 1.用户信息管理:该模块主要由管理员进行操作,将所有用户的用户名.密码.邮箱.创建时间以及用户状态列在一张表,管理员可以进行增加.删除(批量删除).修改以及查询用 ...
基于SpringBoot开发一个Restful服务，实现增删改查功能
点击上方"方志朋",选择"置顶公众号" 技术文章第一时间送达! 作者:虚无境 cnblogs.com/xuwujing/p/8260935.html 前言在去 ...
Springboot使用JPA框架对数据库实现增删改查（附详细代码）
前言 1.本文将详细阐述如何使用JPA框架对数据库实现增删改查操作,业务中比较常见的应用场景几乎在这里都能看到,并且有详尽的代码可供直观演示,其中遇到的坑也进行了实时标注. 2.JPA的环境配置在前面 ...

springboot+mybatisplus+postgis实现几何点和线串增删改查分页

postgis类型介绍

实现点、线环的增删改查分页

springboot+mybatisplus+postgis实现几何点和线串增删改查分页相关推荐

最新文章

热门文章