Python MySQL数据库基本操作及项目示例详解

目录
  • 一、数据库基础用法
  • 二、项目:银行管理系统
    • 1、进行初始化操作
    • 2、登录检查,并选择操作
    • 3、加入查询功能
    • 4、加入取钱功能
    • 5、加入存钱功能

一、数据库基础用法

要先配置环境变量,然后cmd安装:pip install pymysql

1、连接MySQL,并创建wzg库

#引入decimal模块
import pymysql

#连接数据库
db=pymysql.connect(host='localhost',user='root',password='1234',charset='utf8')

#创建一个游标对象(相当于指针)
cursor=db.cursor()

#执行创建数据库语句
cursor.execute('create schema wzg default charset=utf8;')
cursor.execute('show databases;')

#fetchone获取一条数据(元组类型)
print(cursor.fetchone())
#现在指针到了[1]的位置

#fetchall获取全部数据(字符串类型)
all=cursor.fetchall()
for i in all:
    print(i[0])

#关闭游标和数据库连接
cursor.close()
db.close()

2、创建student表,并插入数据

import pymysql

#连接数据库,并打开wzg数据库(数据库已创建)
db=pymysql.connect(host='localhost',user='root',password='1234',charset='utf8',db='wzg')

#创建游标对象
cursor=db.cursor()

try:
    #创建student表,并执行
    sql='''create table student(
       SNO char(10),
       SNAME varchar(20) NOT NULL,
       SSEX varchar(1),
       primary key(SNO)
       )default charset=utf8;'''
    cursor.execute(sql)

    #插入一条数据,并执行
    insert_sql='''
    insert into student values('200303016','王智刚','男'),('20030001','小明','男')
    '''
    cursor.execute(insert_sql)

    #将数据提交给数据库(加入数据,修改数据要先提交)
    db.commit()

    #执行查询语句
    cursor.execute('select * from student')

    #打印全部数据
    all=cursor.fetchall()
    for i in all:
        print(i)

#发生错误时,打印报错原因
except Exception as e:
    print(e)

#无论是否报错都执行
finally:
    cursor.close()
    db.close()

数据库中char和varchar的区别:

char类型的长度是固定的,varchar的长度是可变的。

例如:存储字符串'abc',使用char(10),表示存储的字符将占10个字节(包括7个空字符),

使用varchar(10),表示只占3个字节,10是最大值,当存储的字符小于10时,按照实际的长度存储。

二、项目:银行管理系统

完成功能:1.查询 2.取钱 3.存钱 4.退出

练习:创建信息表,并进行匹配

1、创建数据库为(bank),账户信息表为(account)

account_id(varchar(20)) Account_passwd(char(6)) Money(decimal(10,2))
001 123456 1000.00
002 456789 5000.00

2、拓展:进行账号和密码的匹配

请输入账号:001

请输入密码:123456

select * from account where account_id=001 and Account_passwd=123456
if cursor.fetchall():
登录成功
else:
登录失败
import pymysql

# 连接数据库
db = pymysql.connect(host='localhost', user='root', password='1234', charset='utf8')
cursor = db.cursor()

# 创建bank库
cursor.execute('create database bank charset utf8;')
cursor.execute('use bank;')

try:
    # # 创建表
    # sql = '''create table account(
    #    account_id varchar(20) NOT NULL,
    #    account_passwd char(6) NOT NULL,
    #    money decimal(10,2),
    #    primary key(account_id)
    #    );'''
    # cursor.execute(sql)

    # # 插入数据
    # insert_sql = '''
    # insert into account values('001','123456',1000.00),('002','456789',5000.00)
    # '''
    # cursor.execute(insert_sql)
    # db.commit()

    # # 查询所有数据
    # cursor.execute('select * from account')
    # all = cursor.fetchall()
    # for i in all:
    #     print(i)

    # 输入账号和密码
    z=input("请输入账号:")
    m=input("请输入密码:")

    # 从account表中进行账号和密码的匹配
    cursor.execute('select * from account where account_id=%s and account_passwd=%s',(z,m))

    # 如果找到,则登录成功
    if cursor.fetchall():
        print('登录成功')
    else:
        print('登录失败')

except Exception as e:
    print(e)

finally:
    cursor.close()
    db.close()

1、进行初始化操作

import pymysql

# 创建bank库
CREATE_SCHEMA_SQL='''
    create schema bank charset utf8;
    '''

