python 连接 mysql 数据库（python连接MySQL数据库案例）

用 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))