超详细Python连接Mysql数据库

一、环境准备

安装mysql依赖库

方式一
在这里插入图片描述
建议使用豆瓣进行下载镜像(国内最快镜像)
如何配置豆瓣镜像点击此链接链接: 配置豆瓣镜像

#升级pip,保证pip下载的pymysql是最新版本的
pip intsall -U pip
#安装pymysql依赖项
pip install pymysql

方式二

在这里插入图片描述
在这里插入图片描述
以上环境就准备好啦,下面进入编写程序环节

二、代码编写

添加操作

#导入mysql依赖库
import pymysql

def main():
    # 1、获取数据库连接
    #host:Mysql安装的主机地址 port:端口号(默认为3306) user:mysql用户名 password:密码 database:连接的数据库 charset:设置字符编码
    conn = pymysql.connect(host='localhost',port=3306,user='root',password='123456',database='mydata',charset='utf8')
    try:
        # 2、获取游标对象(数据库操作对象)
        with conn.cursor() as cursor:  # 上下文语法
            # 3、执行sql语句
            result = cursor.execute('insert into person values(null,"eee",2500)')
            if result == 1:
                print('添加成功')
            conn.commit()#成功则提交事务
    except pymysql.MySQLError as error:
        print(error)
        conn.rollback()#出现错误则回滚事务
    finally:
        # 4、释放资源
        conn.close()



if __name__=='__main__':
    main()

删除操作

import pymysql

def main():
    # 1、获取数据库连接
    id = input("请输入需要删除的部门编号:")
    conn = pymysql.connect(host='localhost',port=3306,user='root',password='123456',database='mydata',charset='utf8')
    try:
        # 2、获取游标对象(数据库操作对象)
        with conn.cursor() as cursor:  # 上下文语法
            # 3、执行sql语句

            result = cursor.execute('delete from person where id = "{}"'.format(id))
            if result == 1:
                print('删除成功')
            conn.commit()#成功提交事务
    except pymysql.MySQLError as error:
        print(error)
        conn.rollback()#出现错误回滚事务
    finally:
        # 4、释放资源
        conn.close()



if __name__=='__main__':
    main()

更新操作

import pymysql

def main():
    id = input('编号:')
    name=input('姓名:')
    money=input('金额:')
    # 1、获取数据库连接
    conn = pymysql.connect(host='localhost',port=3306,user='root',password='123456',database='mydata',charset='utf8')
    try:
        # 2、获取游标对象(数据库操作对象)
        with conn.cursor() as cursor:  # 上下文语法
            # 3、执行sql语句
            result = cursor.execute('update person set name="{}" where id={}'.format(name,id))
            if result == 1:
                print('更新成功')
            conn.commit()#成功提交事务
    except pymysql.MySQLError as error:
        print(error)
        conn.rollback()#出现错误回滚事务
    finally:
        # 4、释放资源
        conn.close()



if __name__=='__main__':
    main()

查询操作

import pymysql

def main():
    # 1、获取数据库连接
    conn = pymysql.connect(host='localhost',port=3306,user='root',password='123456',database='mydata',charset='utf8')
    try:
        # 2、获取游标对象(数据库操作对象)
        with conn.cursor() as cursor:  # 上下文语法
            # 3、执行sql语句
            cursor.execute('select id,name,money from person')
            # 4、处理查询结果集 
            '''
            fetchall() -查询所有数据
            fetchone() -查询一条数据
            fetchmony(num) -指定查询多条数据
            '''
            for row in cursor.fetchall():
                print('编号:{}'.format(row[0]))
                print('姓名:{}'.format(row[1]))
                print('金额:{}'.format(row[2]))
                print('-'*20)
    except pymysql.MySQLError as error:
        print(error)
    finally:
        # 4、释放资源
        conn.close()



if __name__=='__main__':
    main()

注意:Python中的MySQL默认事务是开着的,需要手动提交事务,否则操作无效

以上便完成Python连接和操作数据库的入门学习啦!!!

猜你喜欢

转载自blog.csdn.net/qq_45821420/article/details/107893937
今日推荐