devbox
木道寻08
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Python——连接数据库操作_cursor.execute(sql)

作者：木道寻08 | 2024-08-12 09:00:05

赞

踩

cursor.execute(sql)

一、数据库基础用法

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

1、连接MySQL，并创建wzg库

  1. #引入decimal模块
  2. import pymysql
  3.  
  4. #连接数据库
  5. db=pymysql.connect(host='localhost',user='root',password='1234',charset='utf8')
  6.  
  7. #创建一个游标对象（相当于指针）
  8. cursor=db.cursor()
  9.  
  10. #执行创建数据库语句
  11. cursor.execute('create schema wzg default charset=utf8;')
  12. cursor.execute('show databases;')
  13.  
  14. #fetchone获取一条数据（元组类型）
  15. print(cursor.fetchone())
  16. #现在指针到了[1]的位置
  17.  
  18. #fetchall获取全部数据（字符串类型）
  19. all=cursor.fetchall()
  20. for i in all:
  21.     print(i[0])
  22.  
  23. #关闭游标和数据库连接
  24. cursor.close()
  25. db.close()

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

  1. import pymysql
  2.  
  3. #连接数据库，并打开wzg数据库（数据库已创建）
  4. db=pymysql.connect(host='localhost',user='root',password='1234',charset='utf8',db='wzg')
  5.  
  6. #创建游标对象
  7. cursor=db.cursor()
  8.  
  9. try:
  10.     #创建student表，并执行
  11.     sql='''create table student(
  12.        SNO char(10),
  13.        SNAME varchar(20) NOT NULL,
  14.        SSEX varchar(1),
  15.        primary key(SNO)
  16.        )default charset=utf8;'''
  17.     cursor.execute(sql)
  18. 	
  19.     #插入一条数据，并执行
  20.     insert_sql='''
  21.     insert into student values('200303016','王智刚','男'),('20030001','小明','男')
  22.     '''
  23.     cursor.execute(insert_sql)
  24. 	
  25.     #将数据提交给数据库（加入数据，修改数据要先提交）
  26.     db.commit()
  27. 	
  28.     #执行查询语句
  29.     cursor.execute('select * from student')
  30. 	
  31.     #打印全部数据
  32.     all=cursor.fetchall()
  33.     for i in all:
  34.         print(i)
  35.  
  36. #发生错误时，打印报错原因
  37. except Exception as e:
  38.     print(e)
  39.  
  40. #无论是否报错都执行
  41. finally:
  42.     cursor.close()
  43.     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:
登录失败

  1. import pymysql
  2.  
  3. # 连接数据库
  4. db = pymysql.connect(host='localhost', user='root', password='1234', charset='utf8')
  5. cursor = db.cursor()
  6.  
  7. # 创建bank库
  8. cursor.execute('create database bank charset utf8;')
  9. cursor.execute('use bank;')
  10.  
  11. try:
  12.     # # 创建表
  13.     # sql = '''create table account(
  14.     #    account_id varchar(20) NOT NULL,
  15.     #    account_passwd char(6) NOT NULL,
  16.     #    money decimal(10,2),
  17.     #    primary key(account_id)
  18.     #    );'''
  19.     # cursor.execute(sql)
  20.  
  21.     # # 插入数据
  22.     # insert_sql = '''
  23.     # insert into account values('001','123456',1000.00),('002','456789',5000.00)
  24.     # '''
  25.     # cursor.execute(insert_sql)
  26.     # db.commit()
  27.  
  28.     # # 查询所有数据
  29.     # cursor.execute('select * from account')
  30.     # all = cursor.fetchall()
  31.     # for i in all:
  32.     #     print(i)
  33.  
  34.     # 输入账号和密码
  35.     z=input("请输入账号：")
  36.     m=input("请输入密码：")
  37.     
  38.     # 从account表中进行账号和密码的匹配
  39.     cursor.execute('select * from account where account_id=%s and account_passwd=%s',(z,m))
  40.     
  41.     # 如果找到，则登录成功
  42.     if cursor.fetchall():
  43.         print('登录成功')
  44.     else:
  45.         print('登录失败')
  46.  
  47. except Exception as e:
  48.     print(e)
  49.  
  50. finally:
  51.     cursor.close()
  52.     db.close()

