本文源码: GitHub·点这里 || GitEE·点这里
创新互联专注于云霄网站建设服务及定制,我们拥有丰富的企业做网站经验。 热诚为您提供云霄营销型网站建设,云霄网站制作、云霄网页设计、云霄网站官网定制、重庆小程序开发服务,打造云霄网络公司原创品牌,更为您提供云霄网站排名全网营销落地服务。
PostgreSQL是一个功能强大的且开源关系型数据库系统,在网上PostgreSQL和MySQL一直有大量的对比分析。大多从性能,开源协议,SQL标准,开发难度等去比较,只要有比较就会有差距和差异,看看就好。
絮叨一句
:编程世界里的对比是一直存在的,但是无论对比结果如何,当业务需要的时候,该用还是要用。MySQL和PostgreSQL对比很少占上风,但是MySQL在国内的使用依旧广泛。
导入依赖包,版本会自动加载。本案例加载的是42.2.6版本号。
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
这里使用Druid连接池管理。
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource
druid:
driverClassName: org.postgresql.Driver
url: jdbc:postgresql://127.0.0.1:5432/db_01
username: root01
password: 123456
@Configuration
public class DruidConfig {
@Value("${spring.datasource.druid.url}")
private String dbUrl;
@Value("${spring.datasource.druid.username}")
private String username;
@Value("${spring.datasource.druid.password}")
private String password;
@Value("${spring.datasource.druid.driverClassName}")
private String driverClassName;
@Bean
public DruidDataSource dataSource() {
DruidDataSource datasource = new DruidDataSource();
datasource.setUrl(dbUrl);
datasource.setUsername(username);
datasource.setPassword(password);
datasource.setDriverClassName(driverClassName);
return datasource;
}
}
基于mybatis相关组件,在用法上和MySQL环境整合基本一致。
mybatis-plus:
mapper-locations: classpath*:/mapper/**/*.xml
typeAliasesPackage: com.post.gresql.*.entity
global-config:
db-config:
id-type: AUTO
field-strategy: NOT_NULL
logic-delete-value: -1
logic-not-delete-value: 0
banner: false
configuration:
map-underscore-to-camel-case: true
cache-enabled: false
call-setters-on-nulls: true
jdbc-type-for-null: 'null'
提供一个数据查询,写入,分页查的基础使用案例。
@Api(value = "UserController")
@RestController
public class UserController {
@Resource
private UserService userService ;
@GetMapping("/selectById")
public UserEntity selectById (Integer id){
return userService.selectById(id) ;
}
@PostMapping("/insert")
public Integer insert (UserEntity userEntity){
return userService.insert(userEntity) ;
}
@GetMapping("/pageQuery")
public PageInfo<UserEntity> pageQuery (@RequestParam("page") int page){
int pageSize = 3 ;
return userService.pageQuery(page,pageSize) ;
}
}
PostgreSQL支持JSON数据类型格式,但是在用法上与一般数据类型有差异。
这里字段user_list为JSON类型,存储场景第一批用户有哪些,第二批用户有哪些,依次类推。
CREATE TABLE pq_user_json (
ID INT NOT NULL,
title VARCHAR (32) NOT NULL,
user_list json NOT NULL,
create_time TIMESTAMP (6) DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT "user_json_pkey" PRIMARY KEY ("id")
);
定义一个数据库与实体对象的转换器,主要就是JSON数据和Java对象的转换。
@MappedTypes({Object.class})
public class JsonTypeHandler extends BaseTypeHandler<Object> {
private static final PGobject jsonObject = new PGobject();
@Override
public void setNonNullParameter(PreparedStatement ps, int i, Object parameter, JdbcType jdbcType) throws SQLException {
jsonObject.setType("json");
jsonObject.setValue(parameter.toString());
ps.setObject(i, jsonObject);
}
@Override
public Object getNullableResult(ResultSet rs, String columnName) throws SQLException {
return JSON.parseObject(rs.getString(columnName), Object.class);
}
@Override
public Object getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
return JSON.parseObject(rs.getString(columnIndex), Object.class);
}
@Override
public Object getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
return JSON.parseObject(cs.getString(columnIndex), Object.class);
}
}
指定字段的映射类型typeHandler即可。
<mapper namespace="com.post.gresql.mapper.UserJsonMapper" >
<insert id="addUserJson" parameterType="com.post.gresql.entity.UserJsonEntity">
INSERT INTO pq_user_json (id,title,user_list,create_time)
VALUES (#{id}, #{title}, #{userList, typeHandler=com.post.gresql.config.JsonTypeHandler}, #{createTime})
</insert>
</mapper>
JSON格式数据入库,出库查询。
@RestController
public class UserJsonController {
@Resource
private UserJsonService userJsonService ;
@GetMapping("/addUserJson")
public boolean addUserJson (){
List<UserEntity> userEntities = new ArrayList<>() ;
UserEntity userEntity1 = new UserEntity(1,"LiSi",22,new Date());
UserEntity userEntity2 = new UserEntity(2,"WangWu",23,new Date());
userEntities.add(userEntity1);
userEntities.add(userEntity2);
UserJsonEntity userJsonEntity = new UserJsonEntity();
userJsonEntity.setId(1);
userJsonEntity.setTitle("第一批名单");
userJsonEntity.setUserList(JSON.toJSONString(userEntities));
userJsonEntity.setCreateTime(new Date());
return userJsonService.addUserJson(userJsonEntity) ;
}
@GetMapping("/findUserJson")
public List<UserEntity> findUserJson (@RequestParam("id") Integer id){
UserJsonEntity userJsonEntity = userJsonService.findUserJson(id) ;
return JSON.parseArray(userJsonEntity.getUserList(),UserEntity.class) ;
}
}
GitHub·地址
https://github.com/cicadasmile/data-manage-parent
GitEE·地址
https://gitee.com/cicadasmile/data-manage-parent
推荐阅读:数据管理
序号 | 标题 |
---|---|
01 | 数据源管理:主从库动态路由,AOP模式读写分离 |
02 | 数据源管理:基于JDBC模式,适配和管理动态数据源 |
03 | 数据源管理:动态权限校验,表结构和数据迁移流程 |
04 | 数据源管理:关系型分库分表,列式库分布式计算 |
文章题目:数据源管理|PostgreSQL环境整合,JSON类型应用
文章转载:https://www.cdcxhl.com/article22/ipchjc.html
成都网站建设公司_创新互联,为您提供网站设计公司、网站排名、建站公司、网站维护、响应式网站、网站改版
声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联