# 创建account表
CREATE_TABLE_SQL = '''
    create table account(
    account_id varchar(20) NOT NULL,
    account_passwd char(6) NOT NULL,
    # decimal用于保存精确数字的类型,decimal(10,2)表示总位数最大为12位,其中整数10位,小数2位
    money decimal(10,2),
    primary key(account_id)
    ) default charset=utf8;
    '''

# 创建银行账户
CREATE_ACCOUNT_SQL = '''
    insert into account values('001','123456',1000.00),('002','456789',5000.00);
    '''

# 初始化
def init():
    try:
        DB = pymysql.connect(host='localhost',user='root',password='1234',charset='utf8')
        cursor1 = DB.cursor()
        cursor1.execute(CREATE_SCHEMA_SQL)
        DB = pymysql.connect(host='localhost',user='root',password='1234',charset='utf8',database='bank')
        cursor2 = DB.cursor()
        cursor2.execute(CREATE_TABLE_SQL)
        cursor2.execute(CREATE_ACCOUNT_SQL)
        DB.commit()
        print('初始化成功')

except Exception as e:
    print('初始化失败',e)

finally:
    cursor1.close()
    cursor2.close()
    DB.close()  

    # 不让别人调用
if __name__ == "__main__":
    init()

2、登录检查,并选择操作

import pymysql

# 定义全局变量为空
DB=None

# 创建Account类
class Account():
    # 传入参数
    def __init__(self,account_id,account_passwd):
        self.account_id=account_id
        self.account_passwd=account_passwd

    # 登录检查
    def check_account(self):
        cursor=DB.cursor()
        try:
            # 把输入账号和密码进行匹配(函数体内部传入参数用self.)
            SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)

            # 匹配成功返回True,失败返回False
            if cursor.fetchall():
                return True
            else:
                return False

        except Exception as e:
            print("错误原因:",e)
        finally:
            cursor.close()

    # 查询余额
    # def query_money

    # 取钱
    # def reduce_money

    # 存钱
    # def add_money

def main():
    # 定义全局变量
    global DB

    # 连接bank库
    DB=pymysql.connect(host="localhost",user="root",passwd="1234",database="bank")
    cursor=DB.cursor()

    # 输入账号和密码
    from_account_id=input("请输入账号:")
    from_account_passwd=input("请输入密码:")

    # 输入的参数传入给Account类,并创建account对象
    account=Account(from_account_id,from_account_passwd)

    # 调用check_account方法,进行登录检查
    if account.check_account():
        choose=input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        # 当输入不等于4的时候执行,等于4则退出
        while choose!="4":
            # 查询
            if choose=="1":
                print("111")
            # 取钱
            elif choose=="2":
                print("222")
            # 存钱
            elif choose=="3":
                print("333")
            # 上面操作完成之后,继续输入其他操作
            choose = input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        else:
            print("谢谢使用!")
    else:
        print("账号或密码错误")
    DB.close()
main()

3、加入查询功能

存在银行里的钱可能会产生利息,所以需要考虑余额为小数的问题,需要用到decimal库

import pymysql
# 引入decimal模块
import decimal
DB=None
class Account():

    def __init__(self,account_id,account_passwd):
        self.account_id=account_id
        self.account_passwd=account_passwd

    # 登录检查
    def check_account(self):
        cursor=DB.cursor()
        try:
            SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            if cursor.fetchall():
                return True
            else:
                return False
        except Exception as e:
            print("错误",e)
        finally:
            cursor.close()

    # 查询余额
    def query_money(self):
        cursor=DB.cursor()
        try:
            # 匹配账号密码,并返回money
            SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            money=cursor.fetchone()[0]
            # 如果账户有钱就返回金额,没钱返回0.00
            if money:
                # 返回值为decimal类型,quantize函数进行四舍五入,'0.00'表示保留两位小数
                return str(money.quantize(decimal.Decimal('0.00')))
            else:
                return 0.00
        except Exception as e:
            print("错误原因",e)
        finally:
            cursor.close()

def main():
    global DB
    DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
    cursor=DB.cursor()
    from_account_id=input("请输入账号:")
    from_account_passwd=input("请输入密码:")
    account=Account(from_account_id,from_account_passwd)
    if account.check_account():
        choose=input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        while choose!="4":
            # 查询
            if choose=="1":
                # 调用query_money方法
                print("您的余额是%s元" % account.query_money())
            # 取钱
            elif choose=="2":
                print("222")
            # 存钱
            elif choose=="3":
                print("333")
            choose = input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        else:
            print("谢谢使用")
    else:
        print("账号或密码错误")
    DB.close()
main()

4、加入取钱功能

取钱存钱要用update来执行数据库,还要注意取钱需要考虑余额是否充足的问题

