快速入门

-- 使用 MySQL 标准语法创建表结构示例
mysql> CREATE TABLE t1(c1 int, c2 int, c3 int);
Query OK, 0 rows affected (0.08 sec)

-- 使用 MySQL 标准语法写入数据示例
mysql> INSERT INTO t1 VALUES (1, 1, 1), (2, 2, 2), (3, 3, 3);
Query OK, 3 rows affected (0.03 sec)

-- 使用 MySQL 标准语法进行数据的查询示例
mysql> SELECT * FROM t1;
+------+------+------+
| c1   | c2   | c3   |
+------+------+------+
|    1 |    1 |    1 |
|    2 |    2 |    2 |
|    3 |    3 |    3 |
+------+------+------+
3 rows in set (0.02 sec)

# 使用标准的 OpenSearch API 接口进行数据检索，如 match 全文检索示例和向量检索示例
curl -X POST "http://opensearch-host:9200/my_index/_search?size=10" \\
  -u "admin:password" \\
  -H "Accept: application/json" \\
  -H "Content-Type: application/json" \\
  -d '{
    "query": {
      "match": { "name": "Alice" }
    }
  }'

curl -X POST "http://opensearch-host:9200/my_index/_search?size=10" \\
  -u "admin:password" \\
  -H "Accept: application/json" \\
  -H "Content-Type: application/json" \\
  -d '{
    "query": {
      "knn": {
        "embedding": {
          "vector": [0.12, -0.03, 0.45, 0.88, 0.21],
          "k": 10
        }
      }
    }
  }' 

-- 使用标准的 MySQL 语法进行复杂分析查询，如 TPC-H Q1 示例（SF=100G）
mysql> SELECT
    ->     l_returnflag,
    ->     l_linestatus,
    ->     SUM(l_quantity) AS sum_qty,
    ->     SUM(l_extendedprice) AS sum_base_price,
    ->     SUM(l_extendedprice * (1 - l_discount)) AS sum_disc_price,
    ->     SUM(l_extendedprice * (1 - l_discount) * (1 + l_tax)) AS sum_charge,
    ->     AVG(l_quantity) AS avg_qty,
    ->     AVG(l_extendedprice) AS avg_price,
    ->     AVG(l_discount) AS avg_disc,
    ->     COUNT(*) AS count_order
    -> FROM lineitem
    -> WHERE l_shipdate <= DATE '1998-12-01' - INTERVAL '90' DAY
    -> GROUP BY l_returnflag, l_linestatus
    -> ORDER BY l_returnflag, l_linestatus;
+--------------+--------------+---------------+-------------------+---------------------+-----------------------+--------------------+--------------------+----------------------+-------------+
| l_returnflag | l_linestatus |       sum_qty |    sum_base_price |      sum_disc_price |            sum_charge |            avg_qty |          avg_price |             avg_disc | count_order |
+--------------+--------------+---------------+-------------------+---------------------+-----------------------+--------------------+--------------------+----------------------+-------------+
| A            | F            | 3775127758.00 |  5660776097194.45 |  5377736398183.9374 |  5592847429515.927026 | 25.499370423275426 |  38236.11698430489 | 0.050002243530929025 |   148047881 |
| N            | F            |   98553062.00 |   147771098385.98 |   140384965965.0348 |  145999793032.775829  | 25.501556956882876 |   38237.1993888045 |  0.04998528433805397 |     3864590 |
| N            | O            | 7436302976.00 | 11150725681373.59 | 10593195308234.8523 | 11016932248183.655467 | 25.500009404374193 |  38237.227646360945|  0.04999791831562552 |   291619617 |
| R            | F            | 3775724970.00 |  5661603032745.34 |  5378513563915.4097 |  5593662252666.916161 |  25.50006628406532 |  38236.697258452965|  0.05000130433965413 |   148067261 |
+--------------+--------------+---------------+-------------------+---------------------+-----------------------+--------------------+--------------------+----------------------+-------------+
4 rows in set (0.123 sec)

-- 使用 MySQL 兼容协议 + Nexa 联邦扩展语法：在搜索引擎全文检索 "wireless" 相关商品 → 到分析引擎聚合明细算收入 → 到核心引擎取实时订单状态，一次 SQL 完成三引擎协同
mysql> SELECT
    ->     o.order_id,
    ->     o.status,
    ->     p.title,
    ->     p.category,
    ->     SUM(li.quantity) AS qty,
    ->     SUM(li.price * li.quantity * (1 - li.discount)) AS revenue,
    ->     p._score
    -> FROM analyze_engine.main.lineitem li
    -> JOIN mysql_engine.shop.orders o
    ->      ON o.order_id = li.order_id
    -> JOIN opensearch_query(
    ->          index   := 'products',
    ->          catalog := 'search_engine',
    ->          query   := '{"match": {"title": "wireless"}}'
    ->      ) p
    ->      ON p.product_id = li.product_id
    -> WHERE o.order_date >= DATE '2026-09-01'
    -> GROUP BY o.order_id, o.status, p.title, p.category, p._score
    -> ORDER BY p._score DESC;
+----------+---------+-------------------------------+-------------+-----+----------+--------+
| order_id | status  | title                         | category    | qty | revenue  | _score |
+----------+---------+-------------------------------+-------------+-----+----------+--------+
|     1001 | PAID    | Wireless Mouse Pro            | electronics |   2 |  1198.00 |   2.85 |
|     1001 | PAID    | Wireless Mechanical Keyboard  | electronics |   1 |   720.00 |   2.12 |
|     1004 | SHIPPED | Wireless Gaming Headset       | electronics |   2 |  2400.00 |   1.98 |
+----------+---------+-------------------------------+-------------+-----+----------+--------+
3 rows in set (0.42 sec)