Inception相關(guān)功能學(xué)習(xí)

發(fā)布時(shí)間：2020-08-09 23:19:53 來源：ITPUB博客閱讀：232 作者：jx_yu 欄目：MySQL數(shù)據(jù)庫

開源地址 https://github.com/mysql-inception/inception
文檔地址 http://mysql-inception.github.io/inception-document/

Inception安裝

下載解壓

]$wget https://github.com/mysql-inception/inception.git

]$pwd

/inception

]$unzip inception-master.zip

安裝Inception

]$ cd /inception/inception-master/

#執(zhí)行如下命令，可以看到安裝幫助

]$ sh inception_build.sh

Usage: inception_build.sh builddir [platform(linux:Xcode)]

EXAPMLE: inception_build.sh debug [Xcode]

#安裝到./yk目錄

]$ sh inception_build.sh yk

#說明：

1.inception_build.sh實(shí)際上封裝了cmake && make && make install編譯安裝的步驟

2.buliddir是安裝目錄，platform是所在平臺(tái)（默認(rèn)linux）

3.每次如果出錯(cuò)之后，需要把編譯目錄刪除掉，重新執(zhí)行，不然會(huì)執(zhí)行出錯(cuò)。

4.編譯過程沒有err那說明安裝成功了

配置Inception

#與MySQL類型，可以指定一個(gè)cnf配置文件

]$ vim /etc/inc.cnf

[inception]

general_log=1

general_log_file=inception.log

port=6669

socket=/tmp/inc.socket

character-set-client-handshake=0

character-set-server=utf8

。。。。。。。

#此處只是簡單的配置為了啟動(dòng)Inception服務(wù)，更多的配置選項(xiàng)請(qǐng)參考文檔

啟動(dòng)Inception

]$ cd /inception/inception-master/yk/mysql/bin

]$ nohup /Inception --defaults-file=/etc/inc.cnf &

]$ netstat -antpl|grep 6669

tcp 0 0 0.0.0.0:6669 0.0.0.0:* LISTEN 4598/Inception

至此，可以看到inception的6669端口已經(jīng)運(yùn)行

連接Inception

]$ mysql -h227.0.0.1 -P6669

Welcome to the MySQL monitor. Commands end with ; or \g.

Your MySQL connection id is 2

Server version: Inception2.1.23 1

……………………..

mysql> inception get variables; #獲取inception所有的變量和值

+------------------------------------------+----------------------------------------------------------+

| Variable_name | Value |

+------------------------------------------+----------------------------------------------------------+

| autocommit | OFF |

| bind_address | * |

| character_set_system | utf8 |

………………..

Inception簡單使用

1、 Inception規(guī)定，在語句的最開始位置，要加上inception_magic_start;語句，在執(zhí)行語句塊的最后加上inception_magic_commit;語句，這2個(gè)語句在 Inception 中都是合法的、具有標(biāo)記性質(zhì)的可被正確解析的 SQL 語句。被包圍起來的所有需要審核或者執(zhí)行的語句都必須要在每條之后加上分號(hào)，其實(shí)就是批量執(zhí)行SQL語句。（包括use database語句之后也要加分號(hào)，這點(diǎn)與 MySQL 客戶端不同），不然存在語法錯(cuò)誤

2、目前執(zhí)行只支持通過C/C++接口、Python接口來對(duì)Inception訪問，這一段必須是一次性的通過執(zhí)行接口提交給Inception，那么在處理完成之后，Inception會(huì)返回一個(gè)結(jié)果集，來告訴我們這些語句中存在什么錯(cuò)誤，或者是完全正常等等

/*--user=yujx;--password=xxxxxxxxxxx;--host=127.0.0.1;--enable-check;--port=3306;*/

inception_magic_start;

use test;

CREATE TABLE yujx(id int);

inception_magic_commit;

下面是一段執(zhí)行上面語句的Python程序的例子：

]$ cat inc-mysql.py

#!/usr/bin/env python

#coding=utf8

import MySQLdb

sql='''/*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/\

inception_magic_start;\

use test;\

CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試';\

inception_magic_commit;'''

#print sql

try:

conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',db='',port=6669)

