溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
開源地址 https://github.com/mysql-inception/inception
文檔地址 http://mysql-inception.github.io/inception-document/
]$wget https://github.com/mysql-inception/inception.git
]$pwd
/inception
]$unzip inception-master.zip
]$ cd /inception/inception-master/
#執行如下命令，可以看到安裝幫助
]$ 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實際上封裝了cmake && make && make install編譯安裝的步驟
2.buliddir是安裝目錄，platform是所在平臺（默認linux）
3.每次如果出錯之后，需要把編譯目錄刪除掉，重新執行，不然會執行出錯。
4.編譯過程沒有err那說明安裝成功了
#與MySQL類型，可以指定一個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
。。。。。。。
#此處只是簡單的配置為了啟動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端口已經運行
]$ 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 |
………………..
1、 Inception規定，在語句的最開始位置，要加上inception_magic_start;語句，在執行語句塊的最后加上inception_magic_commit;語句，這2個語句在 Inception 中都是合法的、具有標記性質的可被正確解析的 SQL 語句。被包圍起來的所有需要審核或者執行的語句都必須要在每條之后加上分號，其實就是批量執行SQL語句。（包括use database語句之后也要加分號，這點與 MySQL 客戶端不同），不然存在語法錯誤
2、 目前執行只支持通過C/C++接口、Python接口來對Inception訪問，這一段必須是一次性的通過執行接口提交給Inception，那么在處理完成之后，Inception會返回一個結果集，來告訴我們這些語句中存在什么錯誤，或者是完全正常等等
/*--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;
]$ 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 '測試';\
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])
]$ 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 |
]$ 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 |
以此類推，直到如下完整的創建語句時，終于成功
]$ 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 '測試' | 0 | '1464252128_35_1' | 127_0_0_1_3306_test | 0.010 |
如上，是默認的inception審核規則，用戶可以根據自己的實際情況來自定義某些規則
]$ 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 '測試'; inception_magic_commit
160526 17:13:50 26 Query select @@version_comment limit 1
160526 17:13:54 26 Query inception get variables
參考：http://mysql-inception.github.io/inception-document/variables/
Inception在做DML操作時，具有備份功能，它會將所有當前語句修改的行備份下來，存儲到一個指定的庫中，這些庫的指定需要通過幾個參數，它們分別是：
inception_remote_backup_host //遠程備份庫的host
inception_remote_backup_port //遠程備份庫的port
inception_remote_system_user //遠程備份庫的一個用戶
inception_remote_system_password //上面用戶的密碼
1.這些參數可以直接在命令行中指定，也可以在inc.cnf配置文件中指定。修改這些參數需要重啟inception服務。
2.Inception默認是開啟備份功能的，可以使用參數--disable-remote-backup=1來關閉備份功能
3.被影響的表如果沒有主鍵的話，就不會做備份
4.Inception備份用戶必須要具備CREATE、INSERT。CREATE權限用于創建表或者庫的，INSERT權限用于插入備份數據的，其它的權限不需要（也許是暫時的）
5.備份數據在備份機器的存儲，是與線上被修改庫一對一的。但因為機器的多（線上機器有很多）對一（備份機器只有一臺），所以為了防止庫名的沖突，備份機器的庫名組成是由線上機器的 IP 地址的點換成下劃線，再加上端口號，再加上庫名三部分，這三部分也是通過下劃線連接起來的,如：10_103_11_242_3306_test
6.對線上配置需求
線上服務器必須要打開 binlog，在啟動時需要設置參數log_bin、log_bin_index等關于 binlog 的參數。不然不會備份及生成回滾語句。
參數binlog_format必須要設置為 mixed 或者 row 模式，通過語句： set global binlog_format=mixed/row 來設置，如果是 statement 模式，則不做備份及回滾語句的生成。
參數 server_id 必須要設置為非0及非1，通過語句：set global server_id=server_id;來設置，不然在備份時會報錯。
線上服務器一定要有指定用戶名的權限，這個是在語句前面的注釋中指定的，做什么操作就要有什么權限，否則還是會報錯，如果需要執行的功能，則要有線上執行語句的權限，比如DDL及DML，同時如果要執行inception show 等遠程命令的話，有些語句是需要特殊權限的，這些權限也是需要授予的，關于權限這個問題，因為一般Inception是運行在一臺固定機器上面的，那么在選項中指定的用戶名密碼，實際上是Inception機器對線上數據庫訪問的權限，所以建議在使用過程中，使用專門固定的帳號來讓Inception使用，最好是一個只讀一個可寫的即可，這樣在執行時用可寫，審核或者查看線上狀態或者表庫結果時用只讀即可，這樣更安全。
需要額外注意的點
在執行時，不能將 DML 語句及 DDL 語句放在一起執行，否則會因為備份解析binlog時由于表結構的變化出現不可預知的錯誤，如果要有同時執行 DML 及 DDL，則請分開多個語句塊兒來執行，如果真的這樣做了，Inception 會報錯，不會去執行。
#由于測試環境就開all權限了
mysql> grant all on *.* to 'backup'@'%' identified by 'backup';
mysql> flush privileges;
]$ 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
]$Kill -9 inception_pid
]$ nohup /Inception --defaults-file=/etc/inc.cnf &
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)
]$ 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 '測試' | 0 | '1464320865_11_1' | 127_0_0_1_3306_test | 0.010 |
#如下，備份庫多出了2個db:inception和IP_PORT_DBNAME
mysql> show databases;
+---------------------+
| Database |
+---------------------+
| information_schema |
| 127_0_0_1_3306_test |
| inception |
| mysql |
| performance_schema |
| test |
+---------------------+
#inception.statistic表存儲的就是SQL執行數目的統計數據
參考：http://mysql-inception.github.io/inception-document/statistic/
#IP_PORT_dbname庫下表中記錄了對應的rollback操作
除了與原庫中的表一一對應之外，每個備份庫中還有另外一個表：$_$Inception_backup_information$_$，這就是表名，非常難看，主要是為了防止與原線上庫中的表名發生沖突。這個表是用來存儲所有對當前庫操作的操作記錄的，它是公用的，對線上這個庫的所有表操作記錄都存儲在這里面
參考鏈接：http://mysql-inception.github.io/inception-document/backup/
參考：http://mysql-inception.github.io/inception-document/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
]$ 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; #設置表大小超過此參數的值時，inception調用osc工具alter表
]$ 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
Backup successfully | None | alter table test add a int not null default 0 comment 'a字段' | 1 | '1464335727_270_1' | 127_0_0_1_3306_test | 149.880 | *8388D07BAD14866D80DD45CD1521F4F0D17C20CE
#查看osc列表
mysql> inception get osc processlist;
#由上面的processlist可以看到正在執行的osc任務對應的SQLSHA1值，然后使用下方命令可以查看指定的一條osc任務進度
mysql> inception get osc_percent '*8388D07BAD14866D80DD45CD1521F4F0D17C20CE';
+--------+-----------+-------------------------------------------+---------+------------+-----------------------------------
| DBNAME | TABLENAME | SQLSHA1 | PERCENT | REMAINTIME | INFOMATION
+--------+-----------+-------------------------------------------+---------+------------+----------------------------------------------------------------------------------------| 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*/
mysql> desc test;
+-------+---------+------+-----+---------+----------------+
| Field | Type | Null | Key | Default | Extra |
+-------+---------+------+-----+---------+----------------+
| 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)
參考http://mysql-inception.github.io/inception-document/rules/
下面所列出來的規則，不一定能覆蓋所有Inception當前已經實現的功能，具體包括什么規則，還需要在使用過程中總結，發現，同時可以結合配置參數來詳細了解這些規則。
l use db：此時會檢查這個庫是不是存在，需要連接到線上服務器來判斷。
l set option：現在只需要支持set names charset，設置其它變量時都報錯不支持。
l 創建數據庫語句
l 插入語句（包括多值插入）
l 查詢插入語句
l 刪除語句（包括多表刪除）
l 更新語句（包括多表更新）
l 創建表語句
l 刪除表語句
l 修改表語句
l Truncate表語句
l inception命令集語句（包括管理命令）
l 表是否存在
l 必須指定插入列表，也就是要對哪幾個列指定插入值，如insert into t (id,id2) values(...)，（可配置）
l 必須指定值列表，與上面對應的列，插入的值是什么，必須要指定。
l 插入列列表與值列表個數相同，上面二者的個數需要相同，如果沒有指定列列表（因為可配置），則值列表長度要與表列數相同。
l 不為null的列，如果插入的值是null，報錯（可配置）
l 插入指定的列名對應的列必須是存在的。
l 插入指定的列列表中，同一個列不能出現多次。
l 插入值列表中的簡單表達式會做檢查，但具體包括什么不一一指定
l 表是否存在
l 必須有where條件（可配置）
l delete語句不能有limit條件（可配置）
l 不能有order by語句（可配置）
l 影響行數大于10000條，則報警（數目可配置）
l 對WHERE條件這個表達式做簡單檢查，具體包括什么不一一指定
l 對更新列的值列表表達式做簡單檢查，具體不一一指定
l 對更新列對象做簡單檢查，主要檢查列是不是存在等
l 多表更新、刪除時，每個表必須要存在
l 這個表不存在
l 對于create table like，會檢查like的老表是不是存在。
l 對于create table db.table，會檢查db這個數據庫是不是存在
l 表名、列名、索引名的長度不大于64個字節
l 如果建立的是臨時表，則必須要以tmp為前綴
l 必須要指定建立innodb的存儲引擎（可配置）
l 必須要指定utf8的字符集（字符串可配置，指定支持哪些字符集）
l 表必須要有注釋（可配置）
l 表不能建立為分區表（可配置）
l 只能有一個自增列
l 索引名字不能是Primay
l 不支持Foreign key（可配置）
l 建表時，如果指定auto_increment的值不為1，報錯（可配置）
l 如果自增列的名字不為id，說明有可能是有意義的，MySQL這樣使用比較危險，所以報警（可配置）
l 不能設置列的字符集（可配置）
l 列的類型不能使用集合、枚舉、位圖類型。（可配置）
l 列必須要有注釋（可配置）
l char長度大于20的時候需要改為varchar（長度可配置）
l 列的類型不能是BLOB/TEXT。（可配置）
l 每個列都使用not null（可配置）
l 如果列為BLOB/TEXT類型的，則這個列不能設置為NOT NULL。
l 如何是自增列，則使用無符號類型（可配置）
l 如果自增列，則長度必須要大于等于4個字節（可配置）
l 如果是timestamp類型的，則要必須指定默認值。
l 對于MySQL5.5版本（包含）以下的數據庫，不能同時有兩個TIMESTAMP類型的列，如果是DATETIME類型，則不能定義成DATETIME DEFAULT CURRENT_TIMESTAMP及ON UPDATE CURRENT_TIMESTAMP等語句。
l 每個列都需要定義默認值，除了自增列、主鍵列及大字段列之外（可配置）
l 不能有重復的列名
l 索引必須要有名字
l 不能有外鍵（可配置）
l Unique索引必須要以uniq_為前綴（可配置）
l 普通索引必須要以idx_為前綴（可配置）
l 索引的列數不能超過5個（數目可以配置）
l 表必須要有一個主鍵（可配置）
l 最多有5個索引（數目可配置）
l 建索引時，指定的列必須存在。
l 索引中的列，不能重復
l BLOB列不能建做KEY
l 索引長度不能超過766
l 不能有重復的索引，名字及內容
l BLOB/TEXT類型的列，不能有非NULL的默認值
l MySQL5.5以下（含）的版本，對于DATETIME類型的列，不能有函數NOW()的默認值。
l 如果設置默認值為函數，則只能是NOW()。
l 如果默認值為NULL，但列類型為NOT NULL，或者是主鍵列，或者定義為自增列，則報錯。
l 自增列不能設置默認值。
l 修改表語句檢查項
l 表是不是存在
l 同上面創建表中的索引檢查項
l 同上面創建表中的列檢查項
l 表是不是存在
l 如果語句塊中存在多條對同一個表的修改語句，則建議合并成一個ALTER語句
l 列是否存在
l 剩下的同上面創建表，創建索引，創建列，默認值等檢查項一樣
l 表是不是存在
l 檢查索引是不是存在
l 同默認值檢查項
l 表屬性只支持對存儲引擎、表注釋、自增值及默認字符集的修改操作。
l 修改存儲引擎時檢查是不是Innodb（可配置）。
l 字符集修改檢查是不是屬于設置參數的值（支持字符集可配置）。
l 字符集修改檢查是不是屬于設置參數的值（支持字符集可配置）。
針對線上MySQL服務器是不是5.6以上（包含）版本，有不同的處理策略，比如在預估影響行數時，5.6可以直接對任何DML語句做EXPLAIN操作，而在5.5版本中，只支持對SELECT語句執行EXPLAIN操作，而在5.5版本中，有些DML語句是不容易直接轉換為SELECT語句去做EXPLAIN，這樣導致預估行數為0。
還是針對5.6以上版本與5.5版本的不同，DATETIME、TIMESTAMP系列類型在執行時，5.5的限制比較多，而5.6基本通用，所以這上面的處理可能在5.6及5.5版本上，相同語句返回的結果集是不同的（規則是在5.5中以在執行時報的錯誤信息為準），這與線上版本有關系。
]$ 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 '測試';\
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])
]$ 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])
]$ 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])
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
