#/usr/bin/python
#coding=utf-8
#@Time :2017/11/21 0:20
#@Auther :liuzhenchuan
#@File :mysql 数据操作.py
import MySQLdb
def connect_mysql():
db_config={
'host':'192.168.16.70',
'port':3306,
'user':'root',
'db':'python',
'passwd':'123123',
'charset':'utf8'
}
try:
cnx=MySQLdb.connect (**db_config)
except Exception as e:
raise e
return cnx
connect_mysql()
# print connect_mysql()
if __name__ == "__main__":
sql = 'create table test(id int not null); insert into test(id) values (100);'
cnx = connect_mysql()
#查看链接数据库cnx 的方法
#cursor 游标 execute 执行
# print dir(cnx)
cus = cnx.cursor()
try:
#执行游标
cus.execute(sql)
#关闭游标
cus.close()
#mysql 提交
cnx.commit()
except Exception as e:
raise e
#有异常进行回滚
cnx.rollback()
finally:
#没有异常关闭连接
cnx.close()
linux系统登录mysql进行查看，创建了test表，插入了语句
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| cactidb |
| mysql |
| performance_schema |
| python |
| test |
+--------------------+
6 rows in set (0.00 sec)
mysql> use python;
Database changed
mysql> show tables;
+------------------+
| Tables_in_python |
+------------------+
| employees |
| test |
+------------------+
2 rows in set (0.00 sec)
mysql> select *from test;
+-----+
| id |
+-----+
| 100 |
+-----+
1 row in set (0.00 sec)