cur=conn.cursor()

ret=cur.execute(sql)

result=cur.fetchall()

num_fields = len(cur.description)

field_names = [i[0] for i in cur.description]

print field_names

for row in result:

print row[0], "|",row[1],"|",row[2],"|",row[3],"|",row[4],"|",row[5],"|",row[6],"|",row[7],"|",row[8],"|",row[9],"|",row[10]

cur.close()

conn.close()

except MySQLdb.Error,e:

print "Mysql Error %d: %s" % (e.args[0], e.args[1])

當(dāng)創(chuàng)建表語句為

CREATE TABLE yujx(id int)

]$ python inc-mysql.py

['ID', 'stage', 'errlevel', 'stagestatus', 'errormessage', 'SQL', 'Affected_rows', 'sequence', 'backup_dbname', 'execute_time', 'sqlsha1']

1 | CHECKED | 0 | Audit completed | None | use test | 0 | '0_0_0' | None | 0 |

2 | CHECKED | 1 | Audit completed | Set engine to innodb for table 'yujx'.

Set charset to one of 'utf8mb4' for table 'yujx'.

Set comments for table 'yujx'.

Column 'id' in table 'yujx' have no comments.

Column 'id' in table 'yujx' is not allowed to been nullable.

Set Default value for column 'id' in table 'yujx'

Set a primary key for table 'yujx'. | CREATE TABLE yujx(id int) | 0 | '0_0_1' | 127_0_0_1_3306_test | 0 |

CREATE TABLE yujx(id int) engine=innodb;

]$ python inc-mysql.py

['ID', 'stage', 'errlevel', 'stagestatus', 'errormessage', 'SQL', 'Affected_rows', 'sequence', 'backup_dbname', 'execute_time', 'sqlsha1']

1 | CHECKED | 0 | Audit completed | None | use test | 0 | '0_0_0' | None | 0 |

2 | CHECKED | 1 | Audit completed | Set charset to one of 'utf8mb4' for table 'yujx'.

Set comments for table 'yujx'.

Column 'id' in table 'yujx' have no comments.

Column 'id' in table 'yujx' is not allowed to been nullable.

Set Default value for column 'id' in table 'yujx'

Set a primary key for table 'yujx'. | CREATE TABLE yujx(id int) engine=innodb | 0 | '0_0_1' | 127_0_0_1_3306_test | 0 |

以此類推，直到如下完整的創(chuàng)建語句時(shí)，終于成功

CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試'

]$ python inc-mysql.py

['ID', 'stage', 'errlevel', 'stagestatus', 'errormessage', 'SQL', 'Affected_rows', 'sequence', 'backup_dbname', 'execute_time', 'sqlsha1']

1 | RERUN | 0 | Execute Successfully | None | use test | 0 | '1464252128_35_0' | None | 0.000 |

2 | EXECUTED | 0 | Execute Successfully | None | CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試' | 0 | '1464252128_35_1' | 127_0_0_1_3306_test | 0.010 |

如上，是默認(rèn)的inception審核規(guī)則，用戶可以根據(jù)自己的實(shí)際情況來自定義某些規(guī)則

Inception操作LOG

]$ tail -f /inception/inception-master/yk/mysql/bin/inception.log

