Python与数据库的新人手册 -- MySQL

本篇文章向大家介绍《Python与数据库的新人手册 -- MySQL》，主要包括MySQL、数据库、python，具有一定的参考价值，需要的朋友可以参考一下。

Python支持的数据库有很多，

pip3 install pymysql

然后安装ORM框架

pip3 install sqlalchemy

日常工作中，如果不想每次通过命令行来查看数据的话。推荐安装

# 导入SQLAlchemy
from sqlalchemy import Column, BIGINT, String, create_engine
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base

# 创建基类
Base = declarative_base()

# 初始化数据库连接:
# '数据库类型+数据库驱动名称://用户名:密码@数据库地址:端口号/数据库名'
engine = create_engine('mysql+pymysql://root:123123@mysql:3306/test')

# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)
# 创建session对象:
session = DBSession()

# 数据库操作方法
# 初始化数据库
def init_db():
    Base.metadata.create_all(engine)
# 删除数据库
def drop_db():
    Base.metadata.drop_all(engine)

建立

# 定义user类
class User(Base):
    # 表名
    __tablename__ = "user"

    # 表的结构
    # 设置id为主键 并自增长
    id = Column(BIGINT, primary_key=True, autoincrement=True)
    name = Column(String(20))
    gender = Column(String(2))

# 正式初始化数据库，如果没有user表的话，这里将自动创建
init_db()

这里有个需要注意的地方就是在初始化数据库之前需要先定义

# 创建新User对象:
new_user = User(name='mrlizi', gender='man')
# 添加到session:
session.add(new_user)
# 批量添加
session.add_all([
    User(name='子非鱼', gender='M'),
    User(name='虞姬', gender='F'),
    User(name='花木兰', gender='F')
])
# 提交即保存到数据库:
session.commit()

结果：

查

# query: 输出所有的用户名
result = session.query(User.name)
# order: 按倒序输出所有用户
result = session.query(User).order_by(User.id.desc())
result = session.query(User).order_by(-User.id)
# label: 自定义字段名,查询结果可通过item.my_name来获取用户名
for item in session.query(User.name.label('my_name')).all()
# filter和filter_by: 筛选用户名为'mrlizi'的用户
result = session.query(User).filter(User.name=='mrlizi').one()
result = session.query(User).filter_by(name='mrlizi').one()
# offset和limit：组合起来可做分页查询(通过python的切片其实也一样)，下面的两种语句的查询结果是相同的
result = session.query(User).offset(2).limit(1).all()
result = session.query(User)[1:3]

# AND: 与查询      
result = session.query(User).filter(and_(User.name=='mrlizi', User.gender=='M')).all()
result = session.query(User).filter(User.name=='mrlizi', User.gender=='M')
result = session.query(User).filter(User.name=='mrlizi').filter(User.gender=='M').all()
# OR: 或查询
result = session.query(User).filter(or_(User.name == '子非鱼', User.name == '花木兰'))
# 模糊查询
result = session.query(User).filter(User.name.like('子%')).all()

基本日常用到的查询方法就是这些，面向对象操作的用法都比较灵活多变，大家可以根据不同的场景自由组合。

改

相比去查询来讲，修改就显得简单很多，找到命中的记录，然后通过

# 方法一
session.query(User).filter(User.name == 'mrlizi').update({'name': '李白'})
# 方法二
user = session.query(User).filter(User.name == '李白').first()
user.name = '铠'
# 操作方式
result = session.query(User).filter(User.name == '虞姬').update({User.name: '孙尚香'}, synchronize_session='fetch')
# 提交
session.commit()

删

删除的话，无非就是

# 使用查询语句，filter是where条件，最后调用delete()进行删除记录:
session.query(User).filter_by(name="铠").delete()
session.commit()

关联表查询

