• 【python零基础入门学习】python进阶篇之数据库连接-PyMysql-全都是干货-一起来学习吧！！！

      本站以分享各种运维经验和运维所需要的技能为主

    《python零基础入门》：python零基础入门学习

    《python运维脚本》： python运维脚本实践

    《shell》：shell学习

    《terraform》持续更新中：terraform_Aws学习零基础入门到最佳实战

    《k8》暂未更新

    《docker学习》暂未更新

    《ceph学习》ceph日常问题解决分享

    《日志收集》ELK+各种中间件

    《运维日常》运维日常

    《linux》运维面试100问

     python进阶篇之数据库连接-PyMysql

    安装

    python包官方站点:https://pypi.python.org

    # pip install xxxx

    pip install -i https://pypi.tuna.tsinghua.edu.cn/simple mysql-connector-python-rf

    在线安装，默认使用的是国外站站，也可以设置，使用国内镜像站点：

    安装依赖包

    [root@localhost packages]# yum install -y gcc

    [root@room8pc16 day02]# mkdir ~/.pip/

    [root@room8pc16 day02]# vim ~/.pip/pip.conf

    [global]

    index-url = http://pypi.douban.com/simple/

    [install]

    trusted-host=pypi.douban.com

    ### 本地安装：

    注意：需要在虚拟环境中安装

    # ls /linux-soft/05/

    zzg_pypkgs.tar.gz

    # tar xf zzg_pypkgs.tar.gz

    # cd zzg_pypkgs

    # pip install pymysql_pkgs/*

    进入正文：数据库

    数据库:

    你正在为一个小型公司编写基础数数据库,数据库需要记录员工,部门和发工资的信息.

    收集字段:姓名,性别,联系方式,部门,出生日期,工资日,底薪,奖金,实发工资

    数据库范式:

    数据库范式有第一范式、第二范式、第 三范式、巴斯-科德范式、第四范式、第五范式六种

    。

    所谓第一范式（1NF）是指在关系模型中，对域添加的一个规范要求，所有的域都应该是原>子性的，即数据库表的每一列都是不可分割的原子数据项。如联系方式不能成为一个字段，

    需要将其拆分成家庭住址、电话号码、email等。

    第二范式（2NF）是在第一范式（1NF） 的基础上建立起来的，即满足第二范式（2NF）必须

    先满足第一范式（1NF）。第二范式（2NF）要求数据库表中的每个实例或记录必须 可以被>唯一地区分。简单来说就是每个表需要有个主键

    员工表：员工ID、姓名、出生日期、email、部门ID

    部门表：部门ID、部门名

    工资表：id、工资日、员工ID、底薪、奖金、实发工资

    第三范式（3NF）要求一个关系中不包含已在其它关系已包含的非主关键字信息。简单来说>，非主字段，不能依赖其他非主字段。实发工资是由底薪、奖金算出来的，所以它不应该出

    现在数制库中。用的时候，应该是通过程序计算。

    [root@room8pc16 day02]# mysql -uroot -ptedu.cn

    MariaDB [(none)]> CREATE DATABASE nsd1907 DEFAULT CHAR SET utf8;

    >grant all on *.* to root@'192.168.1.%' identified by '123qqq...A' ;

    ## pymsql操作数据库

    - 连接

    - 创建游标。游标就像是文件对象，通过文件对象可以对文件实施读写操作，通过游标就可

    以对数据库进行增删改查。

    - 执行SQL语句

    - 如果执行的语句是增删改，必须commit确认

    - 关闭

    连接数据库

    1. import pymysql
    2.  
    3. #创建链接
    4. conn=pymysql.connect(
    5. host='192.168.1.100',
    6. port=3306,
    7. user='root',
    8. passwd='123qqq...A',
    9. db='nsd1907',
    10. charset='utf8')
    11.  
    12. #创建游标
    13. cur = conn.cursor()
    14.  
    15. # 编写SQL语句
    16. create_dep = """CREATE TABLE departments(
    17. dep_id INT, dep_name VARCHAR(20),
    18. PRIMARY KEY(dep_id)
    19. )"""
    20. create_emp = """CREATE TABLE employees(
    21. emp_id INT, emp_name VARCHAR(20), birth_date DATE,
    22. email VARCHAR(50), dep_id INT,
    23. PRIMARY KEY(emp_id),
    24. FOREIGN KEY(dep_id) REFERENCES departments(dep_id)
    25. )"""
    26. create_sal = """CREATE TABLE salary(
    27. id INT, date DATE, emp_id INT,
    28. basic INT, awards INT,
    29. PRIMARY KEY(id),
    30. FOREIGN KEY(emp_id) REFERENCES employees(emp_id)
    31. )"""
    32.  
    33. # 执行SQL语句
    34. cur.execute(create_dep)
    35. cur.execute(create_emp)
    36. cur.execute(create_sal)
    37.  
    38. # 确认提交
    39. conn.commit()
    40.  
    41. # 关闭
    42. cur.close()
    43. conn.close()
    44.

    增删改查

    1. #增删改查
    2.  
    3. import pymysql
    4.  
    5. #创建链接
    6. conn=pymysql.connect(
    7. host='192.168.1.100',
    8. port=3306,
    9. user='root',
    10. passwd='123qqq...A',
    11. db='nsd1907',
    12. charset='utf8')
    13.  
    14. #创建游标
    15. cur = conn.cursor()
    16.  
    17. # # 创建部门
    18. # insert1 = "INSERT INTO departments VALUES(%s, %s)"
    19. # cur.executemany(insert1, [(1, '人事部')])
    20. # #cur.executemany(insert1, (1, '人事部'))
    21. #cur.executemany(insert1, [(2, '运维部'), (3, '开发部'), (4, '测试部')])
    22. # cur.executemany(insert1, [(4, '测试部'), (5, '市场部'), (6, '销售部')])
    23.  
    24. #insert1 = "INSERT INTO departments VALUES(9, '人事部3'),(10,'人事部4')"
    25. #cur.execute(insert1)
    26.  
    27.  
    28. #更新部门，将人事部改为人力资源部
    29. # update1 = "UPDATE departments SET dep_name=%s WHERE dep_name=%s"
    30. # cur.execute(update1, ('人力资源部', '人事部'))
    31.  
    32. # # 删除4号部门
    33. # del1 = "DELETE FROM departments WHERE dep_id=%s"
    34. # cur.execute(del1, (4,))
    35.  
    36. #查询
    37. select1 = "SELECT * FROM departments"
    38. cur.execute(select1)
    39. result1 = cur.fetchone()#取一个记录
    40. print(result1)
    41. print('*' * 30)
    42. result2 = cur.fetchmany(2)#继续取两个记录
    43. print(result2)
    44. print('*' * 30)
    45. result3 = cur.fetchall()#取出剩余全部记录
    46. print(result3)
    47.  
    48. # 执行SQL语句
    49. # cur.execute(create_dep)
    50. # cur.execute(create_emp)
    51. # cur.execute(create_sal)
    52.  
    53. # 确认提交
    54. conn.commit()
    55.  
    56. # 关闭
    57. cur.close()
    58. conn.close()
    59.

    游标

    SQLAlchemy:

    • sqlalchemy采用ROM管理数据库

    • O:Object 对象

    • R:relational 关系

    • M: Mapping 映射

    • sqlalchemy 将一个class与数据中的一张表相关联

    • sqlalchemy将类变量与表的字段关联

    • sqlalchemy将数据库的各种数据类型定义成了相关的class

    • sqlalchemy将class的实例与表的记录关联

    now( ) year( ) month( ) day( ) date( ) time( ) datetime curtime( ) curdate( )

    安装

    #安装

    pip install sqlalchemy_pkgs/*

     连接数据库

    1. mysql> CREATE DATABASE tedu1907 DEFAULT CHAR SET utf8;
    2. mysql> show grants for root@'192.168.1.%';
    3.  
    4. dbconn.py:
    5.  
    6. from sqlalchemy import create_engine,Column,Integer,String,Date,ForeignKey
    7. from sqlalchemy.ext.declarative import declarative_base
    8. from sqlalchemy.orm import sessionmaker
    9. # 创建到mysql数据库的连接引擎
    10. engine = create_engine(
    11.     'mysql+pymysql://root:123qqq...A@192.168.1.100/tedu1907?charset=utf8',
    12.     encoding = 'utf8',
    13.     #echo = True 屏幕上打印日志
    14.  
    15. )
    16.  
    17. #创建实体类的基类---固定必须要写
    18. Base = declarative_base()
    19.  
    20. #创建到数据库连接的会话类
    21. Session = sessionmaker(bind=engine)
    22.  
    23.  
    24. #创建实体类,也就是创建表对应的类
    25. class Departments(Base):
    26.     __tablename__ = 'departments' #声明类对应的表
    27.     #每个字段都要用Column来定义
    28.     dep_id = Column (Integer,primary_key=True) #设置为主键
    29.     dep_name = Column (String(20),unique=True) #名称必须唯一
    30.  
    31.      def __str__(self):          
    32.         return "部门: %s" % self.dep_name
    33. -----为后面的 print(hr)输出用
    34.  
    35.  
    36. class Employees(Base):
    37.     __tablename__ = 'employees'
    38.     emp_id = Column(Integer,primary_key=True)
    39.     emp_name = Column(String(20))
    40.     birth_date = Column(Date)
    41.     email = Column(String(50))
    42.     dep_id = Column(Integer,ForeignKey('departments.dep_id'))
    43.  
    44.  
    45. class Salary(Base):
    46.     __tablename__ = 'salary'
    47.     id = Column(Integer,primary_key=True)
    48.     date = Column(Date)
    49.     emp_id = Column(Integer,ForeignKey('employees.emp_id'))
    50.     basic = Column(Integer)
    51.     awards = Column(Integer)
    52.  
    53.  
    54. if __name__ == '__main__':
    55.     #如果库中无表则创建,有表将不会执行
    56.     Base.metadata.create_all(engine)
    57.  
    58.

    增删改查

    1. #create / retrieve / update / delete
    2. from dbconn import Session,Departments,Employees
    3.  
    4. #创建到数据库的会话连接
    5. session = Session()
    6.  
    7.  
    8. #插入数据
    9. hr = Departments(dep_id =1 ,dep_name = '人事部')
    10. ops = Departments(dep_id =2 , dep_name = '运维部' )
    11. dev = Departments(dep_id =3 ,dep_name = '开发部')
    12. qa = Departments(dep_id =4 ,dep_name = '测试部')
    13. sales = Departments(dep_id =5 ,dep_name = '销售部')
    14. market = Departments(dep_id =6 ,dep_name = '市场部')
    15.  
    16. lb = Employees(
    17.     emp_id = 1 , emp_name = '刘备',
    18.     birth_date = '1982-3-15', email = 'lb@sg.com' ,dep_id = 1
    19. )
    20.  
    21. km = Employees(
    22.     emp_id = 2 , emp_name = '孔明',
    23.     birth_date = '1982-3-15', email = 'km@sg.com' ,dep_id = 2
    24. )
    25.  
    26. # session.add_all([hr,ops,dev,qa,sales,market,lb])
    27. #session.add_all([km])
    28. #session.add(单个)
    29.  
    30.  
    31. #查询部门,传入的是class,返回的是实例集合
    32. # qset1 = session.query(Departments)
    33. # print(qset1) #此时只是sql语句,取值时,才是真正连接数据库
    34. # print(qset1.all())
    35. # for dep in qset1:
    36. #     print(dep.dep_id,dep.dep_name)
    37.  
    38. #查询员工,传入的是字段,返回的是由字段构成的元组
    39. # qset2 = session.query(Employees.emp_name,Employees.email)
    40. # print(qset2)
    41. # print(qset2.all())
    42. # for emp in qset2:
    43. #     print(emp)
    44. # print('*' * 30)
    45. # for name , email in qset2:
    46. #     print(name,email)
    47.  
    48.  
    49. #查询部门,按id排序
    50. # qset3 = session.query(Departments).order_by(Departments.dep_id)
    51. # for dep in qset3:
    52. #     print(dep.dep_id,dep.dep_name)
    53.  
    54. #查询部门id是1的部门
    55. # qset4 = session.query(Departments).filter(Departments.dep_id==1)
    56. # for dep in qset4:
    57. #     print(dep.dep_id,dep.dep_name)
    58.  
    59. #查询部门id是2到4的部门
    60. # qset5 = session.query(Departments)\
    61. #     .filter(Departments.dep_id>=2)\
    62. #     .filter(Departments.dep_id<=4)
    63. # for dep in qset5:
    64. #     print(dep.dep_id,dep.dep_name)
    65.  
    66.  
    67. #模糊查询:
    68. # qset6 = session.query(Employees.emp_name,Employees.email)\
    69. #     .filter(Employees.email.like('%@sg.com'))
    70. # for emp in qset6:
    71. #     print(emp.emp_name,emp.email)
    72.  
    73.  
    74. #多表查询: query查询的时候,先写Employees.emp_name,就要join Departments
    75. # qset7 = session.query(Employees.emp_name,Departments.dep_name)\
    76. #     .join(Departments)
    77. # qset7 = session.query(Departments.dep_name,Employees.emp_name)\
    78. #      .join(Employees)
    79. # for data in qset7:
    80. #     print(data)
    81.  
    82. # 修改
    83. # qset9 = session.query(Departments)\
    84. #     .filter(Departments.dep_name=='人事部')
    85. # hr = qset9.first()  # 取出查询结果的第一项
    86. # print(hr)
    87. # hr.dep_name = '人力资源部'
    88.  
    89. # 删除
    90. qset10 = session.query(Departments)\
    91.     .filter(Departments.dep_name=='销售部')
    92. sales = qset10[0]
    93. print(sales)
    94. session.delete(sales)
    95.  
    96.  
    97.  
    98.  
    99.  
    100. #如果是增删改操作,需要确认commit
    101. session.commit()
    102.  
    103.  
    104. #关闭会话
    105. session.close()

  • 相关阅读:
    Android 集成Flutter模块踩坑之路
    ardupilot开发 --- External LEDs篇
    对MybatisPlus的Select和Update实现自定义Sql
    关于不同数据库的SQL中比较串的形式为NULL=NULL的返回值不同
    Yakit工具篇：子域名收集的配置和使用
    安卓期末大作业——仿番茄免费小说APP
    《图解Pandas》内容汇总-20220822
    KNN算法与SVM支持向量机
    什么是ajax，ajax有什么特点？
    云原生时代崛起的编程语言Go常用标准库实战
  • 原文地址：https://blog.csdn.net/zerotoall/article/details/134460037