Python3连接MySQL实现数据库基本操作

一、安装PyMySQL

$ pip install PyMySQL

二、数据库连接

连接前，需要确认以下事项：

（1）已安装PyMySQL模块；

（2）连接数据库使用的用户名及密码；

（3）数据库名称；

（4）表名称；

（5）字段名称；

三、代码实例操作

1、数据库表新建：

import pymysql

# 打开数据库连接

db = pymysql.connect("localhost","root","XXXXXX","world",charset='utf8')

# 使用 cursor() 方法创建一个游标对象 cursor

cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除

cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")

# 使用预处理语句创建表

sql = """CREATE TABLE EMPLOYEE (
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接

db.close()

2、数据库表插入：

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","root","XXXXXX","world",charset='utf8')

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()

# 关闭数据库连接
db.close()

3、数据库表查询：

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","root","XXXXXX","world",charset='utf8')

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM EMPLOYEE" 

try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   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 fetch data")

# 关闭数据库连接
db.close()

参考网址：http://www.runoob.com/python3/python3-mysql.html