1、进行初始化操作

  1. import pymysql
  2.  
  3. # 创建bank库
  4. CREATE_SCHEMA_SQL='''
  5.     create schema bank charset utf8;
  6.     '''
  7.  
  8. # 创建account表
  9. CREATE_TABLE_SQL = '''
  10.     create table account(
  11.     account_id varchar(20) NOT NULL,
  12.     account_passwd char(6) NOT NULL,
  13.     # decimal用于保存精确数字的类型，decimal(10,2)表示总位数最大为12位，其中整数10位，小数2位
  14.     money decimal(10,2),
  15.     primary key(account_id)
  16.     ) default charset=utf8;
  17.     '''
  18.  
  19. # 创建银行账户
  20. CREATE_ACCOUNT_SQL = '''
  21.     insert into account values('001','123456',1000.00),('002','456789',5000.00);
  22.     '''
  23.     
  24. # 初始化
  25. def init():
  26.     try:
  27.         DB = pymysql.connect(host='localhost',user='root',password='1234',charset='utf8')
  28.         cursor1 = DB.cursor()
  29.         cursor1.execute(CREATE_SCHEMA_SQL)
  30.         DB = pymysql.connect(host='localhost',user='root',password='1234',charset='utf8',database='bank')
  31.         cursor2 = DB.cursor()
  32.         cursor2.execute(CREATE_TABLE_SQL)
  33.         cursor2.execute(CREATE_ACCOUNT_SQL)
  34.         DB.commit()
  35.         print('初始化成功')
  36.         
  37. except Exception as e:
  38.     print('初始化失败',e)
  39.  
  40. finally:
  41.     cursor1.close()
  42.     cursor2.close()
  43.     DB.close()  
  44.     
  45.     # 不让别人调用
  46. if __name__ == "__main__":
  47.     init()
  48.

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

  1. import pymysql
  2.  
  3. # 定义全局变量为空
  4. DB=None
  5.  
  6. # 创建Account类
  7. class Account():
  8.     # 传入参数
  9.     def __init__(self,account_id,account_passwd):
  10.         self.account_id=account_id
  11.         self.account_passwd=account_passwd
  12.         
  13.     # 登录检查
  14.     def check_account(self):
  15.         cursor=DB.cursor()
  16.         try:
  17.             # 把输入账号和密码进行匹配（函数体内部传入参数用self.）
  18.             SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  19.             cursor.execute(SQL)
  20.             
  21.             # 匹配成功返回True，失败返回False
  22.             if cursor.fetchall():
  23.                 return True
  24.             else:
  25.                 return False
  26.  
  27.         except Exception as e:
  28.             print("错误原因：",e)
  29.         finally:
  30.             cursor.close()
  31.  
  32.     # 查询余额
  33.     # def query_money
  34.     
  35.     # 取钱
  36.     # def reduce_money
  37.     
  38.     # 存钱
  39.     # def add_money
  40.     
  41. def main():
  42.     # 定义全局变量
  43.     global DB
  44.     
  45.     # 连接bank库
  46.     DB=pymysql.connect(host="localhost",user="root",passwd="1234",database="bank")
  47.     cursor=DB.cursor()
  48.     
  49.     # 输入账号和密码
  50.     from_account_id=input("请输入账号：")
  51.     from_account_passwd=input("请输入密码：")
  52.     
  53.     # 输入的参数传入给Account类，并创建account对象
  54.     account=Account(from_account_id,from_account_passwd)
  55.     
  56.     # 调用check_account方法，进行登录检查
  57.     if account.check_account():
  58.         choose=input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  59.         # 当输入不等于4的时候执行，等于4则退出
  60.         while choose!="4":
  61.             # 查询
  62.             if choose=="1":
  63.                 print("111")
  64.             # 取钱
  65.             elif choose=="2":
  66.                 print("222")
  67.             # 存钱
  68.             elif choose=="3":
  69.                 print("333")
  70.             # 上面操作完成之后，继续输入其他操作
  71.             choose = input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  72.         else:
  73.             print("谢谢使用！")
  74.     else:
  75.         print("账号或密码错误")
  76.     DB.close()
  77. main()

