update python_sqlalchemy
xianhu
commit
3a7cb4cdf2
|
|
@ -12,7 +12,7 @@
|
|||
|
||||
### python_lda.py: 玩点高级的--带你入门Topic模型LDA（小改进+附源码）
|
||||
|
||||
### python_sqlalchemy: SQLAlchemy入门代码文档
|
||||
### python_sqlalchemy: 作为一个Pythoner，不会SQLAlchemy都不好意思跟同行打招呼！
|
||||
============================================================
|
||||
|
||||
### 您可以fork该项目,并在修改后提交Pull request
|
||||
|
|
|
|||
|
|
@ -191,7 +191,7 @@
|
|||
# 普通调用
|
||||
"{0}, {1} and {2}".format('spam', 'ham', 'eggs') # 基于位置的调用
|
||||
"{motto} and {pork}".format(motto = 'spam', pork = 'ham') # 基于Key的调用
|
||||
"{motto} and {0}".format(ham, motto = 'spam') # 混合调用
|
||||
"{motto} and {0}".format('ham', motto = 'spam') # 混合调用
|
||||
# 添加键 属性 偏移量 (import sys)
|
||||
"my {1[spam]} runs {0.platform}".format(sys, {'spam':'laptop'}) # 基于位置的键和属性
|
||||
"{config[spam]} {sys.platform}".format(sys = sys, config = {'spam':'laptop'}) # 基于Key的键和属性
|
||||
|
|
|
|||
|
|
@ -8,20 +8,20 @@ import sqlalchemy
|
|||
import sqlalchemy.orm
|
||||
import sqlalchemy.ext.declarative
|
||||
|
||||
# 利用数据库字符串构造engine, echo为True将打印所有的sql语句
|
||||
engine = sqlalchemy.create_engine("mysql+pymysql://username:password@hostname/dbname", encoding="utf8", echo=True)
|
||||
# 利用数据库字符串构造engine, echo为True将打印所有的sql语句, 其他数据库的链接方式可自行百度
|
||||
# engine = sqlalchemy.create_engine("mysql+pymysql://username:password@hostname/dbname", encoding="utf8", echo=True)
|
||||
engine = sqlalchemy.create_engine("mysql+pymysql://dba_0:mimadba_0@101.200.174.172/data_secret", encoding="utf8", echo=False)
|
||||
|
||||
# tset
|
||||
"""
|
||||
# 利用engine创建connection,这里不需要close操作
|
||||
# 利用engine创建connection,因为使用了with所以不需要close操作,这部分不是重点
|
||||
with engine.connect() as conn:
|
||||
# 最基础的用法
|
||||
result = conn.execute("select * from tablename limit 10;")
|
||||
for item in result:
|
||||
print(item)
|
||||
|
||||
# execute的几种用法,这里具体还是得参考pymysql的用法,这里不需要执行commit操作
|
||||
conn.execute("insert into tablename(id, url, title) values(1, "url1", "title1");")
|
||||
# execute的几种用法,这里具体还是得参考pymysql的用法,不需要执行commit操作
|
||||
conn.execute("insert into tablename(id, url, title) values(1, 'url1', 'title1');")
|
||||
conn.execute("insert into tablename(id, url, title) values(%s, %s, %s);", 2, "url2", "title2")
|
||||
conn.execute("insert into tablename(id, url, title) values(%s, %s, %s)", (3, "url3", "title3"))
|
||||
conn.execute("insert into tablename(id, url, title) values(%s, %s, %s)", [(31, "url31", "title31"), (32, "url32", "title32")])
|
||||
|
|
@ -34,66 +34,152 @@ with engine.connect() as conn:
|
|||
except Exception as excep:
|
||||
trans.rollback()
|
||||
raise
|
||||
trans.close()
|
||||
"""
|
||||
|
||||
# 利用ORM特性生成模型
|
||||
Base = sqlalchemy.ext.declarative.declarative_base()
|
||||
# 首先需要生成一个BaseModel类,作为所有模型类的基类
|
||||
BaseModel = sqlalchemy.ext.declarative.declarative_base()
|
||||
|
||||
|
||||
# 构建模型User
|
||||
class User(Base):
|
||||
__tablename__ = "User"
|
||||
# 构建数据模型User
|
||||
class User(BaseModel):
|
||||
__tablename__ = "Users" # 表名
|
||||
__table_args__ = {
|
||||
'mysql_engine': 'InnoDB',
|
||||
'mysql_charset': 'utf8'
|
||||
"mysql_engine": "InnoDB", # 表的引擎
|
||||
"mysql_charset": "utf8", # 表的编码格式
|
||||
}
|
||||
|
||||
# 表结构,具体更多的数据类型自行百度
|
||||
id = sqlalchemy.Column("id", sqlalchemy.Integer, primary_key=True, autoincrement=True)
|
||||
name = sqlalchemy.Column("name", sqlalchemy.String(50), default="", unique=True)
|
||||
age = sqlalchemy.Column("age", sqlalchemy.Integer, nullable=False)
|
||||
name = sqlalchemy.Column("name", sqlalchemy.String(50), nullable=False)
|
||||
age = sqlalchemy.Column("age", sqlalchemy.Integer, default=0)
|
||||
|
||||
# 添加角色id外键(关联到Role.id属性)
|
||||
role_id = sqlalchemy.Column("role_id", sqlalchemy.Integer, sqlalchemy.ForeignKey("Roles.id"), default=-1)
|
||||
|
||||
# 添加关系属性(关联到role_id外键上)
|
||||
role = sqlalchemy.orm.relationship("Role", foreign_keys="User.role_id", backref="User_role")
|
||||
|
||||
|
||||
# 构建数据模型Role
|
||||
class Role(BaseModel):
|
||||
__tablename__ = "Roles" # 表名
|
||||
__table_args__ = {
|
||||
"mysql_engine": "InnoDB", # 表的引擎
|
||||
"mysql_charset": "utf8", # 表的编码格式
|
||||
}
|
||||
|
||||
# 表结构,具体更多的数据类型自行百度
|
||||
id = sqlalchemy.Column("id", sqlalchemy.Integer, primary_key=True)
|
||||
name = sqlalchemy.Column("name", sqlalchemy.String(50), unique=True)
|
||||
|
||||
# 添加关系属性(关联到User.role_id属性上)
|
||||
users = sqlalchemy.orm.relationship("User", foreign_keys='User.role_id', backref="Role_users")
|
||||
|
||||
|
||||
# 利用Session对象连接数据库
|
||||
DBSessinon = sqlalchemy.orm.sessionmaker(bind=engine) # 创建会话类
|
||||
session = DBSessinon() # 创建会话对象
|
||||
|
||||
# 创建表（如果表已经存在，则不会创建）
|
||||
Base.metadata.create_all(engine)
|
||||
|
||||
# 删除所有表
|
||||
BaseModel.metadata.drop_all(engine)
|
||||
# 创建所有表,如果表已经存在,则不会创建
|
||||
BaseModel.metadata.create_all(engine)
|
||||
|
||||
try:
|
||||
# 清空数据,不需要commit操作
|
||||
session.query(User).filter(User.id != -1).delete()
|
||||
session.query(Role).filter(Role.id != -1).delete()
|
||||
# 删除数据的另外一种形式:session.delete()
|
||||
|
||||
# 插入数据,这里的一个user只插入一次,第二次插入不生效
|
||||
user = User(name="tobi", age=20)
|
||||
# 插入数据,这里的一个实例只插入一次,第二次插入不生效
|
||||
session.add(Role(id=1, name="student"))
|
||||
session.add(Role(id=2, name="teacher"))
|
||||
session.commit()
|
||||
|
||||
session.add(User(name="James", age=20, role_id=1))
|
||||
session.add(User(name="Wade", age=40, role_id=2))
|
||||
session.commit()
|
||||
|
||||
user = User(name="Kobe", age=24, role_id=1)
|
||||
session.add(user)
|
||||
session.commit()
|
||||
|
||||
# 修改数据
|
||||
user.name = "allen"
|
||||
user.name = "Allen"
|
||||
session.merge(user) # 使用merge方法,如果存在则修改,如果不存在则插入
|
||||
session.query(User).filter(User.id == user.id).update({"name": "carol"}) # 使用update方法
|
||||
session.query(User).filter(User.id == user.id).update({User.name: "Allen"}) # 使用update方法
|
||||
session.query(User).filter(User.id == user.id).update({User.age: User.age + 1}) # 使用update方法,自增操作
|
||||
|
||||
# 查询数据
|
||||
roles = session.query(Role) # 返回全部结果
|
||||
for role in roles:
|
||||
print("Role:", role.id, role.name)
|
||||
|
||||
users = session.query(User) # 返回全部结果
|
||||
for user in users:
|
||||
print(user.id, user.name, user.age)
|
||||
user = session.query(User).get(2) # 返回结果集的第二项
|
||||
users = session.query(User)[1:3] # 返回结果集中的第2-3项
|
||||
print("User:", user.id, user.name, user.age, user.role_id)
|
||||
|
||||
# 其他获取数据的方式
|
||||
print("get(id):", session.query(User).get(1)) # 返回结果集中id为1的项
|
||||
print("get[1:3]:", session.query(User)[1:3]) # 返回结果集中的第2-3项
|
||||
|
||||
# 其他高级查询,这里以Users表为例
|
||||
users = session.query(User).filter(User.id > 6) # 条件查询
|
||||
users = session.query(User).filter(User.id > 6).all() # 条件查询,返回查询的全部数据
|
||||
user = session.query(User).filter(User.id > 6).first() # 条件查询,返回查询数据的第一项
|
||||
users = session.query(User).filter(User.id > 6).limit(10) # 条件查询,返回最多10条数据
|
||||
users = session.query(User).filter(User.id > 6).offset(2) # 条件查询,从第3条数据开始返回
|
||||
|
||||
users = session.query(User).filter(User.id > 6, User.name == "Kobe") # 条件查询,and操作
|
||||
users = session.query(User).filter(User.id > 6).filter(User.name == "Kobe") # 条件查询,and操作
|
||||
users = session.query(User).filter(sqlalchemy.or_(User.id > 6, User.name == "Kobe")) # 条件查询,or操作
|
||||
users = session.query(User).filter(User.id.in_((1, 2))) # 条件查询,in操作
|
||||
users = session.query(User).filter(sqlalchemy.not_(User.name)) # 条件查询,not操作
|
||||
|
||||
user_count = session.query(User.id).count() # 统计全部user的数量
|
||||
user_count = session.query(sqlalchemy.func.count(User.id)).scalar() # scalar操作返回第一行数据的第一个字段
|
||||
session.query(sqlalchemy.func.count("*")).select_from(User).scalar() # scalar操作返回第一行数据的第一个字段
|
||||
session.query(sqlalchemy.func.count(1)).select_from(User).scalar() # scalar操作返回第一行数据的第一个字段
|
||||
session.query(sqlalchemy.func.count(User.id)).filter(User.id > 0).scalar() # filter() 中包含 User，因此不需要指定表
|
||||
|
||||
session.query(sqlalchemy.func.sum(User.age)).scalar() # 求和运算,运用scalar函数
|
||||
session.query(sqlalchemy.func.avg(User.age)).scalar() # 求均值运算,运用scalar函数
|
||||
session.query(sqlalchemy.func.md5(User.name)).filter(User.id == 1).scalar() # 运用md5函数
|
||||
|
||||
users = session.query(sqlalchemy.distinct(User.name)) # 去重查询,根据name进行去重
|
||||
users = session.query(User).order_by(User.name) # 排序查询,正序查询
|
||||
users = session.query(User).order_by(User.name.desc()) # 排序查询,倒序查询
|
||||
users = session.query(User).order_by(sqlalchemy.desc(User.name)) # 排序查询,倒序查询的另外一种形式
|
||||
|
||||
# 其他高级查询
|
||||
user = session.query(User).filter(User.id < 6).first() # 条件查询
|
||||
users = session.query(User).order_by(User.name) # 排序查询
|
||||
users = session.query(User).order_by(sqlalchemy.desc(User.name)) # 排序查询之倒序
|
||||
users = session.query(User.id, User.name) # 只查询部分属性
|
||||
users = session.query(User.name.label("user_name")).all() # 给结果集的列取别名
|
||||
for user in users: print(user.user_name) # 这里使用别名
|
||||
users = session.query(sqlalchemy.distinct(User.name)).all() # 去重查询
|
||||
user_count = session.query(User.name).count() # 统计全部数量
|
||||
age_avg = session.query(sqlalchemy.func.avg(User.age)).first() # 求平均值
|
||||
age_sum = session.query(sqlalchemy.func.sum(User.age)).first() # 求和运算
|
||||
users = session.query(User.name.label("user_name")) # 结果集的列取别名
|
||||
for user in users:
|
||||
print("label test:", user.user_name) # 这里使用别名
|
||||
|
||||
users = session.query(sqlalchemy.func.count(User.name).label("count"), User.age).group_by(User.age) # 分组查询
|
||||
for user in users:
|
||||
print("age:{0}, count:{1}".format(user.age, user.count))
|
||||
|
||||
# 多表查询
|
||||
result = session.query(User, Role).filter(User.role_id == Role.id)
|
||||
for user, role in result:
|
||||
print("user %s's role is %s" % (user.name, role.name))
|
||||
users = session.query(User).join(Role, User.role_id == Role.id)
|
||||
for user in users:
|
||||
print("user join, name:", user.name)
|
||||
|
||||
# 关联属性的用法
|
||||
roles = session.query(Role)
|
||||
for role in roles:
|
||||
print("role:%s users:" % role.name)
|
||||
for user in role.users:
|
||||
print("\t%s" % user.name)
|
||||
users = session.query(User)
|
||||
for user in users:
|
||||
print("user %s's role is %s" % (user.name, user.role.name))
|
||||
|
||||
except Exception as excep:
|
||||
session.rollback()
|
||||
raise
|
||||
|
|
|
|||
Loading…
Reference in New Issue