一文详解如何在Mycat中配置多个Schema_Mysql

前言

在分布式数据库架构中，mycat 作为一个中间件，提供了强大的数据分片和路由能力。它能够帮助我们实现数据库的水平扩展，提高系统的性能和可用性。本文将详细介绍如何在 mycat 中配置多个 schema，以满足不同业务模块的数据隔离需求。

什么是schema

在数据库中，schema 是一个逻辑容器，用于组织和分类相关的数据库对象（如表、视图、索引等）。通过使用不同的 schema，可以实现数据的逻辑隔离，便于管理和维护。

mycat简介

mycat 是一个开源的分布式数据库系统，它的设计理念是“数据库中间件”，位于应用层和数据库层之间。mycat 可以帮助开发者轻松地实现读写分离、分库分表等高级功能，而无需对应用程序进行大规模改造。

多schema配置步骤

1. 安装mycat

首先，确保你已经安装了 mycat。你可以从 mycat 的官方 github 仓库下载最新版本，并按照官方文档进行安装。

2. 配置schema.xml

schema.xml 文件是 mycat 的核心配置文件之一，用于定义数据库的逻辑结构。我们需要在这个文件中添加多个 schema 的配置。

示例配置

假设我们有两个数据库 db1 和 db2，分别对应两个 schema schema1 和 schema2。

<?xml version="1.0" encoding="utf-8"?>
<!doctype mycat:schema system "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
 
    <!-- 配置schema1 -->
    <schema name="schema1" checksqlschema="false" sqlmaxlimit="100">
        <table name="user" datanode="dn1" rule="auto-sharding-long"/>
    </schema>
 
    <!-- 配置schema2 -->
    <schema name="schema2" checksqlschema="false" sqlmaxlimit="100">
        <table name="order" datanode="dn2" rule="auto-sharding-long"/>
    </schema>
 
    <!-- 配置datanode -->
    <datanode name="dn1" datahost="host1" database="db1"/>
    <datanode name="dn2" datahost="host2" database="db2"/>
 
    <!-- 配置datahost -->
    <datahost name="host1" maxcon="1000" mincon="10" balance="1"
              writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="host1-1" url="192.168.1.1:3306" user="root" password="password"/>
    </datahost>
 
    <datahost name="host2" maxcon="1000" mincon="10" balance="1"
              writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="host2-1" url="192.168.1.2:3306" user="root" password="password"/>
    </datahost>
 
</mycat:schema>

3. 配置server.xml

server.xml 文件用于配置 mycat 的全局参数，包括用户认证、系统属性等。

示例配置

<?xml version="1.0" encoding="utf-8"?>
<!doctype mycat:server system "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
 
    <system>
        <property name="defaultsqllimit">100</property>
    </system>
 
    <user name="test">
        <property name="password">test</property>
        <property name="schemas">schema1,schema2</property>
    </user>
 
</mycat:server>

4. 启动mycat

完成上述配置后，启动 mycat 服务。

./mycat start

5. 测试连接

使用 mysql 客户端连接到 mycat，并测试多 schema 的配置是否成功。

mysql -h127.0.0.1 -p8066 -utest -ptest

切换schema

use schema1;
show tables;
 
use schema2;
show tables;

通过以上步骤，我们成功地在 mycat 中配置了多个 schema。这样，不同的业务模块可以使用不同的 schema 进行数据隔离，提高了系统的可维护性和安全性。

方法补充

1. 环境准备

假设我们有两个 mysql 数据库实例：

- `db1`：ip 地址 `192.168.1.101`，端口 `3306`
- `db2`：ip 地址 `192.168.1.102`，端口 `3306`

每个数据库中都有一个名为 `test` 的 schema，包含一个表 `user`。

2. mycat 配置文件

mycat 的主要配置文件包括 `schema.xml`、`server.xml` 和 `rule.xml`。我们将重点介绍 `schema.xml` 和 `rule.xml`。

2.1 schema.xml

<?xml version="1.0" encoding="utf-8"?>
<!doctype mycat:schema system "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
 
    <!-- 定义全局表 -->
    <table name="global_table" datanode="dn1,dn2" rule="none"/>
 
    <!-- 定义分片表 -->
    <table name="user" datanode="dn1,dn2" rule="mod-long"/>
 
    <!-- 定义数据节点 -->
    <datanode name="dn1" datahost="host1" database="test"/>
    <datanode name="dn2" datahost="host2" database="test"/>
 
    <!-- 定义数据主机 -->
    <datahost name="host1" maxcon="1000" mincon="10" balance="1" writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="host1_1" url="192.168.1.101:3306" user="root" password="password"/>
    </datahost>
 
    <datahost name="host2" maxcon="1000" mincon="10" balance="1" writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="host2_1" url="192.168.1.102:3306" user="root" password="password"/>
    </datahost>
 
</mycat:schema>

2.2 rule.xml

<?xml version="1.0" encoding="utf-8"?>
<!doctype mycat:rule system "rule.dtd">
<mycat:rule xmlns:mycat="http://io.mycat/">
 
    <!-- 定义分片规则 -->
    <tablerule name="mod-long">
        <rule>
            <columns>id</columns>
            <algorithm>mod-long</algorithm>
        </rule>
    </tablerule>
 
    <!-- 定义分片算法 -->
    <function name="mod-long" class="io.mycat.route.function.partitionbymod">
        <property name="count">2</property>
    </function>
 