24 Query /*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/ inception_magic_start; use test; CREATE TABLE yujx(id int) engine=innodb; inception_magic_commit

160526 16:42:08 25 Query set autocommit=0

25 Query /*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/ inception_magic_start; use test; CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試'; inception_magic_commit

160526 17:13:50 26 Query select @@version_comment limit 1

160526 17:13:54 26 Query inception get variables

Inception所支持的參數(shù)變量

參考：http://mysql-inception.github.io/inception-document/variables/

Inception備份功能

備份功能試驗(yàn)

備份服務(wù)器創(chuàng)建bakcup賬號(hào)并且grant權(quán)限

#由于測(cè)試環(huán)境就開all權(quán)限了

mysql> grant all on *.* to 'backup'@'%' identified by 'backup';

mysql> flush privileges;

指定備份服務(wù)器信息

]$ grep remote /etc/inc.cnf

inception_remote_system_password=backup

inception_remote_system_user=backup

inception_remote_backup_port=3306

inception_remote_backup_host=10.10.69.241

重啟inception

]$Kill -9 inception_pid

]$ nohup /Inception --defaults-file=/etc/inc.cnf &

確保線上目標(biāo)庫binlog打開&&binlog_format

mysql> show variables like 'log_bin';

+---------------+-------+

| Variable_name | Value |

+---------------+-------+

| log_bin | ON |

+---------------+-------+

1 row in set (0.00 sec)

mysql> show variables like 'binlog_format';

+---------------+-------+

| Variable_name | Value |

+---------------+-------+

| binlog_format | ROW |

+---------------+-------+

1 row in set (0.00 sec)

調(diào)用inception操作目標(biāo)庫

]$ python inc-mysql.py

['ID', 'stage', 'errlevel', 'stagestatus', 'errormessage', 'SQL', 'Affected_rows', 'sequence', 'backup_dbname', 'execute_time', 'sqlsha1']

1 | RERUN | 0 | Execute Successfully | None | use test | 0 | '1464320865_11_0' | None | 0.000 |

2 | EXECUTED | 0 | Execute Successfully

Backup successfully | None | CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試' | 0 | '1464320865_11_1' | 127_0_0_1_3306_test | 0.010 |

查看備份庫

#如下，備份庫多出了2個(gè)db:inception和IP_PORT_DBNAME

mysql> show databases;

+---------------------+

| Database |

+---------------------+

| information_schema |

| 127_0_0_1_3306_test |

| inception |

| mysql |

| performance_schema |

| test |

+---------------------+

#inception.statistic表存儲(chǔ)的就是SQL執(zhí)行數(shù)目的統(tǒng)計(jì)數(shù)據(jù)

參考：http://mysql-inception.github.io/inception-document/statistic/

Inception相關(guān)功能學(xué)習(xí)

#IP_PORT_dbname庫下表中記錄了對(duì)應(yīng)的rollback操作

Inception相關(guān)功能學(xué)習(xí)

除了與原庫中的表一一對(duì)應(yīng)之外，每個(gè)備份庫中還有另外一個(gè)表：$_$Inception_backup_information$_$，這就是表名，非常難看，主要是為了防止與原線上庫中的表名發(fā)生沖突。這個(gè)表是用來存儲(chǔ)所有對(duì)當(dāng)前庫操作的操作記錄的，它是公用的，對(duì)線上這個(gè)庫的所有表操作記錄都存儲(chǔ)在這里面

參考鏈接：http://mysql-inception.github.io/inception-document/backup/

Inception OSC功能

參考：http://mysql-inception.github.io/inception-document/osc/

配置PT-osc的路徑

]$ which pt-online-schema-change

/usr/bin/pt-online-schema-change

]$ grep bin_dir /etc/inc.cnf

inception_osc_bin_dir=/usr/bin/pt-online-schema-change

設(shè)置osc相關(guān)選項(xiàng)

]$ grep osc inc-mysql-osc.py

inception set session inception_osc_recursion_method=none;

inception set session inception_osc_alter_foreign_keys_method=0;

inception set session inception_osc_min_table_size=1; #設(shè)置表大小超過此參數(shù)的值時(shí)，inception調(diào)用osc工具alter表

執(zhí)行inception調(diào)用pt-osc

]$ python inc-mysql-osc.py

['ID', 'stage', 'errlevel', 'stagestatus', 'errormessage', 'SQL', 'Affected_rows', 'sequence', 'backup_dbname', 'execute_time', 'sqlsha1']

1 | RERUN | 0 | Execute Successfully | None | use test | 0 | '1464335578_270_0' | None | 0.000 |

2 | EXECUTED | 0 | Execute Successfully

查看osc的進(jìn)度

#查看osc列表

mysql> inception get osc processlist;

#由上面的processlist可以看到正在執(zhí)行的osc任務(wù)對(duì)應(yīng)的SQLSHA1值，然后使用下方命令可以查看指定的一條osc任務(wù)進(jìn)度

mysql> inception get osc_percent '*8388D07BAD14866D80DD45CD1521F4F0D17C20CE';

+--------+-----------+-------------------------------------------+---------+------------+-----------------------------------

+--------+-----------+-------------------------------------------+---------+------------+----------------------------------------------------------------------------------------| test | test | *8388D07BAD14866D80DD45CD1521F4F0D17C20CE | 92 | 00:11 | Operation, tries, wait:

copy_rows, 10, 0.25

create_triggers, 10, 1

drop_triggers, 10, 1

swap_tables, 10, 1

update_foreign_keys, 10, 1

No foreign keys reference `test`.`test`; ignoring --alter-foreign-keys-method.

Altering `test`.`test`...

Creating new table...

CREATE TABLE `test`.`_test_new` ( `x` int(11) DEFAULT NULL,

`y` int(11) DEFAULT NULL,

`z` int(11) NOT NULL AUTO_INCREMENT,

PRIMARY KEY (`z`)

) ENGINE=InnoDB AUTO_INCREMENT=6488605 DEFAULT CHARSET=latin1

Created new table test._test_new OK.

Altering new table...

ALTER TABLE `test`.`_test_new` add a int not null default 0 comment 'a?-???μ'

Altered `test`.`_test_new` OK.

Creating triggers...

CREATE TRIGGER `pt_osc_test_test_del` AFTER DELETE ON `test`.`test` FOR EACH ROW DELETE IGNORE FROM `test`.`_test_new` WHERE `test`.`_test_new`.`z` <=> OLD.`z`

CREATE TRIGGER `pt_osc_test_test_upd` AFTER UPDATE ON `test`.`test` FOR EACH ROW REPLACE INTO `test`.`_test_new` (`x`, `y`, `z`) VALUES (NEW.`x`, NEW.`y`, NEW.`z`)

CREATE TRIGGER `pt_osc_test_test_ins` AFTER INSERT ON `test`.`test` FOR EACH ROW REPLACE INTO `test`.`_test_new` (`x`, `y`, `z`) VALUES (NEW.`x`, NEW.`y`, NEW.`z`)

Created triggers OK.

INSERT LOW_PRIORITY IGNORE INTO `test`.`_test_new` (`x`, `y`, `z`) SELECT `x`, `y`, `z` FROM `test`.`test` FORCE INDEX(`PRIMARY`) WHERE ((`z` >= ?)) AND ((`z` <= ?)) LOCK IN SHARE MODE /*pt-online-schema-change 12934 copy nibble*/

