码迷，mamicode.com
首页 > 数据库 > 详细

python操作pysql—2

时间：2020-06-12 00:59:25      阅读：69      评论：0      收藏：0      [点我收藏+]

标签：conda   cells   数据库的操作   插入   highlight   apt   使用   tran   信息   

本篇对于Python操作MySQL主要使用两种方式：

  • 原生模块 pymsql
  • ORM框架 SQLAchemy

pymsql

pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同。

下载安装

1
pip3 install pymysql

使用操作

1、执行SQL

2、获取新创建数据自增ID

3、获取查询数据

注：在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：

  • cursor.scroll(1,mode=‘relative‘)  # 相对当前位置移动
  • cursor.scroll(2,mode=‘absolute‘) # 相对绝对位置移动

4、fetch数据类型

　　关于默认获取的数据是元祖类型，如果想要或者字典类型的数据，即：

作业：
参考表结构：
用户类型

用户信息

权限

用户类型&权限
功能：

# 登陆、注册、找回密码
# 用户管理
# 用户类型
# 权限管理
# 分配权限

特别的：程序仅一个可执行文件

练习题

SQLAchemy

SQLAlchemy是Python编程语言下的一款ORM框架，该框架建立在数据库API之上，使用关系对象映射进行数据库操作，简言之便是：将对象转换成SQL，然后使用数据API执行SQL并获取执行结果。

安装：

1
pip3 install SQLAlchemy

技术图片

 

SQLAlchemy本身无法操作数据库，其必须以来pymsql等第三方插件，Dialect用于和数据API进行交流，根据配置文件的不同调用不同的数据库API，从而实现对数据库的操作，如：

1
2
3
4
5
6
7
8
9
10
11
12
13
MySQL-Python
    mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
   
pymysql
    mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
   
MySQL-Connector
    mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
   
cx_Oracle
    oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
   
更多详见：http://docs.sqlalchemy.org/en/latest/dialects/index.html

一、内部处理

使用 Engine/ConnectionPooling/Dialect 进行数据库操作，Engine使用ConnectionPooling连接数据库，然后再通过Dialect执行SQL语句。

二、ORM功能使用

使用 ORM/Schema Type/SQL Expression Language/Engine/ConnectionPooling/Dialect 所有组件对数据进行操作。根据类创建对象，对象转换成SQL，执行SQL。

1、创建表

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import create_engine
 
engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/t1", max_overflow=5)
 
Base = declarative_base()
 
# 创建单表
class Users(Base):
    __tablename__ = ‘users‘
    id = Column(Integer, primary_key=True)
    name = Column(String(32))
    extra = Column(String(16))
 
    __table_args__ = (
    UniqueConstraint(‘id‘, ‘name‘, name=‘uix_id_name‘),
        Index(‘ix_id_name‘, ‘name‘, ‘extra‘),
    )
 
 
# 一对多
class Favor(Base):
    __tablename__ = ‘favor‘
    nid = Column(Integer, primary_key=True)
    caption = Column(String(50), default=‘red‘, unique=True)
 
 
class Person(Base):
    __tablename__ = ‘person‘
    nid = Column(Integer, primary_key=True)
    name = Column(String(32), index=True, nullable=True)
    favor_id = Column(Integer, ForeignKey("favor.nid"))
 
 
# 多对多
class Group(Base):
    __tablename__ = ‘group‘
    id = Column(Integer, primary_key=True)
    name = Column(String(64), unique=True, nullable=False)
    port = Column(Integer, default=22)
 
 
class Server(Base):
    __tablename__ = ‘server‘
 
    id = Column(Integer, primary_key=True, autoincrement=True)
    hostname = Column(String(64), unique=True, nullable=False)
 
 
class ServerToGroup(Base):
    __tablename__ = ‘servertogroup‘
    nid = Column(Integer, primary_key=True, autoincrement=True)
    server_id = Column(Integer, ForeignKey(‘server.id‘))
    group_id = Column(Integer, ForeignKey(‘group.id‘))
 
 
def init_db():
    Base.metadata.create_all(engine)
 
 
def drop_db():
    Base.metadata.drop_all(engine)

注：设置外检的另一种方式 ForeignKeyConstraint([‘other_id‘], [‘othertable.other_id‘])

2、操作表

#!/usr/bin/env python
# -*- coding:utf-8 -*-
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import create_engine

engine = create_engine("mysql+pymysql://root:123@127.0.0.1:3306/t1", max_overflow=5)

Base = declarative_base()

# 创建单表
class Users(Base):
__tablename__ = ‘users‘
id = Column(Integer, primary_key=True)
name = Column(String(32))
extra = Column(String(16))

__table_args__ = (
UniqueConstraint(‘id‘, ‘name‘, name=‘uix_id_name‘),
Index(‘ix_id_name‘, ‘name‘, ‘extra‘),
)

def __repr__(self):
return "%s-%s" %(self.id, self.name)

# 一对多
class Favor(Base):
__tablename__ = ‘favor‘
nid = Column(Integer, primary_key=True)
caption = Column(String(50), default=‘red‘, unique=True)

def __repr__(self):
return "%s-%s" %(self.nid, self.caption)

class Person(Base):
__tablename__ = ‘person‘
nid = Column(Integer, primary_key=True)
name = Column(String(32), index=True, nullable=True)
favor_id = Column(Integer, ForeignKey("favor.nid"))
# 与生成表结构无关，仅用于查询方便
favor = relationship("Favor", backref=‘pers‘)

