MySQL :: MySQL 8.3 Reference Manual :: 25.3.5 NDB Cluster Example with Tables and Data

Documentation Home

version 8.3

8.0 current
5.7

8.0 Japanese

MySQL 8.3 Reference Manual / ... / NDB Cluster Example with Tables and Data

25.3.5 NDB 集群示例带表和数据

Note

本节信息适用于 Unix 和 Windows 平台上的 NDB 集群。

在 NDB 集群中使用数据库表和数据与在标准 MySQL 中的做法没有太大区别。需要注意两个关键点：

要使表在集群中复制，必须使用 NDBCLUSTER 存储引擎。在创建表时，使用 ENGINE=NDBCLUSTER 或 ENGINE=NDB 选项：
```
CREATE TABLE tbl_name (col_name column_definitions) ENGINE=NDBCLUSTER;
```
或者，对于使用不同存储引擎的现有表，使用 ALTER TABLE 将表更改为使用 NDBCLUSTER：
```
ALTER TABLE tbl_name ENGINE=NDBCLUSTER;
```
每个 NDBCLUSTER 表都有一个主键。如果用户在创建表时没有定义主键，NDBCLUSTER 存储引擎将自动生成一个隐藏的主键。这样的键将占用与其他表索引相同的空间。（经常会遇到由于自动创建的索引所需的内存不足的问题。）

如果您从现有数据库中导入表，使用 mysqldump 的输出，可以在文本编辑器中打开 SQL 脚本，并添加 ENGINE 选项到任何表创建语句中，或者替换现有的 ENGINE 选项。假设您有一个名为 world 的示例数据库，在不支持 NDB 集群的另一个 MySQL 服务器上，并且您想导出 City 表：

$> mysqldump --add-drop-table world City > city_table.sql

生成的 city_table.sql 文件将包含该表创建语句（以及用于导入表数据的 INSERT 语句）：

DROP TABLE IF EXISTS `City`;
CREATE TABLE `City` (
  `ID` int(11) NOT NULL auto_increment,
  `Name` char(35) NOT NULL default '',
  `CountryCode` char(3) NOT NULL default '',
  `District` char(20) NOT NULL default '',
  `Population` int(11) NOT NULL default '0',
  PRIMARY KEY  (`ID`)
) ENGINE=MyISAM;

INSERT INTO `City` VALUES (1,'Kabul','AFG','Kabol',1780000);
INSERT INTO `City` VALUES (2,'Qandahar','AFG','Qandahar',237500);
INSERT INTO `City` VALUES (3,'Herat','AFG','Herat',186800);
(remaining INSERT statements omitted)

您需要确保 MySQL 使用 NDBCLUSTER 存储引擎来创建该表。有两种方法可以实现这一点。其中一种是在将表导入集群数据库之前修改表定义。以 City 表为例，修改表定义的 ENGINE 选项如下：

DROP TABLE IF EXISTS `City`;
CREATE TABLE `City` (
  `ID` int(11) NOT NULL auto_increment,
  `Name` char(35) NOT NULL default '',
  `CountryCode` char(3) NOT NULL default '',
  `District` char(20) NOT NULL default '',
  `Population` int(11) NOT NULL default '0',
  PRIMARY KEY  (`ID`)
) ENGINE=NDBCLUSTER;

INSERT INTO `City` VALUES (1,'Kabul','AFG','Kabol',1780000);
INSERT INTO `City` VALUES (2,'Qandahar','AFG','Qandahar',237500);
INSERT INTO `City` VALUES (3,'Herat','AFG','Herat',186800);
(remaining INSERT statements omitted)

这必须对每个要包含在集群数据库中的表进行操作。最简单的方法是对包含定义的文件执行搜索和替换，将所有 TYPE=engine_name 或 ENGINE=engine_name 实例替换为 ENGINE=NDBCLUSTER。如果您不想修改文件，可以使用未修改的文件创建表，然后使用 ALTER TABLE 更改存储引擎。详细信息将在本节后面提供。

假设您已经在集群的 SQL 节点上创建了名为 world 的数据库，可以使用 mysql 命令行客户端读取 city_table.sql，并以通常方式创建和填充对应的表：

$> mysql world < city_table.sql

请注意，前面的命令必须在 SQL 节点所在的主机上执行（在本例中，是 IP 地址为 198.51.100.20 的机器上）。