3、加入查询功能

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

  1. import pymysql
  2. # 引入decimal模块
  3. import decimal
  4. DB=None
  5. class Account():
  6.  
  7.     def __init__(self,account_id,account_passwd):
  8.         self.account_id=account_id
  9.         self.account_passwd=account_passwd
  10.  
  11.     # 登录检查
  12.     def check_account(self):
  13.         cursor=DB.cursor()
  14.         try:
  15.             SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  16.             cursor.execute(SQL)
  17.             if cursor.fetchall():
  18.                 return True
  19.             else:
  20.                 return False
  21.         except Exception as e:
  22.             print("错误",e)
  23.         finally:
  24.             cursor.close()
  25.  
  26.     # 查询余额
  27.     def query_money(self):
  28.         cursor=DB.cursor()
  29.         try:
  30.             # 匹配账号密码，并返回money
  31.             SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  32.             cursor.execute(SQL)
  33.             money=cursor.fetchone()[0]
  34.             # 如果账户有钱就返回金额，没钱返回0.00
  35.             if money:
  36.                 # 返回值为decimal类型，quantize函数进行四舍五入，'0.00'表示保留两位小数
  37.                 return str(money.quantize(decimal.Decimal('0.00')))
  38.             else:
  39.                 return 0.00
  40.         except Exception as e:
  41.             print("错误原因",e)
  42.         finally:
  43.             cursor.close()
  44.  
  45. def main():
  46.     global DB
  47.     DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
  48.     cursor=DB.cursor()
  49.     from_account_id=input("请输入账号：")
  50.     from_account_passwd=input("请输入密码：")
  51.     account=Account(from_account_id,from_account_passwd)
  52.     if account.check_account():
  53.         choose=input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  54.         while choose!="4":
  55.             # 查询
  56.             if choose=="1":
  57.                 # 调用query_money方法
  58.                 print("您的余额是%s元" % account.query_money())
  59.             # 取钱
  60.             elif choose=="2":
  61.                 print("222")
  62.             # 存钱
  63.             elif choose=="3":
  64.                 print("333")
  65.             choose = input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  66.         else:
  67.             print("谢谢使用")
  68.     else:
  69.         print("账号或密码错误")
  70.     DB.close()
  71. main()

4、加入取钱功能

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

  1. import pymysql
  2. import decimal
  3. DB=None
  4. class Account():
  5.  
  6.     def __init__(self,account_id,account_passwd):
  7.         self.account_id=account_id
  8.         self.account_passwd=account_passwd
  9.  
  10.     # 登录检查
  11.     def check_account(self):
  12.         cursor=DB.cursor()
  13.         try:
  14.             SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  15.             cursor.execute(SQL)
  16.             if cursor.fetchall():
  17.                 return True
  18.             else:
  19.                 return False
  20.         except Exception as e:
  21.             print("错误",e)
  22.         finally:
  23.             cursor.close()
  24.  
  25.     # 查询余额
  26.     def query_money(self):
  27.         cursor=DB.cursor()
  28.         try:
  29.             SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  30.             cursor.execute(SQL)
  31.             money=cursor.fetchone()[0]
  32.             if money:
  33.                 return str(money.quantize(decimal.Decimal('0.00')))
  34.             else:
  35.                 return 0.00
  36.         except Exception as e:
  37.             print("错误原因",e)
  38.         finally:
  39.             cursor.close()
  40.  
  41.     # 取钱（注意传入money参数）
  42.     def reduce_money(self,money):
  43.         cursor = DB.cursor()
  44.         try:
  45.             # 先调用query_money方法，查询余额
  46.             has_money=self.query_money()
  47.             
  48.             # 所取金额小于余额则执行（注意类型转换）
  49.             if decimal.Decimal(money) <= decimal.Decimal(has_money):
  50.             
  51.                 # 进行数据更新操作
  52.                 SQL="update account set money=money-%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
  53.                 cursor.execute(SQL)
  54.                 
  55.                 # rowcount进行行计数，行数为1则将数据提交给数据库
  56.                 if cursor.rowcount==1:
  57.                     DB.commit()
  58.                     return True
  59.                 else:
  60.                     # rollback数据库回滚，行数不为1则不执行
  61.                     DB.rollback()
  62.                     return False
  63.             else:
  64.                 print("余额不足")
  65.         except Exception as e:
  66.             print("错误原因",e)
  67.         finally:
  68.             cursor.close()
  69.             
  70.     # 存钱
  71.     # def add_money
  72.  
  73. def main():
  74.     global DB
  75.     DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
  76.     cursor=DB.cursor()
  77.     from_account_id=input("请输入账号：")
  78.     from_account_passwd=input("请输入密码：")
  79.     account=Account(from_account_id,from_account_passwd)
  80.     if account.check_account():
  81.         choose=input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  82.         while choose!="4":
  83.             # 查询
  84.             if choose=="1":
  85.                 print("您的余额是%s元" % account.query_money())
  86.             # 取钱
  87.             elif choose=="2":
  88.                 # 先查询余额，再输入取款金额，防止取款金额大于余额
  89.                 money=input("您的余额是%s元,请输入取款金额" % account.query_money())
  90.                 # 调用reduce_money方法，money不为空则取款成功
  91.                 if account.reduce_money(money):
  92.                     print("取款成功，您的余额还有%s元" % account.query_money())
  93.                 else:
  94.                     print("取款失败！")
  95.             # 存钱
  96.             elif choose=="3":
  97.                 print("333")
  98.             choose = input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  99.         else:
  100.             print("谢谢使用！")
  101.     else:
  102.         print("账号或密码错误")
  103.     DB.close()
  104. main()

