18-Python SQLAIchemy 操作 MySQL（关系型数据库）「2023年」

(PythonCoderVenv) ➜  MacBookPro16-Code git:(main) ✗ pip install sqlalchemy pymysql
Collecting sqlalchemy
  Downloading SQLAlchemy-1.4.46.tar.gz (8.5 MB)
     ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 8.5/8.5 MB 10.5 MB/s eta 0:00:00
  Preparing metadata (setup.py) ... done
Collecting pymysql
  Downloading PyMySQL-1.0.2-py3-none-any.whl (43 kB)
     ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ 43.8/43.8 kB 5.4 MB/s eta 0:00:00
Installing collected packages: sqlalchemy, pymysql
  DEPRECATION: sqlalchemy is being installed using the legacy 'setup.py install' method, because it does not have a 'pyproject.toml' and the 'wheel' package is not installed. pip 23.1 will enforce this behaviour change. A possible replacement is to enable the '--use-pep517' option. Discussion can be found at https://github.com/pypa/pip/issues/8559
  Running setup.py install for sqlalchemy ... done
Successfully installed pymysql-1.0.2 sqlalchemy-1.4.46

from sqlalchemy import create_engine

engine = create_engine(
    "mysql+pymysql://root:123123@127.0.0.1:3306/test",
    max_overflow=5,
    pool_size=10,
    echo=True,
)

from sqlalchemy import create_engine
# from sqlalchemy import Column
from sqlalchemy import Table, Column
from datetime import datetime
from sqlalchemy import Table, Column, String, Integer, Boolean, MetaData, DateTime

# 链接数据库
engine = create_engine(
    "mysql+pymysql://root:123456@127.0.0.1:3306/test",
    max_overflow=5,
    pool_size=10,
    echo=True,
)

metadata = MetaData() # 取得元数据，介绍数据库
# 获取元数据，这个元数据相当于你对这个数据库的一些描述，你也可以什么都不写。因为，我们没必要在里面写，直接在 sqlalchemy 里面导入 MetaData 就可以了。
# Column：字段
# default：默认
test=Table('数据名称/表名称',元数据(metadata),
          Column('字段名称','字段类型',对这个字段的描述，比如说：第一个时主键，那就写(primary_key=True),自动增长也是 True(autoincrement=True)也就是说，),
           # 这个自动增长就是说，这个 id 作为主键，当表里面的内容不断增加，该 id 也自动增加。
          Column('name',String(255)),
           # 然后，第一个字段是我们的 名字（name），最长 255个字节
          Column('data',DateTime(),default=datetime.now,onupdate=datetime.now),
           # 第二个数据就是我们的时间('date'),数据类型时 Datetime(),default=datetime.now()也就是现在时间
          Column('main',Boolean(),default=False),
          # 是不是男性，类型就是布尔值，default=False 默认不是男性
          )

# -*- coding: utf-8 -*-
# @Time    : 2023/1/8 10:09
# @Author  : AI悦创
# @FileName: demo.py
# @Software: PyCharm
# @Blog    ：https://bornforthis.cn/
from sqlalchemy import create_engine
# from sqlalchemy import Column
from sqlalchemy import Table, Column
from datetime import datetime
from sqlalchemy import Table, Column, String, Integer, Boolean, MetaData, DateTime

# 链接数据库
engine = create_engine(
    "mysql+pymysql://root:123456@127.0.0.1:3306/test",
    max_overflow=5,
    pool_size=10,
    echo=True,
)

metadata = MetaData()  # 取得元数据，介绍数据库
# 获取元数据，这个元数据相当于你对这个数据库的一些描述，你也可以什么都不写。因为，我们没必要在里面写，直接在 sqlalchemy 里面导入 MetaData 就可以了。
# Column：字段
# default：默认
test = Table("test", metadata,
             Column("id", Integer(), primary_key=True, autoincrement=True),
             Column("name", String(255)),
             Column("data", DateTime(), default=datetime.now, onupdate=datetime.now),
             Column("main", Boolean(), default=False))
metadata.create_all(engine)

