詳解MySQL?Shell?運行?SQL?的兩種內(nèi)置方法

更新時間：2022年11月01日 10:38:12 作者：ActionTech

這篇文章主要介紹了MySQL?Shell?運行?SQL?的兩種內(nèi)置方法概述,我們來介紹 MySQL Shell 的組件：MYSQLX 組件的兩個檢索函數(shù)在具體使用上的一些區(qū)別，需要的朋友可以參考下

MYSQLX 組件包含很多預(yù)置的類庫，其中與MySQL 交互最直接的就是 Session 類庫。Session 類庫里又包含一系列內(nèi)置函數(shù)來處理數(shù)據(jù)：其中函數(shù) run_sql 和 sql 都可以直接和 MySQL 服務(wù)端交互來運行 SQL 語句。那到底有什么區(qū)別呢？我們接下來具體介紹這兩個。（Python 環(huán)境寫法：run_sql、sql；JavaScript環(huán)境下：runSQL、sql）

第一、函數(shù)run_sql 如何使用：

先連上 X 端口 33060，替代默認(rèn)語言環(huán)境為 Python ，變量 c1 即為 Session 對象（Session:root@localhost:33060）。

root@ytt-pc-cheap:/home/ytt# mysqlsh mysqlx:/root@localhost:33060/ytt --py
MySQL Shell 8.0.30
...
Creating an X protocol session to 'root@localhost:33060/ytt'
Fetching schema names for autocompletion... Press ^C to stop.
Your MySQL connection id is 9 (X protocol)
Server version: 8.0.30 MySQL Community Server - GPL
Default schema `ytt` accessible through db.
MySQL  localhost:33060+ ssl  ytt  Py > c1=db.get_session()
MySQL  localhost:33060+ ssl  ytt  Py > c1
<Session:root@localhost:33060>

執(zhí)行 run_sql 創(chuàng)建表t1： run_sql 可以運行任何 MySQL 兼容的 SQL 語句。

MySQL  localhost:33060+ ssl  ytt  Py > c1.run_sql("create table t1(id int auto_increment primary key, r1 int)")
Query OK, 0 rows affected (0.0656 sec)
MySQL  localhost:33060+ ssl  ytt  Py > c1.run_sql("desc t1")
+-------+------+------+-----+---------+----------------+
| Field | Type | Null | Key | Default | Extra          |
+-------+------+------+-----+---------+----------------+
| id    | int  | NO   | PRI | NULL    | auto_increment |
| r1    | int  | YES  |     | NULL    |                |
+-------+------+------+-----+---------+----------------+
2 rows in set (0.0017 sec)

插入幾條樣例數(shù)據(jù)：

MySQL  localhost:33060+ ssl  ytt  Py > c1.run_sql("insert into t1(r1) values (10),(20),(30)")
Query OK, 3 rows affected (0.0114 sec)

Records: 3  Duplicates: 0  Warnings: 0

用 run_sql 來執(zhí)行查詢語句：

MySQL  localhost:33060+ ssl  ytt  Py > c1.run_sql("table t1")
+----+----+
| id | r1 |
+----+----+
|  1 | 10 |
|  2 | 20 |
|  3 | 30 |
+----+----+
3 rows in set (0.0008 sec)

以上都是直接運行 run_sql 函數(shù)的結(jié)果。

其實 run_sql 函數(shù)執(zhí)行后會返回一個 SqlResult 對象，SqlResult 對象包含很多函數(shù)：獲取語句執(zhí)行時間，一次性獲取一行或者多行數(shù)據(jù)，判斷是否有數(shù)據(jù)等等。既然是 SqlResult ，那就是一個結(jié)果集，不支持多次獲取，類似 MySQL 的游標(biāo)。

接下來把 run_sql 函數(shù)執(zhí)行結(jié)果賦予一個變量 r1 ，后續(xù)操作都通過 r1 來進行：r1 被賦予 SqlResult 對象。

MySQL  localhost:33060+ ssl  ytt  Py > r1=c1.run_sql("table t1")
MySQL  localhost:33060+ ssl  ytt  Py > r1.has_data()
true
MySQL  localhost:33060+ ssl  ytt  Py > r1.get_execution_time()
0.0010 sec
MySQL  localhost:33060+ ssl  ytt  Py > r1.fetch_one()
[
    1,
    10
]
MySQL  localhost:33060+ ssl  ytt  Py > r1.fetch_one()
[
    2,
    20
]
MySQL  localhost:33060+ ssl  ytt  Py > r1.fetch_one()
[
    3,
    30
]
MySQL  localhost:33060+ ssl  ytt  Py > r1.fetch_one()
MySQL  localhost:33060+ ssl  ytt  Py >

run_sql 函數(shù)也可以綁定變量執(zhí)行：

MySQL  localhost:33060+ ssl  ytt  Py > c1.run_sql("select * from t1 where r1 in (?,?,?)",[10,20,30])
+----+----+
| id | r1 |
+----+----+
|  1 | 10 |
|  2 | 20 |
|  3 | 30 |
+----+----+
3 rows in set (0.0004 sec)

第二、函數(shù) sql 如何使用：

sql 函數(shù)和 run_sql 函數(shù)不一樣，它返回的不是 SqlResult 對象，而是一個 SqlExecute 對象，是 SqlResult 對象產(chǎn)生之前的階段。舉個例子：把 sql 函數(shù)執(zhí)行結(jié)果賦予變量 r2 ，這樣每調(diào)用一次 r2 ，相當(dāng)于重新執(zhí)行一次原請求。

MySQL  localhost:33060+ ssl  ytt  Py > r2=c1.sql("table t1")
MySQL  localhost:33060+ ssl  ytt  Py > r2
+----+----+
| id | r1 |
+----+----+
|  1 | 10 |
|  2 | 20 |
|  3 | 30 |
+----+----+
3 rows in set (0.0004 sec)
MySQL  localhost:33060+ ssl  ytt  Py > r2
+----+----+
| id | r1 |
+----+----+
|  1 | 10 |
|  2 | 20 |
|  3 | 30 |
+----+----+
3 rows in set (0.0002 sec)

如果把變量 r2 的執(zhí)行結(jié)果賦予變量 r3 ，那 r3 就變成一個 SqlResult 對象，只支持獲取一次，又回退到 run_sql 函數(shù)的結(jié)果：

MySQL  localhost:33060+ ssl  ytt  Py > r3=r2.execute()
MySQL  localhost:33060+ ssl  ytt  Py > r3.fetch_all()
[
    [
        1,
        10
    ],
    [
        2,
        20
    ],
    [
        3,
        30
    ]
]

MySQL  localhost:33060+ ssl  ytt  Py > r3.fetch_all()
[]      
MySQL  localhost:33060+ ssl  ytt  Py > r3
Empty set (0.0004 sec)

sql 函數(shù)同樣支持執(zhí)行綁定變量的請求：一次綁定一個數(shù)組。

MySQL  localhost:33060+ ssl  ytt  Py > r2=c1.sql("select * from t1 where r1 in (?,?,?)")
MySQL  localhost:33060+ ssl  ytt  Py > r2.bind([10,20,30])
+----+----+
| id | r1 |
+----+----+
|  1 | 10 |
|  2 | 20 |
|  3 | 30 |
+----+----+
3 rows in set (0.0006 sec)
MySQL  localhost:33060+ ssl  ytt  Py > r2.bind([40,50,30])
+----+----+
| id | r1 |
+----+----+
|  3 | 30 |
+----+----+
1 row in set (0.0002 sec)