SELECT /*!40001 SQL_NO_CACHE */ `z` FROM `test`.`test` FORCE INDEX(`PRIMARY`) WHERE ((`z` >= ?)) ORDER BY `z` LIMIT ?, 2 /*next chunk boundary*/

查看目標(biāo)庫結(jié)果

mysql> desc test;

+-------+---------+------+-----+---------+----------------+

+-------+---------+------+-----+---------+----------------+

| x | int(11) | YES | | NULL | |

| y | int(11) | YES | | NULL | |

| z | int(11) | NO | PRI | NULL | auto_increment |

| a | int(11) | NO | | 0 | | #添加成功

+-------+---------+------+-----+---------+----------------+

4 rows in set (0.01 sec)

Inception 審核規(guī)范及原則

參考http://mysql-inception.github.io/inception-document/rules/

下面所列出來的規(guī)則，不一定能覆蓋所有Inception當(dāng)前已經(jīng)實(shí)現(xiàn)的功能，具體包括什么規(guī)則，還需要在使用過程中總結(jié)，發(fā)現(xiàn)，同時(shí)可以結(jié)合配置參數(shù)來詳細(xì)了解這些規(guī)則。

支持的語句類型

l use db：此時(shí)會(huì)檢查這個(gè)庫是不是存在，需要連接到線上服務(wù)器來判斷。

l set option：現(xiàn)在只需要支持set names charset，設(shè)置其它變量時(shí)都報(bào)錯(cuò)不支持。

l 創(chuàng)建數(shù)據(jù)庫語句

l 插入語句（包括多值插入）

l 查詢插入語句

l 刪除語句（包括多表刪除）

l 更新語句（包括多表更新）

l 創(chuàng)建表語句

l 刪除表語句

l 修改表語句

