如何理解SQL審核利器goinception

這篇文章主要講解了“如何理解SQL審核利器goinception”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“如何理解SQL審核利器goinception”吧！

一、goinception簡介

使用過inception的人對SQL審核這塊獲取都比較熟悉，作為DBA，審核SQL是日常工作中的很重要的一塊內容，審核好SQL對于后期項目以及數據庫維護上起著至關重要的作用，好比一座大廈沒有堅實的地基支撐，也就無法長期屹立不倒。

goInception是一個集審核、執行、備份及生成回滾語句于一身的MySQL運維工具，  通過對執行SQL的語法解析，返回基于自定義規則的審核結果，并提供執行和備份及生成回滾語句的功能。

從架構上來說，goinception簡直跟inception一模一樣，SQL提交到goinception，goinception連接到線上MySQL進行審核。執行的時候也是連接到線上MySQL進行執行，goinception提供了備份、回滾的功能，意思就是能夠監聽執行期間的binlog，基于binlog生成反向的回滾SQL。

二、安裝測試

廢話不多說，咱們直接安裝測試一把。

下載、安裝

官方提供了二進制包，簡直安裝部署的一大福利。

下載地址：https://github.com/hanchuanchuan/goInception/releases

下載好對應版本的goinception，直接解壓即可，解壓完成以后在config/config.toml.default有一個默認的配置文件，大概意思也寫得比較清楚了，那我修改的部分已經寫在下面的配置文件中了，其他部分我都沒有修改

# 日志文件  [log.file]  filename = "/opt/goinception/logs/goinception.log"  max-days = 7  max-backups = 7  [inc]  backup_host = "xxxx"  backup_port = 3306  backup_user = "goinception"  backup_password = "goinception"  sql_safe_updates = 1  lang = "zh-CN"  [osc]  osc_min_table_size = 1024  [ghost]  ghost_on = true  ghost_chunk_size = 10000  ghost_dml_batch_size = 100

那么，我們啟動goinception

./goInception -config=config/config.toml &

啟動以后，我們可以看到端口4000已經啟動監聽了

[root@VM_0_9_centos ~]# netstat -lntp|grep 4000  tcp6       0      0 :::4000                 :::*                    LISTEN      31404/./goInception

測試

goinception可以沿用inception的調用方法，示例如下：

/*--user=root;--password=root;--host=127.0.0.1;--check=1;--port=3306;*/  inception_magic_start;  use test;  create table t1(id int primary key);  inception_magic_commit;

那么我們構建一個python腳本來進行測試：

#!/usr/bin/env python3  # -*- coding:utf-8 -*-  import pymysql  import prettytable as pt  tb = pt.PrettyTable()  sql = '''/*--user=xucl;--password=xuclxucl123;--host=127.0.0.1;--check=1;--port=3308;*/  inception_magic_start;  use sbtest;  create table t1(id int primary key,c1 int, c2 int);  insert into t1(id,c1,c2) values(1,1,1);  inception_magic_commit;'''  conn = pymysql.connect(host='127.0.0.1', user='', passwd='',                         db='', port=4000, charset="utf8mb4")  cur = conn.cursor()  ret = cur.execute(sql)  result = cur.fetchall()  cur.close()  conn.close() tb.field_names = [i[0] for i in cur.description]  for row in result:      tb.add_row(row)  print(tb)

執行后輸出如下：

[root@VM_0_9_centos goinception]# python3 test.py   +----------+---------+-------------+-----------------+-----------------+----------------------------------------------------+---------------+--------------+---------------+--------------+---------+-------------+ | ------+---------------+--------------+---------------+--------------+---------+-------------+|order_id|stage|error_ |  ------+---------------+--------------+---------------+--------------+---------+-------------+|order_id|stage|error_  | ------+---------------+--------------+---------------+--------------+---------+-------------+|order_id|stage|error_level |   ------+---------------+--------------+---------------+--------------+---------+-------------+|order_id|stage|error__status  |  ------+---------------+--------------+---------------+--------------+---------+-------------+|order_id|stage|error_message  |                        sql                         | affected_rows |   sequence   | backup_dbname | execute_time | sqlsha1 | backup_time | +----------+---------+-------------+-----------------+-----------------+----------------------------------------------------+---------------+--------------+---------------+--------------+---------+-------------+ |    1     | CHECKED |      0      | Audit Completed |       None      |                     use sbtest                     |       0       | 0_0_00000000 |      None     |      0       |   None  |      0      | |    2     | CHECKED |      2      | Audit Completed | 表 't1' 已存在. | create table t1(id int primary key,c1 int, c2 int) |       0       | 0_0_00000001 |      None     |      0       |   None  |      0      | |    3     | CHECKED |      0      | Audit Completed |       None      |       insert into t1(id,c1,c2) values(1,1,1)       |       1       | 0_0_00000002 |      None     |      0       |   None  |      0      | +----------+---------+-------------+-----------------+-----------------+----------------------------------------------------+---------------+--------------+---------------+--------------+---------+-------------+

可以看到審核結果還是非常清晰的

那如果需要執行的話怎么做呢？我們只需要修改示例中的頭部，將--check=1改成--execute=1即可

/*--user=xucl;--password=xuclxucl123;--host=127.0.0.1;--execute=1;--port=3308;*/

那你如果想備份的話，添加選項--backup=1即可

/*--user=xucl;--password=xuclxucl123;--host=127.0.0.1;--execute=1;--backup=1;--port=3308;*/

三、審核規則

goinception的審核規則可以見文檔：https://hanchuanchuan.github.io/goInception/rules.html

我撿了一些我認為比較重要的審核規則，列成表格如下：

create  table

表屬性

列屬性

索引屬性檢查項

默認值

自增列

ALTER

DML

INSERT

INSERT  SELECT

UPDATE/DELETE

四、使用感受

簡單測試了一下goinception，整體體驗下來感覺還是很不錯的，相比于之前的inception來說，goinception有如下幾個優點：

1.  安裝部署非常簡單，官方直接提供了二進制包

2.  集成了gh-ost無需另外安裝，同時也提供pt-osc方式執行DDL

3.  提供了基于表大小的ALTER執行選項，并且可配置大小

4.  支持關聯更新，inception本身是不支持的

5.  提供了更加豐富的審核規則選項，并且是基于MySQL5.7的，相比于inception來說支持度更好

6.  長期穩定更新，從github上的commit記錄看作者還是更新得很勤奮的

7.  更快的備份功能，之前使用inception的時候經常會碰到需要備份的binlog過大，網絡超時的現象（從文檔上看goinception使用的批量備份，據說速度能快很多）

五、系統集成

到這里，我們已經基本上選擇goinception作為我們的審核引擎了，那么如何集成到現有的自動化系統中是個問題。

先說一下我們公司的情況，我們公司有流程中心，也就是開發會在上面選擇庫，提交SQL，DBA收到工單以后人工審核，手工執行。

在審核過程中，對于DBA來說，肉眼審核也太過于辛酸了，手工執行一不小心就是背黑鍋。所以，基于goinception，我這邊提供了幾個restful的接口，分別如下：

1.  db信息接口，根據用戶權限，返回該用戶所能看到的dbname

2.  SQL檢查接口，用戶提交SQL，調用goinception進行審核，審核通過以后到DBA

3.  SQL執行接口，DBA選擇執行的實例，調用goinception進行SQL執行，執行完成以后通知開發工單完成

4.  開發查看工單，可以下載對應的回滾SQL

感謝各位的閱讀，以上就是“如何理解SQL審核利器goinception”的內容了，經過本文的學習后，相信大家對如何理解SQL審核利器goinception這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！