def one_to_many():
    # 定义user类
    class User(Base):
        # 表名
        __tablename__ = "user"

        # 表的结构
        # 设置id为主键 并自增长
        id = Column(BIGINT, primary_key=True, autoincrement=True)
        name = Column(String(20))
        # 定义用户关注的公众号属性，指明两者的关系
        account = relationship('Account', back_populates="user")

    class Account(Base):
        __tablename__ = 'account'

        id = Column(BIGINT, primary_key=True, autoincrement=True)
        name = Column(String(20))
        # 设置外键关联到user表的:
        user_id = Column(BIGINT, ForeignKey('user.id'))
        # 定义 Account 的 user 属性，指明两者关系
        user = relationship("User", back_populates="account")

    # 清空数据库并重新初始化
    drop_db()
    init_db()

    mrlizi = User(name='mrlizi')
    mrlizi.account = [
        Account(name='攻城狮峡谷'),
        Account(name='zone7')
    ]
    session.add(mrlizi)

    result = session.query(User).filter(User.name == 'mrlizi').one()
    for item in result.account:
        print(item.name)

    result = session.query(Account).filter(Account.name == '攻城狮峡谷').one()
    print(result.user.name)

    session.commit()

one_to_many()

上面代码的实现过程：

• 建立一对多数据表模型
• 将之前的数据清空后重新初始化，用新的表模型创建个新的user，并添加关注的公众号account
• 增加name为mrlizi的

  def one_to_one():
      # 定义user类
      class User(Base):
          __tablename__ = "user"
  
          id = Column(BIGINT, primary_key=True, autoincrement=True)
          name = Column(String(20))
          account = relationship('Account', uselist=False, back_populates="user")
  
      # 公众号类
      class Account(Base):
          __tablename__ = 'account'
  
          id = Column(BIGINT, primary_key=True, autoincrement=True)
          name = Column(String(20))
          # 设置外键关联到user表的:
          user_id = Column(BIGINT, ForeignKey('user.id'))
          # 定义 Account 的 user 属性，指明两者关系
          user = relationship("User", back_populates="account")
  
      # 清空数据库并重新初始化
      drop_db()
      init_db()
  
      # 添加记录
      user = User(name='子非鱼')
      user.account = Account(name='攻城狮峡谷')
      session.add(user)
      session.commit()
  
      # 查询
      result = session.query(User).filter(User.name == '子非鱼').one()
      print(result.account.name)
      # 输出：
      # 攻城狮峡谷
  
  one_to_one()

  多对多

  多对多是通过两个表之间增加一个关联的表来实现，这个关联表使用

  def many_to_many():
      # 关联表
      association_table = Table('association', Base.metadata,
                                Column('user_id', BIGINT, ForeignKey('user.id')),
                                Column('account_id', BIGINT, ForeignKey('account.id'))
                                )
  
      class User(Base):
          __tablename__ = "user"
  
          id = Column(BIGINT, primary_key=True, autoincrement=True)
          name = Column(String(20))
          accounts = relationship('Account', secondary=association_table, back_populates="users")
  
      class Account(Base):
          __tablename__ = 'account'
  
          id = Column(BIGINT, primary_key=True, autoincrement=True)
          name = Column(String(20))
          users = relationship("User", secondary=association_table, back_populates="accounts")
  
      # 清空数据库并重新初始化
      drop_db()
      init_db()
      
      # 创建记录
      user1 = User(name='子非鱼')
      user2 = User(name='zone')
      user3 = User(name='mrlizi')
      account1 = Account(name='攻城狮峡谷')
      account2 = Account(name='zone7')
  
      # 关联记录
      user1.accounts = [account1]
      user2.accounts = [account1, account2]
      user3.accounts = [account2]
  
      # 添加并保存
      session.add(user1)
      session.add(user2)
      session.add(user3)
      session.commit()
  
      # 双向查询
      result1 = session.query(User).filter(User.name == 'zone').one()
      for item in result1.accounts:
          print(item.name)
      result2 = session.query(Account).filter(Account.name == '攻城狮峡谷').one()
      for item in result2.users:
          print(item.name)
  
  many_to_many()

  总结

  MySQL作为主流的数据库之一，我们不一定说要多深入去研究它的使用，但起码的了解还是要有的。而且python中使用MySQL还是挺简单的，代码敲着敲着就会了。

  到这里，我们也就讲完了《Python与数据库的新人手册 -- MySQL》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于mysql的知识点！