Skip to main content
Version: 0.9

Cluster

Create a cluster

Please refer to Kubernetes to get the information about creating a Kubernetes cluster.

Distributed Read/Write

SQL

You can follow the steps to use SQL to play with distributed insertions and queries:

  1. Use MySQL cli to connect to Frontend.
 mysql -h 127.0.0.1 -P 4002
  1. Create a distributed table via CREATE statement.
 CREATE TABLE dist_table(
ts TIMESTAMP DEFAULT current_timestamp(),
n INT,
row_id INT,
PRIMARY KEY(n),
TIME INDEX (ts)
)
PARTITION ON COLUMNS (n) (
n < 5,
n >= 5 AND n < 9,
n >= 9
)
engine=mito;

The result looks like the following:

 mysql> CREATE TABLE dist_table(
-> ts TIMESTAMP DEFAULT current_timestamp(),
-> n INT,
-> row_id INT,
-> TIME INDEX (ts)
-> PRIMARY KEY(n),
-> )
-> PARTITION ON COLUMNS (n) (
-> n < 5,
-> n >= 5 AND n < 9,
-> n >= 9
-> )
-> engine=mito;
Query OK, 3 rows affected (0.09 sec)

The dist_table is distributed among the Datanodes. You can refer to "Table Sharding" for more details.

  1. Insert some data via INSERT statement.
 INSERT INTO dist_table(n, row_id) VALUES (1, 1);
INSERT INTO dist_table(n, row_id) VALUES (2, 2);
INSERT INTO dist_table(n, row_id) VALUES (3, 3);
INSERT INTO dist_table(n, row_id) VALUES (4, 4);
INSERT INTO dist_table(n, row_id) VALUES (5, 5);
INSERT INTO dist_table(n, row_id) VALUES (6, 6);
INSERT INTO dist_table(n, row_id) VALUES (7, 7);
INSERT INTO dist_table(n, row_id) VALUES (8, 8);
INSERT INTO dist_table(n, row_id) VALUES (9, 9);
INSERT INTO dist_table(n, row_id) VALUES (10, 10);
INSERT INTO dist_table(n, row_id) VALUES (11, 11);
INSERT INTO dist_table(n, row_id) VALUES (12, 12);
  1. Execute some queries via SELECT statement:
 SELECT * FROM dist_table ORDER BY n LIMIT 5;
 +---------------------+------+--------+
| ts | n | row_id |
+---------------------+------+--------+
| 2022-11-14 12:02:32 | 1 | 1 |
| 2022-11-14 12:02:32 | 2 | 2 |
| 2022-11-14 12:02:32 | 3 | 3 |
| 2022-11-14 12:02:32 | 4 | 4 |
| 2022-11-14 12:02:32 | 5 | 5 |
+---------------------+------+--------+
5 rows in set (0.081 sec)
 SELECT MAX(n) FROM dist_table;
 +-------------------+
| MAX(dist_table.n) |
+-------------------+
| 12 |
+-------------------+
1 row in set (0.057 sec)
 SELECT MIN(n) FROM dist_table;
 +-------------------+
| MIN(dist_table.n) |
+-------------------+
| 1 |
+-------------------+
1 row in set (0.079 sec)
 SELECT * FROM dist_table WHERE n > 2 AND n < 10 ORDER BY row_id;
 +---------------------+------+--------+
| ts | n | row_id |
+---------------------+------+--------+
| 2022-11-14 12:02:32 | 3 | 3 |
| 2022-11-14 12:02:32 | 4 | 4 |
| 2022-11-14 12:02:32 | 5 | 5 |
| 2022-11-14 12:02:32 | 6 | 6 |
| 2022-11-14 12:02:32 | 7 | 7 |
| 2022-11-14 12:02:32 | 8 | 8 |
| 2022-11-14 12:02:32 | 9 | 9 |
+---------------------+------+--------+
7 rows in set (0.02 sec)
 SELECT * FROM dist_table WHERE row_id = 10;
 +---------------------+------+--------+
| ts | n | row_id |
+---------------------+------+--------+
| 2022-11-14 12:02:32 | 10 | 10 |
+---------------------+------+--------+
1 row in set (0.03 sec)