版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/baidu_20183817/article/details/80931781
用python来实现对mysql增删改查的操作,具体代码如下:
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
#打开数据库连接
db = MySQLdb.connect("localhost","root","1181ff69","test_demo",charset='utf8' )
# 使用cursor()方法获取操作游标
cursor = db.cursor()
# 使用execute方法执行SQL语句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法获取一条数据
data = cursor.fetchone()
print "Database version : %s " % data
cursor.execute("drop table if exists test_demo.employee")
sql="""CREATE TABLE test_demo.EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
print '建表语句为:'+sql
print '建表完毕'
insertsql1="""insert into test_demo.employee values ("12","wen",27,'m',112222.001);"""
insertsql2="""insert into test_demo.employee values ("11","wen",27,'m',112222.001);"""
insertsql3="""insert into test_demo.employee values ("13","wen",27,'m',112222.001);"""
try:
cursor.execute(insertsql1)
cursor.execute(insertsql2)
cursor.execute(insertsql3)
db.commit()
except:
db.rollback()
print 'error'
print '插入语句为:'+insertsql1
print '插入成功'
# 数据库查询操作
querysql="""select * from employee """
cursor.execute(querysql)
# 获取所有记录列表
print '查询语句为:'+querysql
results = cursor.fetchall()
print type(results)
for i in results:
# print i[0]
# print i[1]
# print i[2]
# print i[3]
print i
# print type(i)
print 'query成功'
# 关闭数据库连接
db.close()