用 PyMySQL 包来连接Python和MySQL。在使用前需要先通过 pip 来安装 PyMySQL包:
在windows 系统中打开cmd,输入
pip install PyMySQL
1、安装完成后,就可以使用以下连接代码:
import pymysql
DBHOST = 'localhost'
DBUSER = 'root'
DBPASS = 'root123'
DBNAME = 'test'
charset = 'utf8'
try:
db = pymysql.connect(host=DBHOST, user=DBUSER, password=DBPASS, database=DBNAME, charset=charset)
print('数据库连接成功')
except pymysql.Error as error:
print('数据库连接失败' + str(error))
运行结果:
2、在数据库连接成功后,就可以对数据库进行各种操作
# 创建新表
# 1、 声明一个游标
cur = db.cursor()
# 2、创建表之前先检查是否存在,如果存在则删除
cur.execute('DROP TABLE IF EXISTS Student')
# 3、输入创建新表的sql语句
sqlQuery = "CREATE TABLE Student(Name CHAR(20) NOT NULL ,Email CHAR(20),Age int)"
# 4、 运行mysql代码
cur.execute(sqlQuery)
创建完表后,就可以向表格中插入数据
# -*- encoding: utf-8 -*-
import pymysql
# 数据库的各种配置
DBHOST = 'localhost'
DBUSER = 'root'
DBPASS = 'root123'
DBNAME = 'test'
charset = 'utf8'
def insertDate(db):
# 插入数据
# 1、 声明一个游标
cur = db.cursor()
# 2、编写sql语句
sqlQuery = " INSERT INTO Student (Name, Email, Age) VALUE (%s,%s,%s) "
# 3、设置具体的数据
value = ('jake', '123456@qq.com', 20)
cur.execute(sqlQuery,value)
db.commit()
print('数据插入成功!')
# 连接数据库
try:
db = pymysql.connect(host=DBHOST, user=DBUSER, password=DBPASS, database=DBNAME, charset=charset)
print('数据库连接成功')
insertDate(db)
except pymysql.Error as error:
print('数据库连接失败' + str(error))
插入数据完成后,就可以查询表格数据:
# -*- encoding: utf-8 -*-
import pymysql
# 数据库的各种配置
DBHOST = 'localhost'
DBUSER = 'root'
DBPASS = 'root123'
DBNAME = 'test'
charset = 'utf8'
def selectDate(db):
#查询全部数据
cur = db.cursor()
# 这里输入sql语句
sqlQuery = "SELECT * FROM Student"
col = cur.execute(sqlQuery) # 查询之前需要先运行sql语句
results = cur.fetchall() # 只有上面先运行了sql语句这句话才可以运行成功
print(col) # 结果为影响的条数
for row in results:
name = row[0]
email = row[1]
age = row[2]
print('Name:%s,Email:%s,Age:%s' % (name, email, age))
# 连接数据库
try:
db = pymysql.connect(host=DBHOST, user=DBUSER, password=DBPASS, database=DBNAME, charset=charset)
print('数据库连接成功')
selectDate(db)
except pymysql.Error as error:
print('数据库连接失败' + str(error))
接下来是删除表中的数据
# -*- encoding: utf-8 -*-
import pymysql
# 数据库的各种配置
DBHOST = 'localhost'
DBUSER = 'root'
DBPASS = 'root123'
DBNAME = 'test'
charset = 'utf8'
def deleteDate(db):
# 删除表中的数据
cur = db.cursor()
# 这里输入sql语句
sqlQuery = "delete from student where name=%s"
value = ('John')
cur.execute(sqlQuery, value)
db.commit()
print('数据更新成功!')
# 连接数据库
try:
db = pymysql.connect(host=DBHOST, user=DBUSER, password=DBPASS, database=DBNAME, charset=charset)
print('数据库连接成功')
except pymysql.Error as error:
print('数据库连接失败' + str(error))