</mycat:rule>

3. 解释

schema.xml:

<table> 标签定义了表的分片规则和数据节点。
name="user" 表示表名。
datanode="dn1,dn2" 表示该表的数据分布在 dn1 和 dn2 两个数据节点上。
rule="mod-long" 表示使用 mod-long 分片规则。
<datanode> 标签定义了数据节点，指定了数据库实例的连接信息。
<datahost> 标签定义了数据主机，指定了心跳检测语句和写入主机的连接信息。

rule.xml:

<tablerule> 标签定义了表的分片规则。
<function> 标签定义了分片算法，这里使用的是 partitionbymod 算法，按 id 列的值取模分片。

4. 测试

启动 mycat 后，可以通过以下 sql 语句测试配置是否生效：

-- 插入数据
insert into user (id, name) values (1, 'alice');
insert into user (id, name) values (2, 'bob');
 
-- 查询数据
select * from user;

根据 mod-long 分片规则，id 为 1 的记录会插入到 db1，id 为 2 的记录会插入到 db2。

通过上述配置，mycat 可以将 user 表的数据分片到两个不同的数据库实例中，实现了数据的水平扩展和负载均衡。希望这个示例对你有所帮助！

mycat 是一个开源的分布式数据库系统，它支持多种数据库后端（如 mysql、postgresql 等），并提供了强大的 sql 解析和路由功能。在 mycat 中，多 schema 配置允许用户在一个 mycat 实例中管理多个逻辑数据库（即 schema）。这种配置对于需要跨多个物理数据库进行操作的应用非常有用。

多 schema 配置的基本概念

schema: 在 mycat 中，schema 是逻辑上的数据库，可以对应到一个或多个物理数据库。
table: 每个 schema 下可以定义多个表，这些表可以映射到不同的物理数据库表。
datanode: datanode 是物理数据库的实例，通常由一个数据库地址和一个数据库名组成。
datasource: datasource 是连接到物理数据库的具体配置，包括用户名、密码等信息。

配置文件

mycat 的配置主要通过几个 xml 文件来完成，其中最重要的文件是 schema.xml 和 server.xml。

1. schema.xml

schema.xml 文件用于定义 schema、table 和 datanode 的关系。

<?xml version="1.0"?>
<!doctype mycat:schema system "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
 
    <!-- 定义第一个 schema -->
    <schema name="db1" checksqlschema="false" sqlmaxlimit="100">
        <table name="user" datanode="dn1" rule="auto-sharding-long"/>
    </schema>
 
    <!-- 定义第二个 schema -->
    <schema name="db2" checksqlschema="false" sqlmaxlimit="100">
        <table name="order" datanode="dn2" rule="mod-long"/>
    </schema>
 
    <!-- 定义 datanode -->
    <datanode name="dn1" datahost="host1" database="db1" />
    <datanode name="dn2" datahost="host2" database="db2" />
 
    <!-- 定义 datahost -->
    <datahost name="host1" maxcon="1000" mincon="10" balance="1"
              writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="hostm1" url="localhost:3306" user="root" password="root"/>
    </datahost>
 
    <datahost name="host2" maxcon="1000" mincon="10" balance="1"
              writetype="0" dbtype="mysql" dbdriver="native" switchtype="1" slavethreshold="100">
        <heartbeat>select user()</heartbeat>
        <writehost host="hostm2" url="localhost:3307" user="root" password="root"/>
    </datahost>
 
</mycat:schema>

2. server.xml

server.xml 文件主要用于配置 mycat 的全局属性，如系统参数、用户权限等。

<?xml version="1.0" encoding="utf-8"?>
<!doctype mycat:server system "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
 
    <!-- 系统参数配置 -->
    <system>
        <property name="defaultsqlparser">druidparser</property>
        <property name="usesqlstat">1</property>
        <property name="useglobletablecheck">0</property>
    </system>
 
    <!-- 用户权限配置 -->
    <user name="test">
        <property name="password">test</property>
        <property name="schemas">db1,db2</property>
    </user>
 
</mycat:server>

关键配置说明

schema 定义:

<schema> 标签定义了一个逻辑数据库，name 属性指定了 schema 的名称。
<table> 标签定义了 schema 中的表，name 属性指定了表的名称，datanode 属性指定了该表所在的 datanode。

datanode 定义:

<datanode> 标签定义了一个物理数据库实例，name 属性指定了 datanode 的名称，datahost 属性指定了 datahost 的名称，database 属性指定了物理数据库的名称。

datahost 定义:

<datahost> 标签定义了一个物理数据库主机，name 属性指定了 datahost 的名称，maxcon 和 mincon 属性分别指定了最大和最小连接数，balance 属性指定了负载均衡策略，writetype 属性指定了写操作的类型，dbtype 和 dbdriver 属性指定了数据库类型和驱动。
<writehost> 标签定义了具体的写操作主机，host 属性指定了主机名称，url 属性指定了数据库连接 url，user 和 password 属性指定了数据库的用户名和密码。
用户权限配置:
<user> 标签定义了一个用户，name 属性指定了用户名，password 属性指定了用户密码，schemas 属性指定了用户可以访问的 schema。

示例应用

假设你有一个应用需要访问两个数据库 db1 和 db2，其中 db1 包含 user 表，db2 包含 order 表。你可以通过上述配置将这两个数据库整合到一个 mycat 实例中，并通过 mycat 提供统一的访问接口。