5、加入存钱功能

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

  1. import pymysql
  2. import decimal
  3. DB=None
  4. class Account():
  5.     def __init__(self,account_id,account_passwd):
  6.         self.account_id=account_id
  7.         self.account_passwd=account_passwd
  8.  
  9.     # 登录检查
  10.     def check_account(self):
  11.         cursor=DB.cursor()
  12.         try:
  13.             SQL="select * from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  14.             cursor.execute(SQL)
  15.             if cursor.fetchall():
  16.                 return True
  17.             else:
  18.                 return False
  19.         except Exception as e:
  20.             print("错误",e)
  21.         finally:
  22.             cursor.close()
  23.  
  24.     # 查询余额
  25.     def query_money(self):
  26.         cursor=DB.cursor()
  27.         try:
  28.             SQL="select money from account where account_id=%s and account_passwd=%s" %(self.account_id,self.account_passwd)
  29.             cursor.execute(SQL)
  30.             money=cursor.fetchone()[0]
  31.             if money:
  32.                 return str(money.quantize(decimal.Decimal('0.00')))
  33.             else:
  34.                 return 0.00
  35.         except Exception as e:
  36.             print("错误原因",e)
  37.         finally:
  38.             cursor.close()
  39.  
  40.     # 取钱
  41.     def reduce_money(self,money):
  42.         cursor = DB.cursor()
  43.         try:
  44.             has_money=self.query_money()
  45.             if decimal.Decimal(money) <= decimal.Decimal(has_money):
  46.                 SQL="update account set money=money-%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
  47.                 cursor.execute(SQL)
  48.                 if cursor.rowcount==1:
  49.                     DB.commit()
  50.                     return True
  51.                 else:
  52.                     DB.rollback()
  53.                     return False
  54.             else:
  55.                 print("余额不足")
  56.         except Exception as e:
  57.             print("错误原因",e)
  58.         finally:
  59.             cursor.close()
  60.  
  61.     # 存钱
  62.     def add_money(self,money):
  63.         cursor = DB.cursor()
  64.         try:
  65.             SQL="update account set money=money+%s where account_id=%s and account_passwd=%s" %(money,self.account_id,self.account_passwd)
  66.             cursor.execute(SQL)
  67.             if cursor.rowcount==1:
  68.                 DB.commit()
  69.                 return True
  70.             else:
  71.                 DB.rollback()
  72.                 return False
  73.         except Exception as e:
  74.             DB.rollback()
  75.             print("错误原因",e)
  76.         finally:
  77.             cursor.close()
  78.  
  79. def main():
  80.     global DB
  81.     DB=pymysql.connect(host="localhost",user="root",passwd="1234",charset="utf8",database="bank")
  82.     cursor=DB.cursor()
  83.     from_account_id=input("请输入账号：")
  84.     from_account_passwd=input("请输入密码：")
  85.     account=Account(from_account_id,from_account_passwd)
  86.     if account.check_account():
  87.         choose=input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  88.         while choose!="4":
  89.             # 查询
  90.             if choose=="1":
  91.                 print("您的余额是%s元" % account.query_money())
  92.             # 取钱
  93.             elif choose=="2":
  94.                 money=input("您的余额是%s元,请输入取款金额" % account.query_money())
  95.                 if account.reduce_money(money):
  96.                     print("取款成功，您的余额还有%s元" % account.query_money())
  97.                 else:
  98.                     print("取款失败！")
  99.             # 存钱
  100.             elif choose=="3":
  101.                 money=input("请输入存款金额：")
  102.                 if account.add_money(money):
  103.                     print("存款成功，您的余额还有%s元，按任意键继续\n" % (account.query_money()))
  104.                 else:
  105.                     print("存款失败，按任意键继续")
  106.             choose = input("请输入操作：\n1、查询余额\n2、取钱\n3、存钱\n4、取卡\n")
  107.         else:
  108.             print("谢谢使用！")
  109.     else:
  110.         print("账号或密码错误")
  111.     DB.close()
  112. main()

原文链接：Python——连接数据库操作 - 王智刚 - 博客园
作者：王智刚

如果觉得本文对你有帮助，可以转发关注支持一下

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/木道寻08/article/detail/968733
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号