四时宝库

程序员的知识宝库

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


发表评论:

控制面板
您好,欢迎到访网站!
  查看权限
网站分类
最新留言
    友情链接