要创建整个 world 数据库的副本在 SQL 节点上，使用 mysqldump 在非集群服务器上导出数据库到名为 world.sql 的文件中（例如，在 /tmp 目录中）。然后，按照前面所述修改表定义，并将文件导入集群的 SQL 节点，如下所示：

$> mysql world < /tmp/world.sql

如果您将文件保存到不同的位置，请相应地调整前面的说明。

在 SQL 节点上运行 SELECT 查询与在任何其他 MySQL 服务器实例上运行它们没有什么不同。要从命令行运行查询，首先需要以通常的方式登录到 MySQL 监视器（在 Enter password: 提示符下指定 root 密码）：

$> mysql -u root -p
Enter password:
Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 1 to server version: 8.3.0-ndb-8.3.0

Type 'help;' or '\h' for help. Type '\c' to clear the buffer.

mysql>

我们只是使用 MySQL 服务器的 root 帐户，并假设您已经遵循了安装 MySQL 服务器的标准安全预防措施，包括设置强的 root 密码。有关更多信息，请参阅第 2.9.4 节，“保护初始 MySQL 帐户”。

值得注意的是，NDB 集群节点在相互访问时不使用 MySQL 权限系统。设置或更改 MySQL 用户帐户（包括 root 帐户）仅影响访问 SQL 节点的应用程序，而不影响节点之间的交互。有关更多信息，请参阅第 25.6.21.2 节，“NDB 集群和 MySQL 权限”。

如果您在导入 SQL 脚本之前没有修改表定义中的 ENGINE 子句，现在应该运行以下语句：

mysql> USE world;
mysql> ALTER TABLE City ENGINE=NDBCLUSTER;
mysql> ALTER TABLE Country ENGINE=NDBCLUSTER;
mysql> ALTER TABLE CountryLanguage ENGINE=NDBCLUSTER;

选择数据库并运行 SELECT 查询对该数据库中的表也是以通常的方式完成的，如同退出 MySQL 监视器一样：

mysql> USE world;
mysql> SELECT Name, Population FROM City ORDER BY Population DESC LIMIT 5;
+-----------+------------+
| Name      | Population |
+-----------+------------+
| Bombay    |   10500000 |
| Seoul     |    9981619 |
| São Paulo |    9968485 |
| Shanghai  |    9696300 |
| Jakarta   |    9604900 |
+-----------+------------+
5 rows in set (0.34 sec)

mysql> \q
Bye

$>

使用 MySQL 的应用程序可以使用标准 API 访问 NDB 表。重要的是记住，您的应用程序必须访问 SQL 节点，而不是管理或数据节点。这是一个简短的示例，展示了如何使用 PHP 5.X mysqli 扩展在网络上的其他 Web 服务器上执行刚刚显示的 SELECT 语句：

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
  "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
  <meta http-equiv="Content-Type"
           content="text/html; charset=iso-8859-1">
  <title>SIMPLE mysqli SELECT</title>
</head>
<body>
<?php
  # connect to SQL node:
  $link = new mysqli('198.51.100.20', 'root', 'root_password', 'world');
  # parameters for mysqli constructor are:
  #   host, user, password, database

  if( mysqli_connect_errno() )
    die("Connect failed: " . mysqli_connect_error());

  $query = "SELECT Name, Population
            FROM City
            ORDER BY Population DESC
            LIMIT 5";

  # if no errors...
  if( $result = $link->query($query) )
  {
?>
<table border="1" width="40%" cellpadding="4" cellspacing ="1">
  <tbody>
  <tr>
    <th width="10%">City</th>
    <th>Population</th>
  </tr>
<?
    # then display the results...
    while($row = $result->fetch_object())
      printf("<tr>\n  <td align=\"center\">%s</td><td>%d</td>\n</tr>\n",
              $row->Name, $row->Population);
?>
  </tbody
</table>
<?
  # ...and verify the number of rows that were retrieved
    printf("<p>Affected rows: %d</p>\n", $link->affected_rows);
  }
  else
    # otherwise, tell us what went wrong
    echo mysqli_error();

  # free the result set and the mysqli connection object
  $result->close();
  $link->close();
?>
</body>
</html>

我们假设在 Web 服务器上运行的进程可以访问 SQL 节点的 IP 地址。

类似地，您可以使用 MySQL C API、Perl-DBI、Python-mysql 或 MySQL 连接器来执行数据定义和操作任务，就像您通常使用 MySQL 一样。

PREV HOME UP NEXT