From 851938bc08db7fb4b026721b23665eaa4ef920b8 Mon Sep 17 00:00:00 2001 From: roger_home_pc Date: Sat, 24 Jun 2023 22:31:05 +0800 Subject: [PATCH] =?UTF-8?q?sqlalchemy2=20=E5=AD=A6=E4=B9=A0=E8=BF=9B?= =?UTF-8?q?=E5=BA=A670%?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../data_prepare.py | 0 {sqlalchemy_1.0 => sqlalchemy_10}/main.py | 0 .../s1_models.py | 0 .../s2.1_insert_data.py | 0 .../s2.2_fetch_data.py | 0 .../s2.3_filter_data.py | 0 .../s2.4_update_data.py | 0 .../s2.5_delete_data.py | 0 .../s2.6_join.py | 0 sqlalchemy_14/__init__.py | 1 + .../db_schema.py | 9 +- sqlalchemy_20/config.ini | 5 + sqlalchemy_20/db.py | 197 ++++++++++++++++++ sqlalchemy_20/db_obj.py | 51 +++++ 14 files changed, 259 insertions(+), 4 deletions(-) rename {sqlalchemy_1.0 => sqlalchemy_10}/data_prepare.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/main.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s1_models.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.1_insert_data.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.2_fetch_data.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.3_filter_data.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.4_update_data.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.5_delete_data.py (100%) rename {sqlalchemy_1.0 => sqlalchemy_10}/s2.6_join.py (100%) create mode 100644 sqlalchemy_14/__init__.py rename {sqlalchemy_1.4 => sqlalchemy_14}/db_schema.py (95%) create mode 100644 sqlalchemy_20/config.ini create mode 100644 sqlalchemy_20/db.py create mode 100644 sqlalchemy_20/db_obj.py diff --git a/sqlalchemy_1.0/data_prepare.py b/sqlalchemy_10/data_prepare.py similarity index 100% rename from sqlalchemy_1.0/data_prepare.py rename to sqlalchemy_10/data_prepare.py diff --git a/sqlalchemy_1.0/main.py b/sqlalchemy_10/main.py similarity index 100% rename from sqlalchemy_1.0/main.py rename to sqlalchemy_10/main.py diff --git a/sqlalchemy_1.0/s1_models.py b/sqlalchemy_10/s1_models.py similarity index 100% rename from sqlalchemy_1.0/s1_models.py rename to sqlalchemy_10/s1_models.py diff --git a/sqlalchemy_1.0/s2.1_insert_data.py b/sqlalchemy_10/s2.1_insert_data.py similarity index 100% rename from sqlalchemy_1.0/s2.1_insert_data.py rename to sqlalchemy_10/s2.1_insert_data.py diff --git a/sqlalchemy_1.0/s2.2_fetch_data.py b/sqlalchemy_10/s2.2_fetch_data.py similarity index 100% rename from sqlalchemy_1.0/s2.2_fetch_data.py rename to sqlalchemy_10/s2.2_fetch_data.py diff --git a/sqlalchemy_1.0/s2.3_filter_data.py b/sqlalchemy_10/s2.3_filter_data.py similarity index 100% rename from sqlalchemy_1.0/s2.3_filter_data.py rename to sqlalchemy_10/s2.3_filter_data.py diff --git a/sqlalchemy_1.0/s2.4_update_data.py b/sqlalchemy_10/s2.4_update_data.py similarity index 100% rename from sqlalchemy_1.0/s2.4_update_data.py rename to sqlalchemy_10/s2.4_update_data.py diff --git a/sqlalchemy_1.0/s2.5_delete_data.py b/sqlalchemy_10/s2.5_delete_data.py similarity index 100% rename from sqlalchemy_1.0/s2.5_delete_data.py rename to sqlalchemy_10/s2.5_delete_data.py diff --git a/sqlalchemy_1.0/s2.6_join.py b/sqlalchemy_10/s2.6_join.py similarity index 100% rename from sqlalchemy_1.0/s2.6_join.py rename to sqlalchemy_10/s2.6_join.py diff --git a/sqlalchemy_14/__init__.py b/sqlalchemy_14/__init__.py new file mode 100644 index 0000000..ae5be51 --- /dev/null +++ b/sqlalchemy_14/__init__.py @@ -0,0 +1 @@ +__all__ = ['db_schema'] \ No newline at end of file diff --git a/sqlalchemy_1.4/db_schema.py b/sqlalchemy_14/db_schema.py similarity index 95% rename from sqlalchemy_1.4/db_schema.py rename to sqlalchemy_14/db_schema.py index a3eafb5..39efe5d 100644 --- a/sqlalchemy_1.4/db_schema.py +++ b/sqlalchemy_14/db_schema.py @@ -1,6 +1,6 @@ import sqlalchemy from sqlalchemy.orm import declarative_base, sessionmaker, Session, relationship, backref # declarative 声明式 -from sqlalchemy import create_engine, Column, Integer, String, DATE, Enum, desc, or_, and_, update, case, union, \ +from sqlalchemy import create_engine, Column, Integer, String, DATE, Enum, func, desc, or_, and_, update, case, union, \ union_all # 创建数据引擎 @@ -107,6 +107,7 @@ user_data_2 = User(name="honey", password='123456') # result = session.query(User).filter(User.id == 1).one_or_none() # one_or_none 当查询结果仅一条时显示返回结果，当没有结果时返回None，否则抛出异常 # result = session.query(User).filter(User.id == 1).scalar() # 调用one方法，并在成功时返回行的第一列 result = session.query(User).filter(User.id > 1).group_by(User.password) +# result = session.query(func.max(User.id)).all() # func.max # print(result[0].name, result[0].password) print(result) # 定义 __repr__ 后可以打印 @@ -154,9 +155,9 @@ print(result) # 定义 __repr__ 后可以打印 # session.commit() # delete -result = session.query(User).filter(User.name == 'delete').delete() -print(result) -session.commit() +# result = session.query(User).filter(User.name == 'delete').delete() +# print(result) +# session.commit() # 关闭session session.close() diff --git a/sqlalchemy_20/config.ini b/sqlalchemy_20/config.ini new file mode 100644 index 0000000..3593228 --- /dev/null +++ b/sqlalchemy_20/config.ini @@ -0,0 +1,5 @@ +[db_source] +sqlalchemy.url=mysql+pymysql://root:Sxzgx1209@home.rogersun.cn:3306/orm_sqlalchemy?charset=utf8 +sqlalchemy.pool_size=1 +sqlalchemy.echo=debug +sqlalchemy.echo_pool=debug \ No newline at end of file diff --git a/sqlalchemy_20/db.py b/sqlalchemy_20/db.py new file mode 100644 index 0000000..9d9f01d --- /dev/null +++ b/sqlalchemy_20/db.py @@ -0,0 +1,197 @@ +from sqlalchemy import create_engine, text, insert, update, select, delete, engine_from_config +from sqlalchemy.orm import Session, sessionmaker +import configparser +import sys + +sys.path.append(r'..') +from sqlalchemy_14.db_schema import User, Student + +# 创建引擎 +HOST = "home.rogersun.cn" +USER = "root" +PWD = "Sxzgx1209" +PORT = "3306" +DB = "orm_sqlalchemy" + +URI = f"mysql+pymysql://{USER}:{PWD}@{HOST}:{PORT}/{DB}?charset=utf8" + +engine = create_engine( + URI, + echo=True, # echo = 'debug' + future=True, # 使用2.0接口 + pool_size=5, # 连接池设置，0表示无限制 + max_overflow=0, # 设置溢出 + pool_timeout=30, # + pool_recycle=3600, # 设置时间以限制多久自动断开 + pool_logging_name='test_pool', # + pool_pre_ping=True, + isolation_level="AUTOCOMMIT", + query_cache_size=200, +) + +# 从配置文件获取数据库链接 +# config = configparser.ConfigParser() +# config.read_file(open('config.ini', 'r')) +# print(config.items('db_source')) +# engine = engine_from_config(dict(config.items('db_source')), pool_size=1, max_overflow=0, pool_timeout=0.1) + +# 执行纯sql +# 无参数 +# stmt = text("SELECT * FROM user") +# with engine.connect() as conn: +# result = conn.execute(stmt).all() +# print(result) + +# 有参数 +# with engine.connect() as conn: +# stmt = text("INSERT INTO user (name, password) VALUES (:name, :password)") +# params = [{'name': 'test1', 'password': 'test1pwd'}, {'name': 'test2', 'password': 'test2pwd'}] +# result = conn.execute(stmt, params) +# print(result) +# conn.commit() + +# 绑定参数 todo 不成功 +# with engine.connect() as conn: +# stmt = text("INSERT INTO user (name, password) VALUES (:name, :password)").bindparams( +# {'name': 'test3', 'password': 'test3pwd'}) +# result = conn.execute(stmt) +# print(result) +# conn.commit() + +# 获取结果 +stmt = text("SELECT * FROM user") +with engine.connect() as conn: + result = conn.execute(stmt) + # 解包赋值 + # for _id, name, password in result: + # print(f"name: {name}, password: {password}") + # 列指定的名称 + # for row in result: + # name, password = row.name, row.password + # print(f"name: {name}, password: {password}") + # 绑定模型 + # result: [User] = result.fetchall() + # for row in result: + # name = row.name + # password = row.password + # print(f"name: {name}, password: {password}") + +# 创建Session实例 +# with Session(engine) as session: +# stmt = text("SELECT * FROM user") +# result = session.execute(stmt) +# for row in result: +# print(f"name: {row.name} - password: {row.password}") + +# 2.0 增删改查 +db_session = sessionmaker(bind=engine)() +# insert 方式1 +# insert_stmt = insert(User).values({'name': 'sql2_test1', 'password': 'pwd1'}) +# with db_session as sess: +# result = sess.execute(insert_stmt) +# print(result) +# sess.commit() + +# insert 方式2 +insert_stmt2 = insert(User) +insert_data2 = {'name': 'sql2_test2', 'password': 'pwd2'} +# with db_session as sess: +# result = sess.execute(insert_stmt2, insert_data2) +# print(result) +# sess.commit() + +# insert 批量插入 +# insert_data3 = [{'name': 'sql2_test3', 'password': 'pwd3'}, {'name': 'sql2_test4', 'password': 'pwd4'}] +# with db_session as sess: +# result = sess.execute(insert_stmt2, insert_data3) +# sess.commit() + +# insert begin方式 +# insert_data4 = [{'name': 'sql2_test5', 'password': 'pwd5'}, {'name': 'sql2_test6', 'password': 'pwd6'}] +# with db_session.begin(): +# db_session.execute(insert_stmt2, insert_data4) +# db_session.commit() +# +# insert 对像方式 +# insert_obj1 = User(name='sql2_test7', password='pwd7') +# with db_session as sess: +# sess.add(insert_obj1) +# sess.commit() + +# insert 对象方式 批量 +# insert_obj2 = User(name='sql2_test8', password='pwd8') +# insert_obj3 = User(name='sql2_test9', password='pwd9') +# with db_session as sess: +# # sess.bulk_save_objects([insert_obj2, insert_obj3]) +# sess.add_all([insert_obj2, insert_obj3]) +# sess.commit() + +# 查 +# get 通过id +# result = db_session.get(User, 4) +# print(result) + +# select all scalars +# result = db_session.execute(select(User)).scalars().all() # [<1 name:rogersun>, <2 name:honeyhoney>, <3 name:haha>] +# print(result) +# for row in result: +# print(f"{row.name} - {row.password}") + +# select all +# result = db_session.execute(select(User)).all() # [(<1 name:rogersun>,), (<2 name:honeyhoney>,), (<3 name:haha>,)] +# print(result) +# for row in result: +# print(f"{row[0].name} - {row[0].password}") + +# select filter_by +# result = db_session.execute(select(User).filter_by(name='roger')).fetchone() +# print(result[0].name) + +# select filter +# result = db_session.execute(select(User).where(User.id <= 4)).scalars().all() +# print(result) +# print(r[0][0].name) + +# select from_statement +# result = db_session.execute(select(User).from_statement(text('SELECT * FROM user'))).scalars().all() +# for row in result: +# print(row.name) + +# 遍历数据 + +# 元组赋值 all +# result = db_session.execute(select(User.id, User.name, User.password).where(User.id <= 4)).all() +# print(result) +# for _id, name, password in result: +# print(f"{_id} - {name} - {password}") + +# # 索引 all +# result = db_session.execute(select(User).where(User.id <= 4)).all() +# print(result) +# for row in result: +# _id, name, password = row[0].id, row[0].name, row[0].password +# print(f"{_id} - {name} - {password}") + +# # 属性 scalers +# result = db_session.execute(select(User).where(User.id <= 4)).scalars().all() +# print(result) +# for row in result: +# _id, name, password = row.id, row.name, row.password +# print(f"{_id} - {name} - {password}") + +# # 映射 +# result = db_session.execute(select(User.id, User.name, User.password).where(User.id <= 4)) +# print(result) +# for dict_row in result.mappings(): +# _id, name, password = dict_row['id'], dict_row['name'], dict_row['password'] +# print(f"{_id} - {name} - {password}") + +# update +# r = db_session.execute(update(User).filter_by(name='roger').values(password='rogerpwd123').execution_options( +# synchronize_session='evaluate')) +# print(r) +# db_session.commit() +# synchronize_session 有三种选项： false, "fetch", "evaluate"，默认是 evaluate +# false 表示完全不更新 Python 中的对象 +# fetch 表示重新从数据库中加载一份对象 +# evaluate 表示在更新数据库的同时，也尽量在 Python 中的对象上使用同样的操作 diff --git a/sqlalchemy_20/db_obj.py b/sqlalchemy_20/db_obj.py new file mode 100644 index 0000000..42e0359 --- /dev/null +++ b/sqlalchemy_20/db_obj.py @@ -0,0 +1,51 @@ +from sqlalchemy.orm import declarative_base +from db import engine +from sqlalchemy import Table, Column, Integer, String, Enum, DATE, MetaData + +Base = declarative_base() + + +# 创建表结构 -- 声名式 +class User(Base): + __tablename__ = 'user' + id = Column(Integer, primary_key=True) + name = Column(String(32)) + password = Column(String(64)) + + def __repr__(self): + return "<%s name:%s>" % (self.id, self.name) + + +class Student(Base): + __tablename__ = 'student' + id = Column(Integer, primary_key=True) + name = Column(String(32), nullable=False) + gender = Column(Enum('m', 'f'), nullable=False) + date = Column(DATE, nullable=False) + + def __repr__(self): + return f"<{self.id}-{self.name}-{self.gender}-{self.date}>" + + +Base.metadata.create_all(engine) + +# 创建表结构 -- 命令式 + +metadata = MetaData() # 生成metadata + +user = Table( + 'user', + metadata, + Column('id', Integer, primary_key=True), + Column('name', String(32)), + Column('password', String(64)) +) + +student = Table( + 'student', + metadata, + Column('id', Integer, primary_key=True), + Column('name', String(32), nullable=False), + Column('gender', Enum('m', 'f'), nullable=False), + Column('date', DATE, nullable=False) +)