欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Mycat,实践篇 - 基于 PostgreSQL

程序员文章站 2022-04-08 19:41:41
...

  写在前面

  Mycat作为独立的数据库中间件,我们只需要进行相关的配置,就可以非常方便的帮我们实现水平切分、垂直切分、读写分离等功能,但PostgreSQL的主从复制需要我们通过其它方式实现。这里假设我们已经搭建好相关的环境,下面就开始我们的实践吧!

  准备环境

  PostgreSQL(Version : 10.1)主从环境搭建对应数据库建立(以下例子中使用的都是默认存在的postgres数据库,可以不用额外添加)

  配置server.xml

  

  postgresmycat

  postgresmycats

  

  配置schema.xml

  

  

  

  

  

  

  

  

  select user

  

  

  

  

  

  select user

  

  

  

  

  dbDriver 属性

  指定连接后端数据库使用的 Driver,目前可选的值有 native 和 jdbc。使用 native 的话,因为这个值执行的

  是二进制的 mysql 协议,所以可以使用 mysql 和 maridb。其他类型的数据库则需要使用 JDBC 驱动来支持

  引述《Mycat权威指南》里面的原话:

  从 1.6 版本开始支持 postgresql 的 native 原始协议。

  如果使用 JDBC 的话需要将符合 JDBC4 标准的驱动 JAR 包放到 MYCAT\lib 目录下,并检查驱动 JAR 包中

  包括如下目录结构的文件:META-INF\services\java.sql.Driver。在这个文件内写上具体的 Driver 类名,例如:

  com.mysql.jdbc.Driver。

  所以,具体的解决方案就是找一个postgresql的jar包,然后丢到mycat的lib目录下,不然就会出现启动失败或者连接不到postgre数据库的异常情况。本例中用到的jar包是:postgresql-42.1.4.jar

  配置rule.xml

  

  

  id

  mod-long

  

  

  

  

  user_id

  mod-long

  

  

  

  2

  

  修改了配置文件后,别忘了重启Mycat,如果有异常出现,请通过查看logs目录下的日志文件进行排查。

  项目搭建(SpringBoot + JPA)

  准备:首次建表,设置application.yml中的spring.jpa.hibernate.ddl-auto属性为:create(JPA自动建表解决方案,使用update的话在连接mycat的时候会报找不到表的错误)。之后似乎必须更改为:none,否则使用其它属性都会报错(这里Mysql与PostgreSQL不同,似乎是一个未解决的bug,这也就意味着以后新增字段都要手动连上数据库进行添加了...)添加application.yml(注意了,这里都是用连mysql的方式去配置,Mycat会在后端做好对其它数据库的连接):

  spring:

  jpa:

  show-sql: true

  hibernate:

  ddl-auto: update

  naming:

  strategy: org.hibernate.cfgprovedNamingStrategy

  properties:

  hibernate:

  dialect: org.hibernate.dialect.MySQL5Dialect

  datasource:

  url: jdbc:mysql://localhost:8066/postgresmycats?characterEncoding=UTF-8&useSSL=false&autoReconnect=true&rewriteBatchedStatements=true

  username: postgresmycat

  password: postgresmycat

  添加User Entity

  @Entity

  @Table(name="tb_user")

  @Data

  public class User {

  @Id

  private Long id;

  private String name;

  private Integer gender;

  }

  添加Student Entity

  @Entity

  @Table(name="tb_student")

  @Data

  public class Student {

  @Id

  private Long id;

  private String name;

  @Column(unique=true)

  private Long userId;

  }

  添加UserDao

  public interface UserDao extends JpaRepository {

  Page findByNameLike(String name, Pageable pageable);

  }

  添加StudentDao

  public interface StudentDao extends JpaRepository {

  Page findByNameLike(String name, Pageable pageable);

  }

  项目测试

  测试添加

  @Test

  public void testAdd() {

  for (long i=0; i

  User user=new User();

  user.setId(i);

  user.setName("李四" + i);

  user.setGender(i % 2==0 ? 1 : 0);

  userDao.save(user);

  Student student=new Student();

  student.setId(System.currentTimeMillis() + i);

  student.setName("李四学生" + i);

  student.setUserId(i);

  studentDao.save(student);

  }

  }

  测试结果:数据按id取模的方式划分到了游戏账号两个数据库中,同时从库同步了主库的数据

  测试模糊查询+分页

  @Test

  public void testFind() {

  Pageable pageable=new PageRequest(0, 10, Sort.Direction.ASC, "id");

  List userList=userDao.findByNameLike("%李四1%", pageable).getContent();

  userList.forEach(System.out::println);

  Pageable pageable2=new PageRequest(0, 10, Sort.Direction.ASC, "userId");

  List studentList=studentDao.findByNameLike("%李四学生2%", pageable2).getContent();

  studentList.forEach(System.out::println);

  }

  测试结果:按照模糊匹配及id升序的方式输出结果

  测试结果:读操作都走了从库

  删除及修改请自行测试