l Truncate表語句

l inception命令集語句（包括管理命令）

插入語句檢查項(xiàng)

l 表是否存在

l 必須指定插入列表，也就是要對(duì)哪幾個(gè)列指定插入值，如insert into t (id,id2) values(...)，（可配置）

l 必須指定值列表，與上面對(duì)應(yīng)的列，插入的值是什么，必須要指定。

l 插入列列表與值列表個(gè)數(shù)相同，上面二者的個(gè)數(shù)需要相同，如果沒有指定列列表（因?yàn)榭膳渲茫?，則值列表長度要與表列數(shù)相同。

l 不為null的列，如果插入的值是null，報(bào)錯(cuò)（可配置）

l 插入指定的列名對(duì)應(yīng)的列必須是存在的。

l 插入指定的列列表中，同一個(gè)列不能出現(xiàn)多次。

l 插入值列表中的簡單表達(dá)式會(huì)做檢查，但具體包括什么不一一指定

更新、刪除語句檢查項(xiàng)

l 表是否存在

l 必須有where條件（可配置）

l delete語句不能有limit條件（可配置）

l 不能有order by語句（可配置）

l 影響行數(shù)大于10000條，則報(bào)警（數(shù)目可配置）

l 對(duì)WHERE條件這個(gè)表達(dá)式做簡單檢查，具體包括什么不一一指定

l 對(duì)更新列的值列表表達(dá)式做簡單檢查，具體不一一指定

l 對(duì)更新列對(duì)象做簡單檢查，主要檢查列是不是存在等

l 多表更新、刪除時(shí)，每個(gè)表必須要存在

建表語句檢查項(xiàng)

表屬性的檢查項(xiàng)

l 這個(gè)表不存在

l 對(duì)于create table like，會(huì)檢查like的老表是不是存在。

l 對(duì)于create table db.table，會(huì)檢查db這個(gè)數(shù)據(jù)庫是不是存在

l 表名、列名、索引名的長度不大于64個(gè)字節(jié)

l 如果建立的是臨時(shí)表，則必須要以tmp為前綴

l 必須要指定建立innodb的存儲(chǔ)引擎（可配置）

l 必須要指定utf8的字符集（字符串可配置，指定支持哪些字符集）

l 表必須要有注釋（可配置）

l 表不能建立為分區(qū)表（可配置）

l 只能有一個(gè)自增列

l 索引名字不能是Primay

l 不支持Foreign key（可配置）

l 建表時(shí)，如果指定auto_increment的值不為1，報(bào)錯(cuò)（可配置）

l 如果自增列的名字不為id，說明有可能是有意義的，MySQL這樣使用比較危險(xiǎn)，所以報(bào)警（可配置）

列屬性的檢查項(xiàng)

l 不能設(shè)置列的字符集（可配置）

l 列的類型不能使用集合、枚舉、位圖類型。（可配置）

l 列必須要有注釋（可配置）

l char長度大于20的時(shí)候需要改為varchar（長度可配置）

l 列的類型不能是BLOB/TEXT。（可配置）

l 每個(gè)列都使用not null（可配置）

l 如果列為BLOB/TEXT類型的，則這個(gè)列不能設(shè)置為NOT NULL。

l 如何是自增列，則使用無符號(hào)類型（可配置）

l 如果自增列，則長度必須要大于等于4個(gè)字節(jié)（可配置）

l 如果是timestamp類型的，則要必須指定默認(rèn)值。

l 對(duì)于MySQL5.5版本（包含）以下的數(shù)據(jù)庫，不能同時(shí)有兩個(gè)TIMESTAMP類型的列，如果是DATETIME類型，則不能定義成DATETIME DEFAULT CURRENT_TIMESTAMP及ON UPDATE CURRENT_TIMESTAMP等語句。

l 每個(gè)列都需要定義默認(rèn)值，除了自增列、主鍵列及大字段列之外（可配置）

l 不能有重復(fù)的列名

索引屬性檢查項(xiàng)

l 索引必須要有名字

l 不能有外鍵（可配置）

l Unique索引必須要以uniq_為前綴（可配置）

l 普通索引必須要以idx_為前綴（可配置）

