开发数据库程序流程:
1.创建connection对象,获取cursor
2.使用cursor执行SQL
3.使用cursor获取数据、判断执行状态
4.提交事务 或者 回滚事务
import:
数据库连接对象:connection
数据库交互对象:
#!/usr/bin/python
# -*- coding: utf-8 -*-
import pymysql
# 创建连接
conn = pymysql.connect(host="10.1.1.36",user='root',password='za5121101112az',port=3306)
# 创建游标
cursor = conn.cursor()
# 执行SQL,并返回收影响行数
cursor.execute("select * from yunwei.hosts")
rows = cursor.fetchall()
print rows
#other
# 执行SQL,并返回受影响行数
#effect_row = cursor.execute("update tb7 set pass = '123' where nid = %s", (11,)) # 执行SQL,并返回受影响行数,执行多次
#effect_row = cursor.executemany("insert into tb7(user,pass,licnese)values(%s,%s,%s)", [("u1","u1pass","11111"),("u2","u2pass","22222")]) # 提交,不然无法保存新建或者修改的数据
conn.commit() # 关闭游标
cursor.close()
# 关闭连接
conn.close()