import pymysql
import decimal
DB=None
class Account():

    def __init__(self,account_id,account_passwd):
        self.account_id=account_id
        self.account_passwd=account_passwd

    # 登录检查
    def check_account(self):
        cursor=DB.cursor()
        try:
            SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            if cursor.fetchall():
                return True
            else:
                return False
        except Exception as e:
            print("错误",e)
        finally:
            cursor.close()

    # 查询余额
    def query_money(self):
        cursor=DB.cursor()
        try:
            SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            money=cursor.fetchone()[0]
            if money:
                return str(money.quantize(decimal.Decimal('0.00')))
            else:
                return 0.00
        except Exception as e:
            print("错误原因",e)
        finally:
            cursor.close()

    # 取钱(注意传入money参数)
    def reduce_money(self,money):
        cursor = DB.cursor()
        try:
            # 先调用query_money方法,查询余额
            has_money=self.query_money()

            # 所取金额小于余额则执行(注意类型转换)
            if decimal.Decimal(money) <= decimal.Decimal(has_money):

                # 进行数据更新操作
                SQL="update account set money=money-%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
                cursor.execute(SQL)

                # rowcount进行行计数,行数为1则将数据提交给数据库
                if cursor.rowcount==1:
                    DB.commit()
                    return True
                else:
                    # rollback数据库回滚,行数不为1则不执行
                    DB.rollback()
                    return False
            else:
                print("余额不足")
        except Exception as e:
            print("错误原因",e)
        finally:
            cursor.close()

    # 存钱
    # def add_money

def main():
    global DB
    DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
    cursor=DB.cursor()
    from_account_id=input("请输入账号:")
    from_account_passwd=input("请输入密码:")
    account=Account(from_account_id,from_account_passwd)
    if account.check_account():
        choose=input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        while choose!="4":
            # 查询
            if choose=="1":
                print("您的余额是%s元" % account.query_money())
            # 取钱
            elif choose=="2":
                # 先查询余额,再输入取款金额,防止取款金额大于余额
                money=input("您的余额是%s元,请输入取款金额" % account.query_money())
                # 调用reduce_money方法,money不为空则取款成功
                if account.reduce_money(money):
                    print("取款成功,您的余额还有%s元" % account.query_money())
                else:
                    print("取款失败!")
            # 存钱
            elif choose=="3":
                print("333")
            choose = input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        else:
            print("谢谢使用!")
    else:
        print("账号或密码错误")
    DB.close()
main()

5、加入存钱功能

存钱功能和取钱功能相似,而且不需要考虑余额的问题,至此已完善当前所有功能 

import pymysql
import decimal
DB=None
class Account():
    def __init__(self,account_id,account_passwd):
        self.account_id=account_id
        self.account_passwd=account_passwd

    # 登录检查
    def check_account(self):
        cursor=DB.cursor()
        try:
            SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            if cursor.fetchall():
                return True
            else:
                return False
        except Exception as e:
            print("错误",e)
        finally:
            cursor.close()

    # 查询余额
    def query_money(self):
        cursor=DB.cursor()
        try:
            SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
            cursor.execute(SQL)
            money=cursor.fetchone()[0]
            if money:
                return str(money.quantize(decimal.Decimal('0.00')))
            else:
                return 0.00
        except Exception as e:
            print("错误原因",e)
        finally:
            cursor.close()

    # 取钱
    def reduce_money(self,money):
        cursor = DB.cursor()
        try:
            has_money=self.query_money()
            if decimal.Decimal(money) <= decimal.Decimal(has_money):
                SQL="update account set money=money-%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
                cursor.execute(SQL)
                if cursor.rowcount==1:
                    DB.commit()
                    return True
                else:
                    DB.rollback()
                    return False
            else:
                print("余额不足")
        except Exception as e:
            print("错误原因",e)
        finally:
            cursor.close()

    # 存钱
    def add_money(self,money):
        cursor = DB.cursor()
        try:
            SQL="update account set money=money+%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
            cursor.execute(SQL)
            if cursor.rowcount==1:
                DB.commit()
                return True
            else:
                DB.rollback()
                return False
        except Exception as e:
            DB.rollback()
            print("错误原因",e)
        finally:
            cursor.close()