l 索引的列數(shù)不能超過5個(gè)（數(shù)目可以配置）

l 表必須要有一個(gè)主鍵（可配置）

l 最多有5個(gè)索引（數(shù)目可配置）

l 建索引時(shí)，指定的列必須存在。

l 索引中的列，不能重復(fù)

l BLOB列不能建做KEY

l 索引長度不能超過766

l 不能有重復(fù)的索引，名字及內(nèi)容

默認(rèn)值檢查項(xiàng)

l BLOB/TEXT類型的列，不能有非NULL的默認(rèn)值

l MySQL5.5以下（含）的版本，對(duì)于DATETIME類型的列，不能有函數(shù)NOW()的默認(rèn)值。

l 如果設(shè)置默認(rèn)值為函數(shù)，則只能是NOW()。

l 如果默認(rèn)值為NULL，但列類型為NOT NULL，或者是主鍵列，或者定義為自增列，則報(bào)錯(cuò)。

l 自增列不能設(shè)置默認(rèn)值。

l 修改表語句檢查項(xiàng)

l 表是不是存在

創(chuàng)建索引檢查項(xiàng)

l 同上面創(chuàng)建表中的索引檢查項(xiàng)

加列檢查項(xiàng)

l 同上面創(chuàng)建表中的列檢查項(xiàng)

修改表檢查項(xiàng)

l 表是不是存在

l 如果語句塊中存在多條對(duì)同一個(gè)表的修改語句，則建議合并成一個(gè)ALTER語句

l 列是否存在

l 剩下的同上面創(chuàng)建表，創(chuàng)建索引，創(chuàng)建列，默認(rèn)值等檢查項(xiàng)一樣

刪除索引檢查項(xiàng)

l 表是不是存在

l 檢查索引是不是存在

修改列的默認(rèn)值檢查項(xiàng)

l 同默認(rèn)值檢查項(xiàng)

修改表屬性

l 表屬性只支持對(duì)存儲(chǔ)引擎、表注釋、自增值及默認(rèn)字符集的修改操作。

l 修改存儲(chǔ)引擎時(shí)檢查是不是Innodb（可配置）。

l 字符集修改檢查是不是屬于設(shè)置參數(shù)的值（支持字符集可配置）。

轉(zhuǎn)換表字符集

l 字符集修改檢查是不是屬于設(shè)置參數(shù)的值（支持字符集可配置）。

聲明

針對(duì)線上MySQL服務(wù)器是不是5.6以上（包含）版本，有不同的處理策略，比如在預(yù)估影響行數(shù)時(shí)，5.6可以直接對(duì)任何DML語句做EXPLAIN操作，而在5.5版本中，只支持對(duì)SELECT語句執(zhí)行EXPLAIN操作，而在5.5版本中，有些DML語句是不容易直接轉(zhuǎn)換為SELECT語句去做EXPLAIN，這樣導(dǎo)致預(yù)估行數(shù)為0。

還是針對(duì)5.6以上版本與5.5版本的不同，DATETIME、TIMESTAMP系列類型在執(zhí)行時(shí)，5.5的限制比較多，而5.6基本通用，所以這上面的處理可能在5.6及5.5版本上，相同語句返回的結(jié)果集是不同的（規(guī)則是在5.5中以在執(zhí)行時(shí)報(bào)的錯(cuò)誤信息為準(zhǔn)），這與線上版本有關(guān)系。

附：執(zhí)行的三個(gè)腳本

創(chuàng)建表

]$ cat inc-mysql.py

#!/usr/bin/env python

#coding=utf8

import MySQLdb

sql='''/*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/\

inception_magic_start;\

use test;\

CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試';\

inception_magic_commit;'''

#print sql

try:

conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',db='',port=6669)

cur=conn.cursor()

ret=cur.execute(sql)

result=cur.fetchall()

num_fields = len(cur.description)

field_names = [i[0] for i in cur.description]

print field_names

for row in result:

print row[0], "|",row[1],"|",row[2],"|",row[3],"|",row[4],"|",row[5],"|",row[6],"|",row[7],"|",row[8],"|",row[9],"|",row[10]

cur.close()

conn.close()