/Users/huangjiabao/GitHub/SourceCode/MacBookPro16-Code/PythonCoder/PythonCoderVenv/bin/python /Users/huangjiabao/GitHub/SourceCode/MacBookPro16-Code/PythonCoder/StudentCoder/07cava/mysql_demo/demo.py 
2023-01-08 10:35:08,899 INFO sqlalchemy.engine.Engine SELECT DATABASE()
2023-01-08 10:35:08,899 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 10:35:08,900 INFO sqlalchemy.engine.Engine SELECT @@sql_mode
2023-01-08 10:35:08,900 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 10:35:08,900 INFO sqlalchemy.engine.Engine SELECT @@lower_case_table_names
2023-01-08 10:35:08,900 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 10:35:08,901 INFO sqlalchemy.engine.Engine BEGIN (implicit)
2023-01-08 10:35:08,901 INFO sqlalchemy.engine.Engine SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = %(table_schema)s AND table_name = %(table_name)s
2023-01-08 10:35:08,901 INFO sqlalchemy.engine.Engine [generated in 0.00006s] {'table_schema': 'test', 'table_name': 'test'}
2023-01-08 10:35:08,906 INFO sqlalchemy.engine.Engine 
CREATE TABLE test (
	id INTEGER NOT NULL AUTO_INCREMENT, 
	name VARCHAR(255), 
	data DATETIME, 
	main BOOL, 
	PRIMARY KEY (id)
)


2023-01-08 10:35:08,906 INFO sqlalchemy.engine.Engine [no key 0.00008s] {}
2023-01-08 10:35:08,929 INFO sqlalchemy.engine.Engine COMMIT

Process finished with exit code 0

mysql> show tables;
+----------------+
| Tables_in_test |
+----------------+
| test           |
+----------------+
1 row in set (0.00 sec)

# Python 中 sqlalchemy 的语句：
test = Table("test", metadata,
             Column("id", Integer(), primary_key=True, autoincrement=True),
             Column("name", String(255)),
             Column("data", DateTime(), default=datetime.now, onupdate=datetime.now),
             Column("main", Boolean(), default=False))

# MySQL 原生语句：
CREATE TABLE test1 (
	id INTEGER NOT NULL AUTO_INCREMENT, 
	name VARCHAR(255), 
	data DATETIME, 
	main BOOL, 
	PRIMARY KEY (id)
)

mysql> desc test;
+-------+--------------+------+-----+---------+----------------+
| Field | Type         | Null | Key | Default | Extra          |
+-------+--------------+------+-----+---------+----------------+
| id    | int          | NO   | PRI | NULL    | auto_increment |
| name  | varchar(255) | YES  |     | NULL    |                |
| data  | datetime     | YES  |     | NULL    |                |
| main  | tinyint(1)   | YES  |     | NULL    |                |
+-------+--------------+------+-----+---------+----------------+
4 rows in set (0.00 sec)

# 连接数据库的样板代码
from sqlalchemy import create_engine,MetaData,Table


def  my_dabase_big():
	def my_database():
		engine = create_engine(
			"mysql+pymysql://root:123456@127.0.0.1:3306/test",# （里面的 root 要填写你的密码）,注意：mysql+pymysql 之间不要加空格
			# "mysql + pymysql://root:root@localhost/test",
			max_overflow = 5, # 超过连接池大小之后，外最多可以创建的链接
			pool_size = 10, # 连接池大小
			echo = True, # 调试信息展示
		)
	my_database()
