关于sqlalchemy的使用

说明

1. 本教程所需软件及库python3.10、sqlalchemy
2. 安装与创建库、连结库
3. 创建表、增加数据
4. 查询记录

一、sqlachemy总体使用思路

1. 在创建或连结后会返回engine(可以参考第二节安装与创建库、连结库)
2. 在创建表后会返回一个表名（可以参考第三节创建表、增加数据）
3. 使用时表名.方法.属性
4. 方法有insert,select,update,delecte
5. 与数据对接时，conn = engine.connect()—conn.execut(表方法返回的值)
6. 当数据库的数据发生改变时，要提交(conn.commit())
7. 查询时，要注意条件，有两种方法where() | or_ | and_

二、安装与创建库、连结库

1. 安装库

pip install sqlalchemy
#查看版本
sqlalchemy.__vetrsion__

2. 创建库或连结库

#连结或创建sqlite3
from sqlalchemy import create_engine
engine = create_engine(`sqlite:///db_path.db`,echo=True)
conn = engine.connect()

#连结或创建mysql
from sqlalchemy import create_engine
engine = create_engine(`mysql://user:pwd@localhoast/库名`,echo=True)
conn = engine.connect()

注：create_engine如果已经存在就连结，如果不存在就创建。

3. 在sqlachemy执行sql语句

import sqlachemy
query = sqlachemy.text("select * from 表名")#sql语句
engine = sqlachemy.create_engine(`sqlite:///db_path.db`,echo=True)
conn = engine.connect()
result_set = conn.execute(query)
print(result_set.all())
conn.close()
engine.dispose()

注：以下代码engine代表创建或检查数据库，conn代表连结数据库。

三、创建表、增加数据

1. 创建表
   创建表要用到sqlalchemy的三个库MetaData、Table、Column及类型代码

from sqlachemy import MetaData,Table,Column
meta = MetaData()
#Meta定义好的字段属性存在这，所以第二个字段就要传它
var = Table(
'表名',meta,
Clolumn('字段名',sqlachemy.类型,primary_key=True),
.......
)
meta.create_all(engine)#创建表

如果表已经存在了，就不会创建，如果不存在就创建。
2. sqlachemy字段类型

名称	字段英文	用法	说明
整形	Integer	Integer	存整数
小数			存小数
字符	String	String(字符个数)	存字符
日期	Date	Date	存年月日
–	–	–	–

注：主键primary_key=True,unique=True唯一,unllable=True不能为空。

3. 增加数据（insert）
   3.1 插入一条数据

var = 表名.insert().values(字段名=值，......)
with engine.connect() as conn:
	conn.execute(var)
	conn.commit()

1、连结conn以后执行数据库操作要用conn.execut(sqlachemy语句)
2、数据库数据有变要提交事务,conn.commit()
3、var = 表名.insert().values(字段名=值，…)是新增数据的sqlachemy语句
4、 自增长是插一次，它就增加一次，它不管你是否成功
3.2 插入多条数据

var = 表名.insert()
with engine.connect() as conn:
	conn.execute(var,[
		{'字段名':value,.......},
		{'字段名':value,.......},
		........
		])
	conn.commit()

这个要用列表，并且列表里放字典，key是字段名，value是对应的值

四、查询记录

1. sql查询语句

select * from 表名

2. 函数表达式

表名.select()

3. 结果获取

结果.fetchall()#获取所有数据
结果.fetchone()#获取第一条数据

4. 条件查询

表名.select().where(表名.c.字段名条件)
#一次只能有一个条件
#如果多个条件查询时，在后面加.where(表名.c.字段名条件)

5. and_(与)、or_(或)

from sqlachemy.sql import and_,or_
表名.select().where(or_(条件,条件.....) | and_(条件,条件.....))
# 要在where中使用and_,or_
# and_,or_可以相互嵌套

五、更新或删除

1. 更新

表名.update().where(条件).values(字段名=value)
#查询结果后再更新值，一个values可以更新多条记录或所有记录，取决于查询的结果

2. 删除

表名.delete().where(条件)
#查询结果后再删除，可以删除多条记录或所有记录，取决于查询的结果

六、关联表定义