except MySQLdb.Error,e:

print "Mysql Error %d: %s" % (e.args[0], e.args[1])

Insert表

]$ cat inc-mysql-insert.py

#!/usr/bin/env python

#coding=utf8

import MySQLdb

sql='''/*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/\

inception_magic_start;\

use test;\

insert into yujx(id) value(1);\

inception_magic_commit;'''

#print sql

try:

conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',db='',port=6669)

cur=conn.cursor()

ret=cur.execute(sql)

result=cur.fetchall()

num_fields = len(cur.description)

field_names = [i[0] for i in cur.description]

print field_names

for row in result:

print row[0], "|",row[1],"|",row[2],"|",row[3],"|",row[4],"|",row[5],"|",row[6],"|",row[7],"|",row[8],"|",row[9],"|",row[10]

cur.close()

conn.close()

except MySQLdb.Error,e:

print "Mysql Error %d: %s" % (e.args[0], e.args[1])

OSC表

]$ cat inc-mysql-osc.py

#!/usr/bin/env python

#coding=utf8

import MySQLdb

sql='''

inception set session inception_osc_recursion_method=none;

inception set session inception_osc_alter_foreign_keys_method=0;

inception set session inception_osc_min_table_size=1;

/*--user=yujx;--password=yujx;--host=127.0.0.1;--execute=1;--port=3306;*/\

inception_magic_start;\

use test;\

alter table test add b int not null default 0 comment 'b字段';\

inception_magic_commit;'''

try:

conn=MySQLdb.connect(host='127.0.0.1',user='',passwd='',db='',port=6669)

cur=conn.cursor()

ret=cur.execute(sql)

result=cur.fetchall()

num_fields = len(cur.description)

field_names = [i[0] for i in cur.description]

print field_names

for row in result:

print row[0], "|",row[1],"|",row[2],"|",row[3],"|",row[4],"|",row[5],"|",row[6],"|",row[7],"|",row[8],"|",row[9],"|",row[10]

cur.close()

conn.close()

except MySQLdb.Error,e:

print "Mysql Error %d: %s" % (e.args[0], e.args[1])

向AI問一下細(xì)節(jié)

Inception相關(guān)功能學(xué)習(xí)

Inception安裝

下載解壓

安裝Inception

配置Inception

啟動(dòng)Inception

連接Inception

Inception簡單使用

下面是一段執(zhí)行上面語句的Python程序的例子：

當(dāng)創(chuàng)建表語句為

CREATE TABLE yujx(id int)

CREATE TABLE yujx(id int) engine=innodb;

CREATE TABLE yujx(id int comment 'test' primary key) engine=innodb DEFAULT CHARSET=utf8mb4 comment '測(cè)試'

Inception操作LOG

Inception所支持的參數(shù)變量

Inception備份功能

相關(guān)說明

備份功能試驗(yàn)

備份服務(wù)器創(chuàng)建bakcup賬號(hào)并且grant權(quán)限

指定備份服務(wù)器信息

重啟inception

確保線上目標(biāo)庫binlog打開&&binlog_format

調(diào)用inception操作目標(biāo)庫

查看備份庫

Inception OSC功能

配置PT-osc的路徑

設(shè)置osc相關(guān)選項(xiàng)

執(zhí)行inception調(diào)用pt-osc

查看osc的進(jìn)度

查看目標(biāo)庫結(jié)果

Inception 審核規(guī)范及原則

支持的語句類型

插入語句檢查項(xiàng)

更新、刪除語句檢查項(xiàng)

建表語句檢查項(xiàng)

表屬性的檢查項(xiàng)

列屬性的檢查項(xiàng)

索引屬性檢查項(xiàng)

默認(rèn)值檢查項(xiàng)

創(chuàng)建索引檢查項(xiàng)

加列檢查項(xiàng)

修改表檢查項(xiàng)

刪除索引檢查項(xiàng)

修改列的默認(rèn)值檢查項(xiàng)

修改表屬性

轉(zhuǎn)換表字符集

聲明

附：執(zhí)行的三個(gè)腳本

創(chuàng)建表

Insert表

OSC表

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽

更新、刪除語句檢查項(xiàng)