赞
踩
1、要安装pymysql模块,pip install pymysql
新增数据,要commit操作:
- #!/usr/bin/python3
-
- import pymysql
-
- # 打开数据库连接
- db = pymysql.connect(host="10.11.xxx",user="test",passwd="test",db="test" ,port=3306)
-
- # 使用 cursor() 方法创建一个游标对象 cursor
- cursor = db.cursor()
-
- # 使用 execute() 方法执行 SQL,如果表存在则删除
- ss = cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
-
- # 使用预处理语句创建表,或update、delete语句,要commit操作
- sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
- LAST_NAME, AGE, SEX, INCOME) \
- VALUES ('%s', '%s', '%d', '%c', '%d' )" % \
- ('Mac', 'Mohan', 20, 'M', 2000)
-
- try:
- # 执行sql语句
- cursor.execute(sql)
- # 执行sql语句
- db.commit()
- except:
- # 发生错误时回滚
- db.rollback()
-
- # 关闭数据库连接
- db.close()
2、查询数据
- #!/usr/bin/python3
-
- import pymysql
-
- # 打开数据库连接
- db = pymysql.connect(host="10.11.xxx",user="test",passwd="test",db="test" ,port=3306)
-
- # 使用cursor()方法获取操作游标
- cursor = db.cursor()
-
- # SQL 查询语句
- sql = "SELECT * FROM EMPLOYEE \
- WHERE INCOME > '%d'" % (1000)
- try:
- # 执行SQL语句
- cursor.execute(sql)
- # 获取所有记录列表
- results = cursor.fetchall()
- #print(results) #可以直接输出结果
- for row in results:
- fname = row[0]
- lname = row[1]
- age = row[2]
- sex = row[3]
- income = row[4]
- # 打印结果
- print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \
- (fname, lname, age, sex, income ))
- except:
- print ("Error: unable to fecth data")
-
- # 关闭数据库连接
- db.close()
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。