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

Documentation Home

version 8.4

8.0 current
5.7

8.0 Japanese

MySQL 8.4 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存储引擎将自动生成一个隐藏的主键。这种键占用空间与其他表索引相同。（在遇到由于内存不足无法 accommodate 这些自动创建的索引时，可能会出现问题。）

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

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

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

$> mysql world < city_table.sql

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

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

$> mysql world < /tmp/world.sql

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

在 SQL 节点上运行SELECT查询与在任何其他 MySQL 服务器实例上运行它们没有区别。要从命令行运行查询，您首先需要按照通常的方式登录到 MySQL Monitor（指定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.4.0-ndb-8.4.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 Monitor：

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

$>

可以使用标准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 Connectors来执行数据定义和操作任务，就像您通常使用MySQL一样。

PREV HOME UP NEXT