my_dabase_big()
metadata = MetaData() # 取得元素据，介绍数据库
# ------------当你上面创建好该表之后，就可以把这一个创建表的代码删除------------
test=Table('test',metadata,
          Column('id',Integer(),primary_key=True,autoincrement=True),
          #  Column：字段，我们可以存储各种字段,
          #  第一个就是我们的字段名称（取个名字）
          #  第二个是类型（数据类型）
          #  第三个是对这个字段的描述（例如第一个是主键，我就 True，自动增长 autoincrement,也就是我每增加一条信息，他的 ID 就增加 1
          Column('name',String(255)),
           # 接下来就是我们的第一个字段， name，后面定义它最长 255 个字节
          Column('data',DateTime(),default=datetime.now,onupdate=datetime.now,
          #  第二个我们存储日期，然后，使用 default 默认就是我们现在的时间
          Column('man',Boolean(),default=False),
           # man 是不是男性，（当然添加其他的也是可以的），使用了 布尔值(Bookean()) 默认不是男性 default=False
           )
# ------------当你上面创建好该表之后，也可以不把创建的代码删除，把这一句删除即可：metadata.create_all(engine) # 创建数据表------------
conn = engine.connect() # 获取一个连接
a = conn.begin()  # 开始一个事物
# 然后，接下来。我们就开始执行

try:
	# 我们在这个事物中的表：test 插入入一个数据，也就是表中的 ：name下面的数据插入 lol3
	conn.execute(test.insert(),{'name':'lol3'})
	print(1/0) # 这里我们故意让代码出错去执行 rollback()
	a.commit() # 最后提交即可

except:
	a.rollback()
# 	我们来重点说一下这个事物回滚：
# 在上面的 try:...except:...中的代码，在我们故意出错之前是正常执行了在数据库表中插入的操作。
# 但这个代码出错的时候就回滚操作，那这个回顾就会撤销你刚刚所作出来的修改（或者说操作回退，就是类似于没有执行。譬如：文本操作中的 Control + Z）的操作。
# 因为，我（程序）已经发生错误，保证数据库表的完整性，类似于文件的开启就要有关闭（保证文件数据的完整性一个意思）

# -*- coding: utf-8 -*-
# @Time    : 2023/1/8 11:03
# @Author  : AI悦创
# @FileName: demo2.py
# @Software: PyCharm
# @Blog    ：https://bornforthis.cn/
from sqlalchemy import create_engine
# from sqlalchemy import Column
from sqlalchemy import Table, Column
from datetime import datetime
from sqlalchemy import Table, Column, String, Integer, Boolean, MetaData, DateTime

# 链接数据库
engine = create_engine(
    "mysql+pymysql://root:123456@127.0.0.1:3306/test",
    max_overflow=5,
    pool_size=10,
    echo=True,
)

metadata = MetaData()  # 取得元数据，介绍数据库
# 获取元数据，这个元数据相当于你对这个数据库的一些描述，你也可以什么都不写。因为，我们没必要在里面写，直接在 sqlalchemy 里面导入 MetaData 就可以了。
# Column：字段
# default：默认
test = Table("test", metadata,
             Column("id", Integer(), primary_key=True, autoincrement=True),
             Column("name", String(255)),
             Column("data", DateTime(), default=datetime.now, onupdate=datetime.now),
             Column("main", Boolean(), default=False))
# metadata.create_all(engine)
conn = enging.connect()  # 获取一个链接
a = conn.begin()  # 开始一个事务
# 然后，接下来。我们就开始执行

try:
    # 我们在这个事务中的表：test 插入入一个数据，也就是表中的 ：name 下面的数据插入 lol3
    conn.execute(test.insert(), {"name": "lol3"})
    print(1 / 0)  # 这里我们故意让代码出错去执行 rollback()
    a.commit()  # 最后提交即可
except:
    a.rollback()

# 	我们来重点说一下这个事物回滚：
# 在上面的 try:...except:...中的代码，在我们故意出错之前是正常执行了在数据库表中插入的操作。
# 但这个代码出错的时候就回滚操作，那这个回顾就会撤销你刚刚所作出来的修改（或者说操作回退，就是类似于没有执行。譬如：文本操作中的 Control + Z）的操作。
# 因为，我（程序）已经发生错误，保证数据库表的完整性，类似于文件的开启就要有关闭（保证文件数据的完整性一个意思）

2023-01-08 11:11:57,239 INFO sqlalchemy.engine.Engine SELECT DATABASE()
2023-01-08 11:11:57,239 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:11:57,241 INFO sqlalchemy.engine.Engine SELECT @@sql_mode
2023-01-08 11:11:57,241 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:11:57,242 INFO sqlalchemy.engine.Engine SELECT @@lower_case_table_names
2023-01-08 11:11:57,242 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:11:57,242 INFO sqlalchemy.engine.Engine BEGIN (implicit)
2023-01-08 11:11:57,243 INFO sqlalchemy.engine.Engine INSERT INTO test (name, data, main) VALUES (%(name)s, %(data)s, %(main)s)
2023-01-08 11:11:57,243 INFO sqlalchemy.engine.Engine [generated in 0.00013s] {'name': 'lol3', 'data': datetime.datetime(2023, 1, 8, 11, 11, 57, 243463), 'main': 0}
2023-01-08 11:11:57,247 INFO sqlalchemy.engine.Engine ROLLBACK

/Users/huangjiabao/GitHub/SourceCode/MacBookPro16-Code/PythonCoder/PythonCoderVenv/bin/python /Users/huangjiabao/GitHub/SourceCode/MacBookPro16-Code/PythonCoder/StudentCoder/07cava/mysql_demo/demo2.py 
2023-01-08 11:27:37,726 INFO sqlalchemy.engine.Engine SELECT DATABASE()
2023-01-08 11:27:37,726 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:27:37,726 INFO sqlalchemy.engine.Engine SELECT @@sql_mode
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine SELECT @@lower_case_table_names
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine [raw sql] {}
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine BEGIN (implicit)
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine SELECT COUNT(*) FROM information_schema.tables WHERE table_schema = %(table_schema)s AND table_name = %(table_name)s
2023-01-08 11:27:37,727 INFO sqlalchemy.engine.Engine [generated in 0.00006s] {'table_schema': 'test', 'table_name': 'user'}
2023-01-08 11:27:37,731 INFO sqlalchemy.engine.Engine 
CREATE TABLE user (
	id INTEGER NOT NULL AUTO_INCREMENT, 
	name VARCHAR(10), 
	PRIMARY KEY (id)
)


2023-01-08 11:27:37,731 INFO sqlalchemy.engine.Engine [no key 0.00008s] {}
2023-01-08 11:27:37,746 INFO sqlalchemy.engine.Engine COMMIT

Process finished with exit code 0

"""
# -*- coding: utf-8 -*-
# @Author：AI悦创 @DateTime ：2019/9/29  22:10 @Function ：功能  Development_tool ：PyCharm
# code is far away from bugs with the god animal protecting
    I love animals. They taste delicious.
              ┏┓      ┏┓
            ┏┛┻━━━┛┻┓
            ┃      ☃      ┃
            ┃  ┳┛  ┗┳  ┃
            ┃      ┻      ┃
            ┗━┓      ┏━┛
                ┃      ┗━━━┓
                ┃  神兽保佑    ┣┓
                ┃　永无BUG！   ┏┛
                ┗┓┓┏━┳┓┏┛
                  ┃┫┫  ┃┫┫
                  ┗┻┛  ┗┻┛
"""
# 连接数据库的样板代码
from sqlalchemy import create_engine,MetaData,Table,engine
from sqlalchemy import Column,String,Integer


engine = create_engine(
	"mysql+pymysql://root:123456@127.0.0.1:3306/test",# （里面的 root 要填写你的密码）,注意：mysql+pymysql 之间不要加空格
	# "mysql + pymysql://root:root@localhost/test",
	max_overflow = 5, # 超过连接池大小之后，外最多可以创建的链接
	pool_size = 10, # 连接池大小
	echo = True, # 调试信息展示
)

# ---------创建表-------------
metadata = MetaData() # 获得元数据，介绍数据库
# 定义表
user = Table('user',metadata,
             # 数据库表名称，元素据
             Column('id',Integer,primary_key=True,autoincrement=True),
             Column('name',String(10)))
# metadata.create_all(engine) # 创建数据表

# ---------------实施增删查改的操作--------------

# 增加数据
engine.execute("insert into user (name) values ('AI悦创')")
# 更新数据
engine.execute("update user set id=5,name='python' where id=5;")
# 更新数据方法二
engine.execute("update user set name='python' where id=5;")
# 更新数据方法三
engine.execute("update user set name='20191001'")
# 删除数据
# engine.execute("delete from user") # 删除全部
# 删除指定位置
# engine.execute("delete from user where id=2")
# engine.execute("delete from user where name='AI悦创'")
# 查看数据
a = engine.execute("select * from user")
# print(a)
for text in a:
	print(text)
	print(type(text))