数据源管理 | PostgreSQL环境整合，JSON类型应用

一、PostgreSQL简介

1、和MySQL的比较

PostgreSQL是一个功能强大的且开源关系型数据库系统，在网上PostgreSQL和MySQL一直有大量的对比分析。大多从性能，开源协议，SQL标准，开发难度等去比较，只要有比较就会有差距和差异，看看就好。

絮叨一句：编程世界里的对比是一直存在的，但是无论对比结果如何，当业务需要的时候，该用还是要用。MySQL和PostgreSQL对比很少占上风，但是MySQL在国内的使用依旧广泛。

2、PostgreSQL特性

• 多副本同步复制，满足金融级可靠性要求；
• 支持丰富的数据类型，除了常见基础的，还包括文本，图像，声音，视频，JSON等；
• 自带全文搜索功能，可以简化搜索功能实现流程；
• 高效处理图结构, 轻松实现"朋友的朋友的朋友"关系类型；
• 地理信息处理扩展，支持地图寻路相关业务；

二、开发环境整合

1、基础依赖

导入依赖包，版本会自动加载。本案例加载的是42.2.6版本号。

<code>
<
dependency
>

    
<
groupId
>
org.postgresql
groupId
>

    
<
artifactId
>
postgresql
artifactId
>

dependency
>
/<code>

2、核心配置文件

这里使用Druid连接池管理。

<code>
spring
:
  
datasource
:
    
type
: com.alibaba.druid.pool.DruidDataSource
    
druid
:
      
driverClassName 
: org.postgresql.Driver
      
url
: 
jdbc
:
postgresql
: 
      
username
: root01
      
password
: 
123456
/<code>

3、连接池配置

<code> 
public
 
class
 
DruidConfig
 
{

     
    
private
 String dbUrl;
     
    
private
 String username;
     
    
private
 String password;
     
    
private
 String driverClassName;

     
    
public
 DruidDataSource dataSource() {
        DruidDataSource datasource = new DruidDataSource();
        datasource.setUrl(dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);
        
return
 datasource;
    }
}/<code>

4、持久层配置

基于mybatis相关组件，在用法上和MySQL环境整合基本一致。

<code>
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'
/<code>

5、基础测试案例

提供一个数据查询，写入，分页查的基础使用案例。

<code> 
 
public
 
class
 
UserController
 
{

     
    
private
 UserService userService ;

     
    
public
 UserEntity selectById (Integer id){
        
return
 userService.selectById(id) ;
    }

     
    
public
 Integer insert (UserEntity userEntity){
        
return
 userService.insert(userEntity) ;
    }

     
    
public
 PageInfo pageQuery (  int page){
        int pageSize = 
3
 ;
        
return
 userService.pageQuery(page,pageSize) ;
    }
}/<code>

三、JSON类型使用

PostgreSQL支持JSON数据类型格式，但是在用法上与一般数据类型有差异。

1、Json表字段创建

这里字段user_list为JSON类型，存储场景第一批用户有哪些，第二批用户有哪些，依次类推。

<code>
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"
)
);/<code>

2、类型转换器

定义一个数据库与实体对象的转换器，主要就是JSON数据和Java对象的转换。

<code> ({Object
.
class 
})
public
 
class
 
JsonTypeHandler
 
extends
 
BaseTypeHandler
<
Object
> 
{

    
private
 
static
 
final
 PGobject jsonObject = 
new
 PGobject();

     
    
public
 
void
 
setNonNullParameter
(PreparedStatement ps, 
int
 i, Object parameter, JdbcType jdbcType)
 
throws
 SQLException 
{
        jsonObject.setType(
"json"
);
        jsonObject.setValue(parameter.toString());
        ps.setObject(i, jsonObject);
    }

     
    
public
 Object 
getNullableResult
(ResultSet rs, String columnName)
 
throws
 SQLException 
{
        
return 
 JSON.parseObject(rs.getString(columnName), Object
.
class
)
;
    }

     
    
public
 Object 
getNullableResult
(ResultSet rs, 
int
 columnIndex)
 
throws
 SQLException 
{
        
return
 JSON.parseObject(rs.getString(columnIndex), Object
.
class
)
;
    }

     
    
public
 Object 
getNullableResult
(CallableStatement cs, 
int
 columnIndex)
 
throws
 SQLException 
{
        
return
 JSON.parseObject(cs.getString(columnIndex), Object
.
class
)
;
    }
}/<code>

3、调用方法

指定字段的映射类型typeHandler即可。

<code>
< 
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
>
/<code>

4、JSON格式测试

JSON格式数据入库，出库查询。

<code> 
public
 
class
 UserJsonController {

     
    
private
 UserJsonService userJsonService ;

     (
"/addUserJson"
)
    
public
 
boolean
 addUserJson (){
        List 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) ;
    }

     (
"/findUserJson"
)
    
public
 List findUserJson ( (
"id"
) Integer id){
        UserJsonEntity userJsonEntity = userJsonService.findUserJson(id) ;
        
return
 
JSON
.parseArray(userJsonEntity.getUserList(),UserEntity.class) ;
    }
}/<code>

推荐关联阅读：

数据源管理 | 基于JDBC模式，适配和管理动态数据源

数据源管理 | 动态权限校验，表结构和数据迁移流程

数据源管理 | 主从库动态路由，AOP模式读写分离

数据源管理 | 关系型分库分表，列式库分布式计算

专栏

微服务架构实战

作者：知了一笑

9.9币

10人已购

查看