# 多对多
class ServerToGroup(Base):
__tablename__ = ‘servertogroup‘
nid = Column(Integer, primary_key=True, autoincrement=True)
server_id = Column(Integer, ForeignKey(‘server.id‘))
group_id = Column(Integer, ForeignKey(‘group.id‘))
group = relationship("Group", backref=‘s2g‘)
server = relationship("Server", backref=‘s2g‘)

class Group(Base):
__tablename__ = ‘group‘
id = Column(Integer, primary_key=True)
name = Column(String(64), unique=True, nullable=False)
port = Column(Integer, default=22)
# group = relationship(‘Group‘,secondary=ServerToGroup,backref=‘host_list‘)


class Server(Base):
__tablename__ = ‘server‘

id = Column(Integer, primary_key=True, autoincrement=True)
hostname = Column(String(64), unique=True, nullable=False)

 


def init_db():
Base.metadata.create_all(engine)


def drop_db():
Base.metadata.drop_all(engine)


Session = sessionmaker(bind=engine)
session = Session()

表结构 + 数据库连接

    • 增

      obj = Users(name="alex0", extra=‘sb‘)
      session.add(obj)
      session.add_all([
      Users(name="alex1", extra=‘sb‘),
      Users(name="alex2", extra=‘sb‘),
      ])
      session.commit()


      技术图片
      obj = Users(name="alex0", extra=‘sb‘)
session.add(obj)
session.add_all([
    Users(name="alex1", extra=‘sb‘),
    Users(name="alex2", extra=‘sb‘),
])
session.commit()
      技术图片
    • 删
      session.query(Users).filter(Users.id > 2).delete()
session.commit()

      session.query(Users).filter(Users.id > 2).delete()
session.commit()
    • 改
      session.query(Users).filter(Users.id > 2).update({"name" : "099"})
session.query(Users).filter(Users.id > 2).update({Users.name: Users.name + "099"}, synchronize_session=False)
session.query(Users).filter(Users.id > 2).update({"num": Users.num + 1}, synchronize_session="evaluate")
session.commit()
    • 查

      ret = session.query(Users).all()
      ret = session.query(Users.name, Users.extra).all()
      ret = session.query(Users).filter_by(name=‘alex‘).all()
      ret = session.query(Users).filter_by(name=‘alex‘).first()

      ret = session.query(Users).filter(text("id<:value and name=:name")).params(value=224, name=‘fred‘).order_by(User.id).all()

      ret = session.query(Users).from_statement(text("SELECT * FROM users where name=:name")).params(name=‘ed‘).all()

    • 其他

      #　条件
      ret = session.query(Users).filter_by(name=‘alex‘).all()
      ret = session.query(Users).filter(Users.id > 1, Users.name == ‘eric‘).all()
      ret = session.query(Users).filter(Users.id.between(1, 3), Users.name == ‘eric‘).all()
      ret = session.query(Users).filter(Users.id.in_([1,3,4])).all()
      ret = session.query(Users).filter(~Users.id.in_([1,3,4])).all()
      ret = session.query(Users).filter(Users.id.in_(session.query(Users.id).filter_by(name=‘eric‘))).all()
      from sqlalchemy import and_, or_
      ret = session.query(Users).filter(and_(Users.id > 3, Users.name == ‘eric‘)).all()
      ret = session.query(Users).filter(or_(Users.id < 2, Users.name == ‘eric‘)).all()
      ret = session.query(Users).filter(
      or_(
      Users.id < 2,
      and_(Users.name == ‘eric‘, Users.id > 3),
      Users.extra != ""
      )).all()


      # 通配符
      ret = session.query(Users).filter(Users.name.like(‘e%‘)).all()
      ret = session.query(Users).filter(~Users.name.like(‘e%‘)).all()

      # 限制
      ret = session.query(Users)[1:2]

      # 排序
      ret = session.query(Users).order_by(Users.name.desc()).all()
      ret = session.query(Users).order_by(Users.name.desc(), Users.id.asc()).all()

      # 分组
      from sqlalchemy.sql import func

      ret = session.query(Users).group_by(Users.extra).all()
      ret = session.query(
      func.max(Users.id),
      func.sum(Users.id),
      func.min(Users.id)).group_by(Users.name).all()

      ret = session.query(
      func.max(Users.id),
      func.sum(Users.id),
      func.min(Users.id)).group_by(Users.name).having(func.min(Users.id) >2).all()

      # 连表

      ret = session.query(Users, Favor).filter(Users.id == Favor.nid).all()

      ret = session.query(Person).join(Favor).all()

      ret = session.query(Person).join(Favor, isouter=True).all()


      # 组合
      q1 = session.query(Users.name).filter(Users.id > 2)
      q2 = session.query(Favor.caption).filter(Favor.nid < 2)
      ret = q1.union(q2).all()

      q1 = session.query(Users.name).filter(Users.id > 2)
      q2 = session.query(Favor.caption).filter(Favor.nid < 2)
      ret = q1.union_all(q2).all()

 

python操作pysql—2

标签：conda   cells   数据库的操作   插入   highlight   apt   使用   tran   信息   

原文地址：https://www.cnblogs.com/Polar-sunshine/p/13096871.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！