def main():
    global DB
    DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
    cursor=DB.cursor()
    from_account_id=input("请输入账号:")
    from_account_passwd=input("请输入密码:")
    account=Account(from_account_id,from_account_passwd)
    if account.check_account():
        choose=input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        while choose!="4":
            # 查询
            if choose=="1":
                print("您的余额是%s元" % account.query_money())
            # 取钱
            elif choose=="2":
                money=input("您的余额是%s元,请输入取款金额" % account.query_money())
                if account.reduce_money(money):
                    print("取款成功,您的余额还有%s元" % account.query_money())
                else:
                    print("取款失败!")
            # 存钱
            elif choose=="3":
                money=input("请输入存款金额:")
                if account.add_money(money):
                    print("存款成功,您的余额还有%s元,按任意键继续\n" % (account.query_money()))
                else:
                    print("存款失败,按任意键继续")
            choose = input("请输入操作:\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
        else:
            print("谢谢使用!")
    else:
        print("账号或密码错误")
    DB.close()
main() 

以上就是Python MySQL数据库基本操作及项目示例详解 的详细内容,更多关于Python MySQL数据库操作的资料请关注我们其它相关文章!

(0)

相关推荐

  • python mysql实现学生成绩管理系统

    这学期在学python,感觉想写一个东西来巩固自己的基础,因为大二的时候我看过python,所以还是一共花了几个小时写了一个基于mysql的成绩管理系统,这个东西其实拿不出手,不过就当复习基本了. 1 .首先如果你python中没安装mysql的驱动,还是要打开cmd命令行安装一下才可以使用: pip3 install PyMySQL 2 .创建数据库studentdb,你可以在图形化界面sqlyog中创建: 3 .然后在数据库中创建表st 4 .python连接数据库的核心代码: db = p

  • Python 操作 MySQL数据库

    开发环境与配置 win_x64 Ubuntu14.04 Python3.x pip安装pymysql模块 直接使用pip安装 pip install pymysql win64上直接在cmd中执行 连接本地数据库 使用模块pymysql连接数据库 本地数据库相关配置请参阅: http://rustfisher.github.io/2017/02/25/backend/MySQL_install/ #!/usr/bin/python # coding=utf-8 import pymysql #

  • python+mysql实现个人论文管理系统

    本文实例为大家分享了python mysql个人论文管理系统的具体代码,供大家参考,具体内容如下 1.mysql数据库建表 在mysql数据库里面建立两个表,分别是用户表和论文表.建表的方式有很多,可以直接用sql语句进行建表,也可以在Navicat里面直接建,在Navicat里面可以清楚的看到我们建表的类型和表中的数据. 上图是用户表的数据类型 上图是论文表的数据类型 上图是论文表的样例 上图是用户表的样例 2.流程实现展示 本次系统的实现主要用到python的pymysql库来连接mysql

  • python+mysql实现学生信息查询系统

    本文实例为大家分享了python mysql学生信息查询系统的具体代码,供大家参考,具体内容如下 import pymysql #import redis #pool = redis.ConnectionPool(host='IP地址', port=6379, decode_responses=True) while True: while True: # print('=' * 15) user = str(input('请输入用户名:')) passwd = str(input('请输入密码

  • Python基础之操作MySQL数据库

    一.数据库操作 1.1 安装PyMySQL pip install PyMySQL 1.2 连接数据库 python连接test数据库 import pymysql host = 'localhost' # 主机地址 username = 'root' # 数据库用户名 password = '' # 数据库密码 db_name = 'test' # 数据库名称 # 创建connect对象 connect = pymysql.connect(host=host, user=username, p

  • Python操作MySQL数据库的示例代码

    1. MySQL Connector 1.1 创建连接 import mysql.connector config={ "host":"localhost","port":"3306", "user":"root","password":"password", "database":"demo" } con=

  • Python MySQL数据库基本操作及项目示例详解

    目录 一.数据库基础用法 二.项目:银行管理系统 1.进行初始化操作 2.登录检查,并选择操作 3.加入查询功能 4.加入取钱功能 5.加入存钱功能 一.数据库基础用法 要先配置环境变量,然后cmd安装:pip install pymysql 1.连接MySQL,并创建wzg库 #引入decimal模块 import pymysql #连接数据库 db=pymysql.connect(host='localhost',user='root',password='1234',charset='ut

  • Python写入MySQL数据库的三种方式详解

    目录 场景一:数据不需要频繁的写入mysql 场景二:数据是增量的,需要自动化并频繁写入mysql 方式一 方式二 总结 大家好,Python 读取数据自动写入 MySQL 数据库,这个需求在工作中是非常普遍的,主要涉及到 python 操作数据库,读写更新等,数据库可能是 mongodb. es,他们的处理思路都是相似的,只需要将操作数据库的语法更换即可. 本篇文章会给大家分享数据如何写入到 mysql,分为两个场景,三种方式. 场景一:数据不需要频繁的写入mysql 使用 navicat 工

  • Python开发自定义Web框架的示例详解

    目录 开发自定义Web框架 1.开发Web服务器主体程序 2.开发Web框架主体程序 3.使用模板来展示响应内容 4.开发框架的路由列表功能 5.采用装饰器的方式添加路由 6.电影列表页面的开发案例 开发自定义Web框架 接收web服务器的动态资源请求,给web服务器提供处理动态资源请求的服务.根据请求资源路径的后缀名进行判断: 如果请求资源路径的后缀名是.html则是动态资源请求, 让web框架程序进行处理. 否则是静态资源请求,让web服务器程序进行处理. 1.开发Web服务器主体程序 1.

  • MySQL数据库子查询语法规则详解

    目录 子查询简介 WHERE 子查询 FROM 子查询 SELECT 子查询 子查询是在查询语句里面再嵌套一个查询,这是因为我们在提取数据的时候有很多不知道的数据产生了依赖关系.此时我们就需要先查询一组数据的结果集,然后将这个结果集作用为下一个查询的对象.在 “表连接的章节”,我们曾说过子查询的效率低下的问题,其实并不是所有的子查询效率都是低下的,“WHERE” 子查询在匹配记录的时候要反复执行,这是不推荐使用的:但是如果将查询结果集当做一张表来使用,与其他的表做一个连接,这就是 “FROM”

  • Python实现解析yaml配置文件的示例详解

    目录 楔子 字典 数组 标量 引用 生成 yaml 文件 楔子 前面我们介绍了 ini 格式的配置文件,本次来看看 yaml,它的表达能力相比 ini 更加的强大.yaml 文件以 .yml 结尾,在介绍它的语法结构之前我们先来看看 yaml 的一些基本规则. 大小写敏感: 使用缩进表示层级关系,并且缩进只能用空格.不可以使用 tab 键.缩进的空格数目不重要,只要相同层级的元素左侧对齐即可: # 表示注释,# 到行尾的所有字符都会被忽略: yaml 支持的数据结构有以下三种: 字典:键值对的集

  • JDBC连接MySQL数据库批量插入数据过程详解

    这篇文章主要介绍了JDBC连接MySQL数据库批量插入数据过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 1.读取本地json数据 2.jdbc理解数据库 3.批量插入 maven 引入jar包: <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2

  • MySql中子查询内查询示例详解

    西北望乡何处是,东南见月几回圆. 月亮又慢悠悠的挂上了天空,趁着睡前梦呓,我就带领各位可爱的读者们探索MySql最后的子查询部分. 说明:有些查询结果出来结果截图与题目要求不一样会出现多余的字段是为了方便展示结果的可读性.实际操作的读者可以删除SELECT后面多余的字段得到正确的结果. #WHERE或HAVING后面 #1.标量子查询(单行子查询) #2.列子查询(多行子查询) #3.行子查询(多列多行) #特点: # ①子查询放在小括号内 # ②子查询一般放在条件的右侧 # ③标量子查询:一般

  • MySQL教程DML数据操纵语言示例详解

    目录 1.数据操纵语言(DML) 2.增添数据(insert) 3.复制已有表,生成新表 1)复制已有表的结构和数据. 2)只复制已有表的结构(得到的是一个空结构表). 3)在2的基础上,向空结构表中插入数据. 4.修改数据update 5.删除数据delete:物理删除(一旦删除就彻底没有了). 6.truncate和delete的区别 1)delete 2)truncate 3)truncate和delete的区别 1.数据操纵语言(DML) 数据操纵语言全称是Data Manipulati

  • python可视化大屏库big_screen示例详解

    目录 big_screen 特点 安装环境 输入数据 本地运行 在线部署 对于从事数据领域的小伙伴来说,当需要阐述自己观点.展示项目成果时,我们需要在最短时间内让别人知道你的想法.我相信单调乏味的语言很难让别人快速理解.最直接有效的方式就是将数据如上图所示这样,进行可视化展现. 具体如下: big_screen 特点 便利性工具, 结构简单, 你只需传数据就可以实现数据大屏展示. 安装环境 pip install -i https://pypi.tuna.tsinghua.edu.cn/simp

  • python机器学习Sklearn实战adaboost算法示例详解

    目录 pandas批量处理体测成绩 adaboost adaboost原理案例举例 弱分类器合并成强分类器 pandas批量处理体测成绩 import numpy as np import pandas as pd from pandas import Series,DataFrame import matplotlib.pyplot as plt data = pd.read_excel("/Users/zhucan/Desktop/18级高一体测成绩汇总.xls") cond =

随机推荐